Path Lines of Code connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/DefaultIoTSerializationSchema.java 88 connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/Event.java 40 connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java 165 connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSource.java 64 connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTSerializationSchema.java 5 connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBOptions.java 39 connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBSinkOptions.java 66 connectors/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBSourceOptions.java 26 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/client/IoTDBWebSocketClient.java 61 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/common/Options.java 41 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/common/Utils.java 143 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalIoTDBPathException.java 6 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalOptionException.java 6 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalSchemaException.java 6 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalUrlPathException.java 6 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/UnsupportedDataTypeException.java 6 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/factory/IoTDBDynamicTableFactory.java 188 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBBoundedScanFunction.java 132 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBCDCSourceFunction.java 259 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBLookupFunction.java 117 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBSinkFunction.java 109 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/provider/IoTDBDynamicTableSink.java 38 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/provider/IoTDBDynamicTableSource.java 49 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/wrapper/SchemaWrapper.java 22 connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/wrapper/TabletWrapper.java 22 connectors/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowRecordParser.java 7 connectors/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowRowRecordParser.java 81 connectors/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowTSRecordConverter.java 136 connectors/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TSRecordConverter.java 10 connectors/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TSRecordOutputFormat.java 65 connectors/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java 124 connectors/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TsFileOutputFormat.java 94 connectors/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/util/TSFileConfigUtil.java 41 connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/TsfileWebDemoApplication.java 9 connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java 21 connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/conf/MyConfiguration.java 22 connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/controller/DatabaseConnectController.java 143 connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/dao/BasicDao.java 9 connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImpl.java 157 connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/interceptor/LoginInterceptor.java 38 connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/service/DatabaseConnectService.java 9 connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/service/impl/DatabaseConnectServiceImpl.java 21 connectors/grafana-plugin/Magefile.go 9 connectors/grafana-plugin/pkg/main.go 13 connectors/grafana-plugin/pkg/plugin/iotdb_resource_handler.go 137 connectors/grafana-plugin/pkg/plugin/plugin.go 342 connectors/grafana-plugin/src/ConfigEditor.tsx 79 connectors/grafana-plugin/src/QueryEditor.tsx 308 connectors/grafana-plugin/src/componments/AggregateFun.tsx 22 connectors/grafana-plugin/src/componments/ControlValue.tsx 19 connectors/grafana-plugin/src/componments/FillValue.tsx 19 connectors/grafana-plugin/src/componments/Form.tsx 22 connectors/grafana-plugin/src/componments/FromValue.tsx 91 connectors/grafana-plugin/src/componments/GroupBy.tsx 38 connectors/grafana-plugin/src/componments/SelectValue.tsx 91 connectors/grafana-plugin/src/componments/TimeSeries.tsx 62 connectors/grafana-plugin/src/componments/WhereValue.tsx 19 connectors/grafana-plugin/src/datasource.ts 82 connectors/grafana-plugin/src/functions.ts 3 connectors/grafana-plugin/src/module.ts 8 connectors/grafana-plugin/src/types.ts 39 connectors/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSConfUtil.java 81 connectors/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSFile.java 369 connectors/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSInput.java 77 connectors/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSOutput.java 69 connectors/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/IReaderSet.java 9 connectors/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFHadoopException.java 20 connectors/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFInputFormat.java 169 connectors/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFInputSplit.java 13 connectors/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFOutputFormat.java 31 connectors/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordReader.java 201 connectors/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordWriter.java 35 connectors/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/record/HDFSTSRecord.java 145 connectors/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveInputFormat.java 27 connectors/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveOutputFormat.java 43 connectors/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveRecordReader.java 112 connectors/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveRecordWriter.java 39 connectors/hive-connector/src/main/java/org/apache/iotdb/hive/TsFileDeserializer.java 119 connectors/hive-connector/src/main/java/org/apache/iotdb/hive/TsFileSerDe.java 119 connectors/hive-connector/src/main/java/org/apache/iotdb/hive/TsFileSerDeException.java 16 connectors/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/Converter.scala 58 connectors/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/DataFrameTools.scala 99 connectors/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/DefaultSource.scala 31 connectors/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/IoTDBOptions.scala 14 connectors/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/IoTDBRDD.scala 92 connectors/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/IoTDBRelation.scala 76 connectors/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/SQLConstant.scala 7 connectors/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/Transformer.scala 77 connectors/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/package.scala 8 connectors/spark-iotdb-table-connector/iotdb-table-connector-3.3/src/main/scala/org/apache/iotdb/spark/table/db/IoTDBTableProvider.scala 5 connectors/spark-iotdb-table-connector/iotdb-table-connector-3.4/src/main/scala/org/apache/iotdb/spark/table/db/IoTDBTableProvider.scala 5 connectors/spark-iotdb-table-connector/iotdb-table-connector-3.5/src/main/scala/org/apache/iotdb/spark/table/db/IoTDBTableProvider.scala 5 connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/AbstractIoTDBTableProvider.scala 17 connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/IoTDBOptions.scala 21 connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/IoTDBTable.scala 30 connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/IoTDBUtils.scala 138 connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/read/IoTDBExpressionSQLBuilder.scala 115 connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/read/IoTDBInputPartition.scala 5 connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/read/IoTDBPartitionReader.scala 43 connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/read/IoTDBPartitionReaderFactory.scala 10 connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/read/IoTDBScan.scala 27 connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/read/IoTDBScanBuilder.scala 62 connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/write/IoTDBDataWriter.scala 104 connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/write/IoTDBWrite.scala 10 connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/write/IoTDBWriteBuilder.scala 7 connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/write/IoTDBWriteFactory.scala 10 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/io/TsFileOutputFormat.java 21 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/io/TsFileRecordWriter.java 34 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/Executor.java 26 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/QueryProcessor.java 139 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/BasicOperator.java 38 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/FilterOperator.java 112 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/Operator.java 19 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/SQLConstant.java 105 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/SingleQuery.java 34 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/TSQueryPlan.java 39 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/BasicOperatorException.java 7 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/DNFOptimizeException.java 7 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/LogicalOptimizeException.java 7 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/MergeFilterException.java 7 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/QueryOperatorException.java 7 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/QueryProcessorException.java 13 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/RemoveNotException.java 7 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/DNFFilterOptimizer.java 89 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/IFilterOptimizer.java 9 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/MergeSingleFilterOptimizer.java 93 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/PhysicalOptimizer.java 186 connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/RemoveNotOptimizer.java 58 connectors/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/Converter.scala 74 connectors/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/DefaultSource.scala 210 connectors/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/NarrowConverter.scala 433 connectors/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/NarrowTsFileOutputWriter.scala 26 connectors/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/Transformer.scala 80 connectors/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/TsFileWriterFactory.scala 19 connectors/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/WideConverter.scala 362 connectors/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/WideTsFileOutputWriter.scala 29 connectors/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/package.scala 29 connectors/zeppelin-interpreter/src/main/java/org/apache/zeppelin/iotdb/IoTDBInterpreter.java 249