Merge pull request #197 from ni-ze/supportRsqldb

support join sql in rsqldb

Author: ni-ze

rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/FileBasedTable.java

@@ -60,9 +60,9 @@ public FileBasedTable(String fileName, int columnsCount, TableSchema schema) {
                 String fieldName = tableSchema.getField(i);
                 String fieldType = tableSchema.getFieldType(i);
                 DataType dataType = DataTypeUtil.getDataType(fieldType);
-                cloumnName2Index.put(fieldName, i);
-                index2ColumnName.put(i, fieldName);
-                cloumnName2DatatType.put(fieldName, dataType);
+                column2Index.put(fieldName, i);
+                index2Column.put(i, fieldName);
+                column2DataType.put(fieldName, dataType);
             }
         }
 

rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/MappedByteBufferTable.java

@@ -356,8 +356,8 @@ public static void writeFileMeta(MappedByteBufferTable table, File file) throws
             }
             lines.add(sb.toString());
             StringBuilder sb1 = new StringBuilder();
-            Map<Integer, String> index2ColumnName = table.getIndex2ColumnName();
-            Map<String, DataType> columnName2DataType = table.getCloumnName2DatatType();
+            Map<Integer, String> index2ColumnName = table.getIndex2Column();
+            Map<String, DataType> columnName2DataType = table.getColumn2DataType();
             int rowCount = index2ColumnName.size();
             for (int i = 0; i < rowCount; i++) {
                 String columnName = index2ColumnName.get(i);
@@ -569,9 +569,9 @@ private void loadFromFile(MappedByteBufferTable table) throws IOException {
             table.setFileOffset(meta.totalByteSize);
             table.setColumnsCount(meta.columnsCount);
             table.setFileRowCount(meta.totalRowCount);
-            table.setCloumnName2Index(meta.columnName2Index);
-            table.setIndex2ColumnName(meta.index2ColumnName);
-            table.setCloumnName2DatatType(meta.columns2DataType);
+            table.setColumn2Index(meta.columnName2Index);
+            table.setIndex2Column(meta.index2ColumnName);
+            table.setColumn2DataType(meta.columns2DataType);
             for (int i = 0; i < meta.filePaths.length; i++) {
                 String path = meta.filePaths[i];
                 int limit = meta.limits[i];