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
distributions/src/assembly/common-files.xml	19
distributions/src/assembly/flink-sql-connector.xml	21
distributions/src/assembly/grafana-connector.xml	28
distributions/src/assembly/grafana-plugin.xml	18
distributions/src/assembly/iotdb-spring-boot-starter.xml	21
distributions/src/assembly/mybatis-generator-plugin.xml	21
distributions/src/assembly/spark-connector.xml	28
helm/Chart.yaml	6
helm/templates/_helpers.tpl	73
helm/templates/confignode-cm.yaml	17
helm/templates/confignode.yaml	87
helm/templates/datanode-cm.yaml	11
helm/templates/datanode.yaml	97
helm/templates/load-balancer.yaml	11
helm/values.yaml	36
iotdb-collector/collector-core/src/assembly/core.xml	20
iotdb-collector/collector-core/src/assembly/resources/conf/logback.xml	105
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/Application.java	64
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/filter/ApiOriginFilter.java	26
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/ping/impl/PingApiServiceImpl.java	17
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/v1/plugin/impl/PluginApiServiceImpl.java	38
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/v1/plugin/impl/PluginApiServiceRequestValidationHandler.java	15
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/v1/task/impl/TaskApiServiceImpl.java	58
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/v1/task/impl/TaskApiServiceRequestValidationHandler.java	21
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/ApiServiceOptions.java	10
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/Configuration.java	86
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/Options.java	86
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/PipeRuntimeOptions.java	230
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/PluginRuntimeOptions.java	28
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/TaskRuntimeOptions.java	48
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/TrimProperties.java	28
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/persistence/DBConstant.java	30
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/persistence/Persistence.java	18
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/persistence/PluginPersistence.java	113
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/persistence/TaskPersistence.java	164
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/PullSource.java	12
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/PushSource.java	29
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/customizer/CollectorParameters.java	14
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/customizer/CollectorProcessorRuntimeConfiguration.java	18
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/customizer/CollectorRuntimeEnvironment.java	36
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/customizer/CollectorSinkRuntimeConfiguration.java	18
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/customizer/CollectorSourceRuntimeConfiguration.java	18
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/event/CollectorEvent.java	6
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/event/DemoEvent.java	15
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/event/PeriodicalEvent.java	3
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/BuiltinPlugin.java	34
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/processor/DoNothingProcessor.java	36
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/processor/SubscriptionProcessor.java	31
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/DemoSink.java	52
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/client/IoTDBClientManager.java	72
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/client/IoTDBDataNodeCacheLeaderClientManager.java	46
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/client/IoTDBDataNodeSyncClientManager.java	95
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/client/IoTDBSyncClient.java	136
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/client/IoTDBSyncClientManager.java	298
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/client/ThriftClient.java	69
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/client/ThriftClientProperty.java	74
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/compressor/PipeCompressor.java	28
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/compressor/PipeCompressorConfig.java	15
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/compressor/PipeCompressorFactory.java	78
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/compressor/PipeGZIPCompressor.java	27
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/compressor/PipeLZ4Compressor.java	27
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/compressor/PipeLZMA2Compressor.java	27
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/compressor/PipeSnappyCompressor.java	27
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/compressor/PipeZSTDCompressor.java	22
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/constant/ColumnHeaderConstant.java	9
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/constant/PipeConnectorConstant.java	193
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/constant/PipeTransferHandshakeConstant.java	13
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/event/PipeInsertionEvent.java	15
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/event/PipeRawTabletInsertionEvent.java	47
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/event/PipeTsFileInsertionEvent.java	28
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/exception/PipeRuntimeConnectorCriticalException.java	72
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/exception/PipeRuntimeCriticalException.java	66
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/exception/PipeRuntimeException.java	26
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/exception/PipeRuntimeExceptionType.java	60
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/exception/PipeRuntimeMetaVersion.java	41
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/exception/PipeRuntimeNonCriticalException.java	70
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/exception/PipeRuntimeOutOfMemoryCriticalException.java	73
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/exception/PipeStatus.java	26
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/evolvable/batch/PipeTabletEventBatch.java	56
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/evolvable/batch/PipeTabletEventPlainBatch.java	81
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/evolvable/batch/PipeTabletEventTsFileBatch.java	114
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/evolvable/batch/PipeTransferBatchReqBuilder.java	124
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/IoTDBConnectorRequestVersion.java	13
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeRequestType.java	50
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferCompressedReq.java	83
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferDataNodeHandshakeV1Req.java	33
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferDataNodeHandshakeV2Req.java	33
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferFilePieceReq.java	75
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferFileSealReqV1.java	65
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferFileSealReqV2.java	119
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferHandshakeV1Req.java	60
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferHandshakeV2Req.java	77
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferSchemaSnapshotPieceReq.java	35
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferSchemaSnapshotSealReq.java	122
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferSliceReq.java	96
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferTabletBatchReqV2.java	72
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferTabletBinaryReq.java	57
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferTabletBinaryReqV2.java	80
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferTabletRawReq.java	79
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferTabletRawReqV2.java	76
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferTsFilePieceReq.java	34
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferTsFilePieceWithModReq.java	35
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/request/PipeTransferTsFileSealWithModReq.java	100
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/payload/thrift/response/PipeTransferFilePieceResp.java	38
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/protocol/IoTDBConnector.java	408
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/protocol/IoTDBDataRegionSyncConnector.java	294
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/protocol/IoTDBSslSyncConnector.java	176
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/protocol/PipeReceiverStatusHandler.java	145
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/protocol/session/IClientSession.java	39
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/HttpPullSource.java	32
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/HttpPushSource.java	56
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/IoTDBPushSource.java	96
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/constant/IoTDBPushSourceConstant.java	13
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/event/SubDemoEvent.java	19
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/event/common/PipeBinaryTransformer.java	13
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/event/common/PipeDataTypeTransformer.java	45
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/event/common/PipeResetTabletRow.java	28
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/event/common/PipeRow.java	163
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/event/common/PipeRowCollector.java	67
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/PluginRuntime.java	165
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/constructor/PluginConstructor.java	65
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/constructor/ProcessorConstructor.java	27
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/constructor/SinkConstructor.java	29
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/constructor/SourceConstructor.java	34
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/load/PluginClassLoader.java	38
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/load/PluginClassLoaderManager.java	27
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/meta/PluginMeta.java	82
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/meta/PluginMetaKeeper.java	92
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/Task.java	39
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/TaskCombiner.java	35
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/TaskDispatch.java	26
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/TaskRuntime.java	134
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/TaskStateEnum.java	12
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/event/EventCollector.java	15
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/event/EventContainer.java	11
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/processor/ProcessorConsumer.java	36
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/processor/ProcessorExceptionHandler.java	20
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/processor/ProcessorTask.java	120
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/sink/SinkConsumer.java	33
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/sink/SinkExceptionHandler.java	20
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/sink/SinkTask.java	105
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/source/SourceTask.java	45
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/source/pull/PullSourceConsumer.java	17
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/source/pull/PullSourceTask.java	107
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/source/push/PushSourceTask.java	99
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/service/ApiService.java	70
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/service/IService.java	6
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/service/PeriodicalJobService.java	89
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/service/PersistenceService.java	52
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/service/RuntimeService.java	51
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/utils/PathUtil.java	2
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/utils/PipeMemoryWeightUtil.java	202
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/utils/PluginFileUtils.java	60
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/utils/builder/PipeTableModeTsFileBuilder.java	205
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/utils/builder/PipeTreeModelTsFileBuilder.java	200
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/utils/builder/PipeTsFileBuilder.java	73
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/utils/cacher/LeaderCacheUtils.java	29
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/utils/preiodical/ScheduledExecutorUtil.java	97
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/utils/preiodical/WrappedRunnable.java	23
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/utils/sorter/PipeTableModelTabletEventSorter.java	212
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/utils/sorter/PipeTabletEventSorter.java	81
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/utils/sorter/PipeTreeModelTabletEventSorter.java	82
iotdb-collector/collector-distribution/src/assembly/collector-core.xml	57
iotdb-collector/collector-openapi/src/main/openapi3/ping/ping.yaml	40
iotdb-collector/collector-openapi/src/main/openapi3/v1/plugin.yaml	68
iotdb-collector/collector-openapi/src/main/openapi3/v1/task.yaml	125
iotdb-operator/api/v1/common_types.go	5
iotdb-operator/api/v1/confignode_types.go	29
iotdb-operator/api/v1/confignode_webhook.go	61
iotdb-operator/api/v1/datanode_types.go	29
iotdb-operator/api/v1/datanode_webhook.go	61
iotdb-operator/api/v1/groupversion_info.go	10
iotdb-operator/api/v1/zz_generated.deepcopy.go	188
iotdb-operator/cmd/main.go	113
iotdb-operator/config/certmanager/certificate.yaml	31
iotdb-operator/config/certmanager/kustomization.yaml	4
iotdb-operator/config/certmanager/kustomizeconfig.yaml	7
iotdb-operator/config/crd/bases/iotdb.apache.org_confignodes.yaml	295
iotdb-operator/config/crd/bases/iotdb.apache.org_datanodes.yaml	295
iotdb-operator/config/crd/kustomization.yaml	8
iotdb-operator/config/crd/kustomizeconfig.yaml	16
iotdb-operator/config/crd/patches/cainjection_in_confignodes.yaml	6
iotdb-operator/config/crd/patches/cainjection_in_datanodes.yaml	6
iotdb-operator/config/crd/patches/webhook_in_confignodes.yaml	15
iotdb-operator/config/crd/patches/webhook_in_datanodes.yaml	15
iotdb-operator/config/default/kustomization.yaml	109
iotdb-operator/config/default/manager_auth_proxy_patch.yaml	37
iotdb-operator/config/default/manager_config_patch.yaml	10
iotdb-operator/config/default/manager_webhook_patch.yaml	23
iotdb-operator/config/default/webhookcainjection_patch.yaml	23
iotdb-operator/config/manager/kustomization.yaml	8
iotdb-operator/config/manager/manager.yaml	65
iotdb-operator/config/manifests/kustomization.yaml	5
iotdb-operator/config/prometheus/kustomization.yaml	2
iotdb-operator/config/prometheus/monitor.yaml	20
iotdb-operator/config/rbac/auth_proxy_client_clusterrole.yaml	12
iotdb-operator/config/rbac/auth_proxy_role.yaml	20
iotdb-operator/config/rbac/auth_proxy_role_binding.yaml	15
iotdb-operator/config/rbac/auth_proxy_service.yaml	17
iotdb-operator/config/rbac/confignode_editor_role.yaml	26
iotdb-operator/config/rbac/confignode_viewer_role.yaml	22
iotdb-operator/config/rbac/datanode_editor_role.yaml	26
iotdb-operator/config/rbac/datanode_viewer_role.yaml	22
iotdb-operator/config/rbac/kustomization.yaml	14
iotdb-operator/config/rbac/leader_election_role.yaml	39
iotdb-operator/config/rbac/leader_election_role_binding.yaml	15
iotdb-operator/config/rbac/role.yaml	102
iotdb-operator/config/rbac/role_binding.yaml	15
iotdb-operator/config/rbac/service_account.yaml	8
iotdb-operator/config/scorecard/bases/config.yaml	7
iotdb-operator/config/scorecard/kustomization.yaml	15
iotdb-operator/config/scorecard/patches/basic.config.yaml	10
iotdb-operator/config/scorecard/patches/olm.config.yaml	50
iotdb-operator/config/webhook/kustomization.yaml	5
iotdb-operator/config/webhook/kustomizeconfig.yaml	19
iotdb-operator/config/webhook/manifests.yaml	92
iotdb-operator/config/webhook/service.yaml	15
iotdb-operator/internal/controller/common_name.go	3
iotdb-operator/internal/controller/confignode_controller.go	272
iotdb-operator/internal/controller/datanode_controller.go	335
iotdb-operator/internal/controller/strutil/strutil.go	9
iotdb-spring-boot-starter/src/main/java/org/apache/iotdb/config/IoTDBSessionProperties.java	121
iotdb-spring-boot-starter/src/main/java/org/apache/iotdb/session/IoTDBSessionPool.java	73
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/BatchInsertPlugin.java	97
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/LombokPlugin.java	38
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/SerializablePlugin.java	102
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/generator/CNCommentGenerator.java	91
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/generator/SwaggerCommentGenerator.java	112
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/generator/resolver/IoTDBJavaTypeResolver.java	70
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/generator/resolver/JavaTypeResolverSelfImpl.java	34
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/util/DateUtil.java	9
mybatis-generator/src/main/resources/generatorConfig.xml	32