You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2023/05/26 08:32:48 UTC
[iotdb] branch opt_alignedTVList_column_order_check updated (c8af4516f4b -> e44b461bd5e)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch opt_alignedTVList_column_order_check
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c8af4516f4b fix bug
add 58967134baa [IOTDB-5897] Fix NullPointerException in compaction (#9888)
add 804fe050a07 [IOTDB-5899] Fix unexpected TemplateNotExistException when deactivating template (#9889)
add f96f3a52322 Schema query supports filtered by DataType (#9891)
add eb0a4460863 Change cost time unit from milli to nano & merge operator metric together in one driver
add 738a1389842 [IOTDB-5847] Pipe: IoTDB Thrift Connector and PipeReceiverAgent (#9829)
add d1f2897bdfe [IoTDB-5861] Use Compartor<Binary> instead of Comparator<String> in last query sort (#9865)
add b905b4a831c [IOTDB-5898] Pipe: pipe meta sync schedular (#9887)
add e07248bcc6f [IOTDB-5772] spark-iotdb-connnector: support scala 2.11 & 2.12 and resolve the Thrift version conflict with Spark's (#9788)
add 6f3f4e0d92f [IOTDB-5893] Pipe: PipeLauncher for data node setup process (#9879)
add 48fff510224 [IOTDB-5890] [IOTDB-5891] Fix messages problem in order by
add 67d70cea85f [IOTDB-5887] Optimize the construction performance of PathPatternTree without wildcards
add 61ee2a35bd9 [IOTDB-5869][IOTDB-5721][IOTDB-5901] Load strategy: load all files to unsequence dir (#9900)
add 7c9299f7b37 IOTDB-5848] Allow ratis-client retry when gRPC IO Unavailable (#9898)
add b833e3b66d1 [IOTDB-5895][IOTDB-5904] Pipe: handling DataNode removal (#9881)
add 20e78c0b90f [IOTDB-5845] Pipe: change the init order of LoadManager to avoid NPE in RetryFailedTasksThread (#9905)
add 631904d48f1 [IOTDB-5859]Compaction error when using Version as first sort dimension (#9817)
add ab922dba30a [DOC] Update the Grafana plugin user manual using screenshots of Grafana 9.3 version (#9912)
add 0fc126f3f11 [IOTDB-5903] Fix cannot select any inner space compaction task when there is only unsequence data (#9909)
add f8516ed32d8 [IOTDB-5907] Pipe: pipe subtask scheduler (#9915)
add 8a5d706754b [IOTDB-5909] Ignore IoTDBConfigNodeConsensusEfficiencyIT temporary (#9919)
add 088ae859448 [IOTDB-5908] Add more query metrics
add 5b82263b2bc [IOTDB-5911] Fix print-iotdb-data-dir tool cannot work (#9921)
add 2a456baa28b [IOTDB-5902] fix cluster restart bug about mlog.bin (#9893)
add c3ebb19b027 Remove useless schema fetch when show timeseries without order by heat (#9923)
add e46be0e9623 [IOTDB-5912] Pipe: Handle PipeMeta changes through heartbeat (#9922)
add 5b83ed50c32 [IOTDB-5914] Remove redundant debug log in Session
add c7380f485b6 [IOTDB-5796][IOTDB-5701] Remove recorder and optimize the usage of metrics (#9901)
add 26a795172c5 Support using logical view in query aligned by time. (#9874)
add 7008fea4ef3 Fix potential NPE when deRegisterFragmentInstanceFromQueryMemoryMap
add 17eb9d3b424 [IOTDB-5908] Fix some query metrics not effect
add 12d67e08c55 Avoid rpc invoking for SimpleQueryTerminator when endpoint is local address
add 1392e03b21f [IOTDB-5919]show variables add a variable timestamp_precision (#9936)
add 73037586d71 [IOTDB-5917] Refactor module hierarchy (#9930)
add 05a54dc13d3 [IOTDB-5906] Resolve metric dependency conflicts for IT module (#9943)
add ea3badc24e8 [IOTDB-5915] Adjust the granularity of data migration example from timeseries to device (#9916)
add a285d428208 Support Delete/Drop Logical View (#9938)
add 3bc6457a5f1 [IOTDB-5919] show variables add a variable timestamp_precision (#9946)
add 94212b64c74 [IOTDB-5925] Pipe: WAL Resource Management (#9948)
add 89d96ade469 Fix potential deadlock when freeing memory in MemoryPool
add e4ead169cee Support Show View (#9951)
add e44b461bd5e Merge branch 'master' of https://github.com/apache/iotdb into opt_alignedTVList_column_order_check
No new revisions were added by this update.
Summary of changes:
.github/workflows/client-cpp.yml | 8 +-
.github/workflows/client-go.yml | 2 +-
.github/workflows/client-python.yml | 6 +-
.github/workflows/grafana-plugin.yml | 4 +-
.github/workflows/influxdb-protocol.yml | 2 +-
.gitignore | 9 +
.gitmodules | 6 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 16 +-
client-go | 1 -
.../confignode/client/DataNodeRequestType.java | 5 +
.../client/async/AsyncDataNodeClientPool.java | 21 +
.../client/async/handlers/AsyncClientHandler.java | 3 +
.../heartbeat/DataNodeHeartbeatHandler.java | 10 +-
.../consensus/request/ConfigPhysicalPlan.java | 6 +-
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../PipeHandleLeaderChangePlan.java | 2 +-
.../pipe/runtime/PipeHandleMetaChangePlan.java | 67 +
.../statemachine/ConfigRegionStateMachine.java | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 33 +-
.../apache/iotdb/confignode/manager/IManager.java | 11 +-
.../iotdb/confignode/manager/ProcedureManager.java | 87 ++
.../manager/load/service/HeartbeatService.java | 16 +-
.../iotdb/confignode/manager/node/NodeManager.java | 4 +-
.../manager/partition/PartitionMetrics.java | 35 +-
.../iotdb/confignode/manager/pipe/PipeManager.java | 3 +
.../pipe/{ => plugin}/PipePluginCoordinator.java | 2 +-
.../manager/pipe/runtime/PipeMetaSyncer.java | 95 ++
.../pipe/{ => runtime}/PipeRuntimeCoordinator.java | 34 +-
.../pipe/{ => task}/PipeTaskCoordinator.java | 23 +-
.../manager/schema/ClusterSchemaManager.java | 3 +-
.../persistence/executor/ConfigPlanExecutor.java | 7 +-
.../persistence/pipe/PipePluginInfo.java | 44 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 80 +-
.../persistence/pipe/PipeTaskOperation.java | 3 +-
.../procedure/env/DataNodeRemoveHandler.java | 2 +
.../pipe/plugin/CreatePipePluginProcedure.java | 2 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 2 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 5 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 285 ++++
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 126 ++
.../pipe/task/AbstractOperatePipeProcedureV2.java | 11 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 16 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 4 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 4 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 4 +-
.../impl/schema/DeleteDatabaseProcedure.java | 4 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 353 +++++
.../state/schema/DeleteLogicalViewState.java | 9 +-
.../procedure/store/ProcedureFactory.java | 18 +
.../confignode/procedure/store/ProcedureType.java | 7 +-
.../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 8 +-
.../thrift/ConfigNodeRPCServiceMetrics.java | 8 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 13 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 44 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 1 -
.../runtime/PipeHandleMetaChangeProcedureTest.java | 96 ++
.../pipe/runtime/PipeMetaSyncProcedureTest.java | 55 +
.../consensus/iot/IoTConsensusServerImpl.java | 87 +-
.../consensus/iot/IoTConsensusServerMetrics.java | 327 ++--
.../consensus/iot/client/DispatchLogHandler.java | 25 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 32 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 194 ++-
.../ratis/ApplicationStateMachineProxy.java | 2 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 18 +-
.../iotdb/consensus/simple/SimpleConsensus.java | 2 +-
distribution/pom.xml | 14 +
distribution/src/assembly/all.xml | 4 +-
distribution/src/assembly/cli.xml | 4 +-
distribution/src/assembly/client-cpp.xml | 2 +-
distribution/src/assembly/grafana-connector.xml | 2 +-
distribution/src/assembly/grafana-plugin.xml | 2 +-
.../{client-cpp.xml => spark-connector.xml} | 16 +-
docker/src/main/DockerCompose/start-1c1d.sh | 2 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 8 +-
.../UserGuide/Ecosystem-Integration/Spark-IoTDB.md | 273 ++--
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 51 +-
docs/UserGuide/Operate-Metadata/Timeseries.md | 28 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 6 +-
.../UserGuide/Ecosystem-Integration/Spark-IoTDB.md | 261 ++--
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 66 +-
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 26 +-
example/session/pom.xml | 6 +
.../org/apache/iotdb/DataMigrationExample.java | 142 +-
grafana-plugin/go.sum | 660 ---------
influxdb-protocol/pom.xml | 140 --
.../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 411 ------
.../iotdb/influxdb/IoTDBInfluxDBFactory.java | 70 -
.../iotdb/influxdb/protocol/dto/SessionPoint.java | 85 --
.../protocol/impl/IoTDBInfluxDBService.java | 99 --
.../influxdb/protocol/util/ParameterUtils.java | 36 -
.../iotdb/influxdb/session/InfluxDBSession.java | 279 ----
.../influxdb/integration/IoTDBInfluxDBIT.java | 207 ---
integration-test/pom.xml | 24 +
integration-test/src/assembly/mpp-test.xml | 4 +-
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 42 +
.../confignode/it/utils/ConfigNodeTestUtils.java | 1 +
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 18 +
.../db/it/last/IoTDBLastQueryLastCacheIT.java | 17 +-
.../apache/iotdb/db/it/orderBy/IoTDBOrderByIT.java | 26 +
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 22 +
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 6 +-
.../org/apache/iotdb/spark/it/AbstractTest.java | 55 +
.../java/org/apache/iotdb/spark/it/ReadTest.java | 145 ++
.../test/java/org/apache/iotdb/spark/it/Utils.java | 96 ++
.../java/org/apache/iotdb/spark/it/WriteTest.java | 116 ++
integration/README.md | 120 --
integration/checkstyle.xml | 217 ---
integration/import-control.xml | 29 -
integration/pom.xml | 295 ----
integration/src/assembly/cluster.xml | 47 -
.../db/engine/trigger/example/Accumulator.java | 96 --
.../iotdb/db/engine/trigger/example/Counter.java | 97 --
.../iotdb/db/query/udf/example/Accumulator.java | 102 --
.../apache/iotdb/db/query/udf/example/Adder.java | 92 --
.../apache/iotdb/db/query/udf/example/Counter.java | 88 --
.../db/query/udf/example/ExampleUDFConstant.java | 31 -
.../org/apache/iotdb/db/query/udf/example/Max.java | 74 -
.../iotdb/db/query/udf/example/Multiplier.java | 63 -
.../SlidingSizeWindowConstructorTester0.java | 59 -
.../SlidingSizeWindowConstructorTester1.java | 64 -
.../SlidingTimeWindowConstructionTester.java | 72 -
.../db/query/udf/example/TerminateTester.java | 67 -
.../iotdb/db/query/udf/example/ValidateTester.java | 44 -
.../iotdb/db/query/udf/example/WindowStartEnd.java | 66 -
.../iotdb/integration/env/ClusterEnvBase.java | 279 ----
.../iotdb/integration/env/ClusterEnvConfig.java | 154 --
.../apache/iotdb/integration/env/ClusterNode.java | 179 ---
.../iotdb/integration/env/ConfigFactory.java | 52 -
.../apache/iotdb/integration/env/EnvFactory.java | 57 -
.../iotdb/integration/env/FiveNodeCluster1Env.java | 64 -
.../iotdb/integration/env/RemoteEnvConfig.java | 23 -
.../iotdb/integration/env/RemoteServerEnv.java | 107 --
.../apache/iotdb/itbase/category/ClusterTest.java | 21 -
.../iotdb/itbase/category/LocalStandaloneTest.java | 21 -
.../apache/iotdb/itbase/category/RemoteTest.java | 21 -
.../org/apache/iotdb/itbase/env/BaseConfig.java | 112 --
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 39 -
.../apache/iotdb/db/integration/IOTDBInsertIT.java | 200 ---
.../IoTDBAlignedTimeSeriesCompactionIT.java | 564 -------
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 142 --
.../iotdb/db/integration/IoTDBClearCacheIT.java | 171 ---
.../apache/iotdb/db/integration/IoTDBCloseIT.java | 191 ---
.../iotdb/db/integration/IoTDBCompactionIT.java | 338 -----
.../integration/IoTDBCompactionWithIDTableIT.java | 352 -----
.../iotdb/db/integration/IoTDBCompressTypeIT.java | 101 --
.../db/integration/IoTDBContinuousQueryIT.java | 544 -------
.../apache/iotdb/db/integration/IoTDBDaemonIT.java | 456 ------
.../iotdb/db/integration/IoTDBDisableAlignIT.java | 392 -----
.../apache/iotdb/db/integration/IoTDBFillIT.java | 1227 ---------------
.../db/integration/IoTDBFlushQueryMergeIT.java | 197 ---
.../iotdb/db/integration/IoTDBKillQueryIT.java | 80 -
.../iotdb/db/integration/IoTDBLargeDataIT.java | 373 -----
.../apache/iotdb/db/integration/IoTDBLastIT.java | 629 --------
.../iotdb/db/integration/IoTDBMaxTimeQueryIT.java | 139 --
.../IoTDBMultiOverlappedChunkInUnseqIT.java | 110 --
.../db/integration/IoTDBMultiOverlappedPageIT.java | 166 ---
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 471 ------
.../db/integration/IoTDBMultiStatementsIT.java | 187 ---
.../db/integration/IoTDBNewTsFileCompactionIT.java | 1078 --------------
.../db/integration/IoTDBOverlappedPageIT.java | 194 ---
.../iotdb/db/integration/IoTDBQueryTimeoutIT.java | 156 --
.../db/integration/IoTDBQueryWithIDTableIT.java | 290 ----
.../db/integration/IoTDBRemovePartitionIT.java | 331 -----
.../db/integration/IoTDBRepeatPatternNameIT.java | 67 -
.../db/integration/IoTDBRewriteTsFileToolIT.java | 618 --------
.../db/integration/IoTDBRpcCompressionIT.java | 140 --
.../iotdb/db/integration/IoTDBSensorUpdateIT.java | 87 --
.../db/integration/IoTDBSessionTimeoutIT.java | 84 --
.../IoTDBSetSystemReadOnlyWritableIT.java | 258 ----
.../integration/IoTDBSizeTieredCompactionIT.java | 1370 -----------------
.../integration/IoTDBSortedShowTimeseriesIT.java | 339 -----
.../iotdb/db/integration/IoTDBTimePartitionIT.java | 90 --
.../iotdb/db/integration/IoTDBTracingIT.java | 84 --
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 354 -----
.../db/integration/IoTDBUDFWindowQueryIT.java | 808 ----------
.../db/integration/IoTDBUDTFHybridQueryIT.java | 160 --
.../db/integration/IoTDBUDTFNonAlignQueryIT.java | 341 -----
.../db/integration/IoTDBUnseqOverlappedPageIT.java | 127 --
.../iotdb/db/integration/IoTDBVersionIT.java | 68 -
.../iotdb/db/integration/env/StandaloneEnv.java | 93 --
.../db/integration/env/StandaloneEnvConfig.java | 133 --
.../versionadaption/IoTDBDDLVersionAdaptionIT.java | 362 -----
.../IoTDBDeletionVersionAdaptionIT.java | 303 ----
.../IoTDBQueryVersionAdaptionIT.java | 320 ----
.../session/IoTDBSessionAlignedABDeviceIT.java | 235 ---
.../session/IoTDBSessionAlignedAggregationIT.java | 263 ----
.../IoTDBSessionAlignedAggregationWithUnSeqIT.java | 196 ---
.../iotdb/session/IoTDBSessionIteratorIT.java | 354 -----
.../src/test/resources/iotdb-datanode.properties | 24 -
integration/src/test/resources/logback-test.xml | 58 -
{external-api => iotdb-api/external-api}/pom.xml | 2 +-
.../iotdb/external/api/IPropertiesLoader.java | 0
.../iotdb/external/api/ISeriesNumerMonitor.java | 0
.../external/api/thrift/JudgableServerContext.java | 0
.../external/api/thrift/ServerContextFactory.java | 0
.../external-pipe-api}/pom.xml | 2 +-
.../apache/iotdb/pipe/external/api/DataType.java | 0
.../external/api/ExternalPipeSinkWriterStatus.java | 0
.../pipe/external/api/IExternalPipeSinkWriter.java | 0
.../api/IExternalPipeSinkWriterFactory.java | 0
{pipe-api => iotdb-api/pipe-api}/pom.xml | 2 +-
.../org/apache/iotdb/pipe/api/PipeCollector.java | 0
.../org/apache/iotdb/pipe/api/PipeConnector.java | 14 +-
.../java/org/apache/iotdb/pipe/api/PipePlugin.java | 0
.../org/apache/iotdb/pipe/api/PipeProcessor.java | 10 +-
.../java/org/apache/iotdb/pipe/api/access/Row.java | 0
.../apache/iotdb/pipe/api/access/RowIterator.java | 0
.../iotdb/pipe/api/collector/EventCollector.java | 32 +-
.../iotdb/pipe/api/collector/RowCollector.java | 0
.../api/customizer/PipeParameterValidator.java | 0
.../iotdb/pipe/api/customizer/PipeParameters.java | 0
.../api/customizer/PipeRuntimeConfiguration.java | 0
.../iotdb/pipe/api/customizer/PipeStrategy.java | 0
.../PipeCollectorRuntimeConfiguration.java | 0
.../PipeConnectorRuntimeConfiguration.java | 0
.../connector/parallel/ParallelStrategy.java | 0
.../retry/EqualRetryIntervalStrategy.java | 0
.../retry/ExponentialRetryIntervalStrategy.java | 0
.../customizer/connector/retry/RetryStrategy.java | 0
.../customizer/connector/reuse/ReuseStrategy.java | 0
.../PipeProcessorRuntimeConfiguration.java | 0
.../org/apache/iotdb/pipe/api/event/Event.java | 6 +-
.../org/apache/iotdb/pipe/api/event/EventType.java | 0
.../event/dml/insertion/TabletInsertionEvent.java | 6 -
.../event/dml/insertion/TsFileInsertionEvent.java | 6 -
.../PipeAttributeNotProvidedException.java | 0
.../api/exception/PipeConnectionException.java | 0
.../iotdb/pipe/api/exception/PipeException.java | 0
.../api/exception/PipeManagementException.java | 0
.../exception/PipeParameterNotValidException.java | 0
.../exception/PipeRuntimeCriticalException.java | 0
.../pipe/api/exception/PipeRuntimeException.java | 0
.../exception/PipeRuntimeNonCriticalException.java | 0
.../exception/PipeStrategyNotValidException.java | 0
.../org/apache/iotdb/pipe/api/type/Binary.java | 0
.../java/org/apache/iotdb/pipe/api/type/Type.java | 0
.../subscription-api}/pom.xml | 2 +-
.../api/SubscriptionConfiguration.java | 0
.../subscription/api/SubscriptionFactory.java | 0
.../iotdb/subscription/api/consumer/Consumer.java | 0
.../api/consumer/pull/PullConsumer.java | 0
.../api/consumer/push/DataArrivalListener.java | 0
.../api/consumer/push/ExceptionListener.java | 0
.../api/consumer/push/PushConsumer.java | 0
.../api/dataset/SubscriptionDataSet.java | 0
.../api/exception/SubscriptionException.java | 0
.../SubscriptionStrategyNotValidException.java | 0
.../api/strategy/SubscriptionStrategy.java | 0
.../disorder/DisorderHandlingStrategy.java | 0
.../api/strategy/disorder/IntolerableStrategy.java | 0
.../api/strategy/disorder/WatermarkStrategy.java | 0
.../strategy/topic/MultipleConnectionStrategy.java | 0
.../api/strategy/topic/SingleTopicStrategy.java | 0
.../api/strategy/topic/TopicsStrategy.java | 0
{trigger-api => iotdb-api/trigger-api}/pom.xml | 2 +-
.../java/org/apache/iotdb/trigger/api/Trigger.java | 0
.../iotdb/trigger/api/TriggerAttributes.java | 0
.../iotdb/trigger/api/enums/FailureStrategy.java | 0
.../iotdb/trigger/api/enums/TriggerEvent.java | 0
.../iotdb/trigger/api/enums/TriggerType.java | 0
{udf-api => iotdb-api/udf-api}/pom.xml | 2 +-
.../main/java/org/apache/iotdb/udf/api/UDF.java | 0
.../main/java/org/apache/iotdb/udf/api/UDTF.java | 0
.../java/org/apache/iotdb/udf/api/access/Row.java | 0
.../apache/iotdb/udf/api/access/RowIterator.java | 0
.../org/apache/iotdb/udf/api/access/RowWindow.java | 0
.../iotdb/udf/api/collector/PointCollector.java | 0
.../api/customizer/config/UDFConfigurations.java | 0
.../api/customizer/config/UDTFConfigurations.java | 0
.../parameter/UDFParameterValidator.java | 0
.../api/customizer/parameter/UDFParameters.java | 0
.../api/customizer/strategy/AccessStrategy.java | 0
.../strategy/MappableRowByRowAccessStrategy.java | 0
.../strategy/RowByRowAccessStrategy.java | 0
.../strategy/SessionTimeWindowAccessStrategy.java | 0
.../strategy/SlidingSizeWindowAccessStrategy.java | 0
.../strategy/SlidingTimeWindowAccessStrategy.java | 0
.../strategy/StateWindowAccessStrategy.java | 0
.../UDFAttributeNotProvidedException.java | 0
.../iotdb/udf/api/exception/UDFException.java | 0
.../UDFInputSeriesDataTypeNotValidException.java | 0
.../UDFInputSeriesIndexNotValidException.java | 0
.../UDFInputSeriesNumberNotValidException.java | 0
.../udf/api/exception/UDFManagementException.java | 0
.../UDFOutputSeriesDataTypeNotValidException.java | 0
.../exception/UDFParameterNotValidException.java | 0
.../java/org/apache/iotdb/udf/api/type/Binary.java | 0
.../java/org/apache/iotdb/udf/api/type/Type.java | 0
{cli => iotdb-client/cli}/pom.xml | 2 +-
{cli => iotdb-client/cli}/src/assembly/cli.xml | 0
.../src/assembly/resources/conf/logback-cli.xml | 0
.../cli}/src/assembly/resources/sbin/start-cli.bat | 0
.../cli}/src/assembly/resources/sbin/start-cli.sh | 0
.../src/assembly/resources/tools/export-csv.bat | 0
.../src/assembly/resources/tools/export-csv.sh | 0
.../src/assembly/resources/tools/export-tsfile.bat | 0
.../src/assembly/resources/tools/export-tsfile.sh | 0
.../src/assembly/resources/tools/import-csv.bat | 0
.../src/assembly/resources/tools/import-csv.sh | 0
.../src/assembly/resources/tools/load-tsfile.bat | 0
.../src/assembly/resources/tools/load-tsfile.sh | 0
.../java/org/apache/iotdb/cli/AbstractCli.java | 0
.../src/main/java/org/apache/iotdb/cli/Cli.java | 0
.../apache/iotdb/cli/IoTDBSyntaxHighlighter.java | 0
.../org/apache/iotdb/cli/utils/IoTPrinter.java | 0
.../org/apache/iotdb/cli/utils/JlineUtils.java | 0
.../apache/iotdb/exception/ArgsErrorException.java | 0
.../org/apache/iotdb/tool/AbstractCsvTool.java | 0
.../org/apache/iotdb/tool/AbstractTsFileTool.java | 0
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 0
.../java/org/apache/iotdb/tool/ExportTsFile.java | 0
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 0
.../java/org/apache/iotdb/cli/AbstractCliIT.java | 0
.../java/org/apache/iotdb/cli/AbstractScript.java | 0
.../iotdb/tool/integration/ExportCsvTestIT.java | 0
.../iotdb/tool/integration/ImportCsvTestIT.java | 0
.../apache/iotdb/tool/unit/WriteCsvFileTestUT.java | 0
.../cli}/src/test/resources/logback.xml | 0
{client-cpp => iotdb-client/client-cpp}/README.md | 0
{client-cpp => iotdb-client/client-cpp}/pom.xml | 24 +-
.../client-cpp}/src/assembly/client-cpp.xml | 0
.../client-cpp}/src/main/CMakeLists.txt | 0
.../client-cpp}/src/main/Session.cpp | 0
.../client-cpp}/src/main/Session.h | 0
.../client-cpp}/src/test/CMakeLists.txt | 0
.../client-cpp}/src/test/cpp/sessionIT.cpp | 0
.../client-cpp}/src/test/main.cpp | 0
iotdb-client/client-go | 1 +
{client-py => iotdb-client/client-py}/.flake8 | 0
{client-py => iotdb-client/client-py}/.gitignore | 0
{client-py => iotdb-client/client-py}/README.md | 0
.../client-py}/SessionAlignedTimeseriesExample.py | 0
.../client-py}/SessionExample.py | 0
.../client-py}/iotdb/IoTDBContainer.py | 0
.../client-py}/iotdb/Session.py | 0
.../client-py}/iotdb/__init__.py | 0
.../client-py}/iotdb/dbapi/Connection.py | 0
.../client-py}/iotdb/dbapi/Cursor.py | 0
.../client-py}/iotdb/dbapi/Exceptions.py | 0
.../client-py}/iotdb/dbapi/__init__.py | 0
.../client-py}/iotdb/dbapi/tests/__init__.py | 0
.../iotdb/dbapi/tests/test_connection.py | 0
.../client-py}/iotdb/dbapi/tests/test_cursor.py | 0
.../client-py}/iotdb/sqlalchemy/IoTDBDialect.py | 0
.../iotdb/sqlalchemy/IoTDBIdentifierPreparer.py | 0
.../iotdb/sqlalchemy/IoTDBSQLCompiler.py | 0
.../iotdb/sqlalchemy/IoTDBTypeCompiler.py | 0
.../client-py}/iotdb/sqlalchemy/__init__.py | 0
.../client-py}/iotdb/sqlalchemy/tests/__init__.py | 0
.../iotdb/sqlalchemy/tests/test_dialect.py | 0
.../client-py}/iotdb/template/InternalNode.py | 0
.../client-py}/iotdb/template/MeasurementNode.py | 0
.../client-py}/iotdb/template/Template.py | 0
.../client-py}/iotdb/template/TemplateNode.py | 0
.../client-py}/iotdb/template/TemplateQueryType.py | 0
.../client-py}/iotdb/template/__init__.py | 0
.../client-py}/iotdb/tsfile/__init__.py | 0
.../client-py}/iotdb/tsfile/common/__init__.py | 0
.../iotdb/tsfile/common/constant/TsFileConstant.py | 0
.../iotdb/tsfile/common/constant/__init__.py | 0
.../client-py}/iotdb/tsfile/utils/Pair.py | 0
.../iotdb/tsfile/utils/ReadWriteIOUtils.py | 0
.../client-py}/iotdb/tsfile/utils/__init__.py | 0
.../client-py}/iotdb/utils/BitMap.py | 0
.../client-py}/iotdb/utils/Field.py | 0
.../iotdb/utils/IoTDBConnectionException.py | 0
.../client-py}/iotdb/utils/IoTDBConstants.py | 0
.../client-py}/iotdb/utils/IoTDBRpcDataSet.py | 0
.../client-py}/iotdb/utils/NumpyTablet.py | 0
.../client-py}/iotdb/utils/RowRecord.py | 0
.../client-py}/iotdb/utils/SessionDataSet.py | 0
.../client-py}/iotdb/utils/Tablet.py | 0
.../client-py}/iotdb/utils/__init__.py | 0
{client-py => iotdb-client/client-py}/pom.xml | 6 +-
.../client-py}/pyproject.toml | 0
{client-py => iotdb-client/client-py}/release.sh | 0
.../client-py}/requirements.txt | 0
.../client-py}/requirements_dev.txt | 0
{client-py => iotdb-client/client-py}/setup.py | 0
.../client-py}/tests/__init__.py | 0
.../tests/tablet_performance_comparison.py | 0
.../client-py}/tests/test_aligned_timeseries.py | 0
.../client-py}/tests/test_dataframe.py | 0
.../client-py}/tests/test_delete_data.py | 0
.../client-py}/tests/test_numpy_tablet.py | 0
.../client-py}/tests/test_one_device.py | 0
.../client-py}/tests/test_session.py | 0
.../client-py}/tests/test_tablet.py | 0
.../client-py}/tests/test_template.py | 0
.../client-py}/tests/test_todf.py | 0
.../compile-tools}/README.md | 0
.../compile-tools}/pom.xml | 2 +-
.../compile-tools}/thrift/pom.xml | 0
{isession => iotdb-client/isession}/pom.xml | 1 +
.../java/org/apache/iotdb/isession/ISession.java | 0
.../org/apache/iotdb/isession/SessionConfig.java | 0
.../org/apache/iotdb/isession/SessionDataSet.java | 8 +
.../apache/iotdb/isession/pool/ISessionPool.java | 0
.../iotdb/isession/pool/SessionDataSetWrapper.java | 0
.../apache/iotdb/isession/template/Template.java | 0
.../iotdb/isession/template/TemplateNode.java | 0
.../apache/iotdb/isession/util/SystemStatus.java | 0
.../org/apache/iotdb/isession/util/Version.java | 0
{jdbc => iotdb-client/jdbc}/README.md | 0
{jdbc => iotdb-client/jdbc}/osgi.bnd | 0
{jdbc => iotdb-client/jdbc}/pom.xml | 2 +-
.../jdbc}/src/main/feature/feature.xml | 0
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 0
.../main/java/org/apache/iotdb/jdbc/Activator.java | 0
.../main/java/org/apache/iotdb/jdbc/Config.java | 0
.../main/java/org/apache/iotdb/jdbc/Constant.java | 0
.../src/main/java/org/apache/iotdb/jdbc/Field.java | 0
.../iotdb/jdbc/GroupedLSBWatermarkEncoder.java | 0
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 0
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 0
.../org/apache/iotdb/jdbc/IoTDBDataSource.java | 0
.../apache/iotdb/jdbc/IoTDBDataSourceFactory.java | 0
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 0
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 0
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 0
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 0
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 0
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 0
.../org/apache/iotdb/jdbc/IoTDBSQLException.java | 0
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 0
.../org/apache/iotdb/jdbc/IoTDBTracingInfo.java | 0
.../org/apache/iotdb/jdbc/IoTDBURLException.java | 0
.../java/org/apache/iotdb/jdbc/StringUtils.java | 0
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 0
.../org/apache/iotdb/jdbc/WatermarkEncoder.java | 0
.../resources/services/META-INF/java.sql.Driver | 0
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 0
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 0
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 0
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 0
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 0
.../apache/iotdb/jdbc/IoTDBResultMetadataTest.java | 0
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 0
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 0
{service-rpc => iotdb-client/service-rpc}/pom.xml | 2 +-
.../org/apache/iotdb/rpc/AutoResizingBuffer.java | 3 -
.../iotdb/rpc/AutoScalingBufferReadTransport.java | 0
.../iotdb/rpc/AutoScalingBufferWriteTransport.java | 0
.../apache/iotdb/rpc/BatchExecutionException.java | 0
.../iotdb/rpc/ConfigNodeConnectionException.java | 0
.../apache/iotdb/rpc/ConfigurableTByteBuffer.java | 0
.../iotdb/rpc/InfluxDBSynchronizedHandler.java | 0
.../apache/iotdb/rpc/IoTDBConnectionException.java | 0
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 0
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 0
.../apache/iotdb/rpc/NoValidValueException.java | 0
.../org/apache/iotdb/rpc/NonOpenTransport.java | 0
.../org/apache/iotdb/rpc/RedirectException.java | 0
.../main/java/org/apache/iotdb/rpc/RpcStat.java | 0
.../org/apache/iotdb/rpc/RpcTransportFactory.java | 0
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 0
.../iotdb/rpc/StatementExecutionException.java | 0
.../org/apache/iotdb/rpc/SynchronizedHandler.java | 0
.../rpc/TCompressedElasticFramedTransport.java | 0
.../org/apache/iotdb/rpc/TConfigurationConst.java | 0
.../apache/iotdb/rpc/TElasticFramedTransport.java | 0
.../iotdb/rpc/TNonblockingSocketWrapper.java | 0
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 9 +-
.../iotdb/rpc/TSnappyElasticFramedTransport.java | 0
.../java/org/apache/iotdb/rpc/TSocketWrapper.java | 0
.../rpc/TimeoutChangeableTFastFramedTransport.java | 0
.../TimeoutChangeableTSnappyFramedTransport.java | 0
.../iotdb/rpc/TimeoutChangeableTransport.java | 0
.../org/apache/iotdb/rpc/TSStatusCodeTest.java | 0
{session => iotdb-client/session}/pom.xml | 2 +-
.../org/apache/iotdb/session/InsertConsumer.java | 0
.../java/org/apache/iotdb/session/Session.java | 7 -
.../apache/iotdb/session/SessionConnection.java | 0
.../org/apache/iotdb/session/pool/SessionPool.java | 16 -
.../iotdb/session/template/InternalNode.java | 0
.../iotdb/session/template/MeasurementNode.java | 0
.../iotdb/session/template/TemplateQueryType.java | 0
.../apache/iotdb/session/util/SessionUtils.java | 0
.../org/apache/iotdb/session/util/ThreadUtils.java | 0
.../apache/iotdb/session/SessionCacheLeaderUT.java | 0
.../java/org/apache/iotdb/session/TabletTest.java | 0
.../apache/iotdb/session/pool/SessionPoolTest.java | 0
.../apache/iotdb/session/util/ThreadUtilsTest.java | 0
.../src/test/resources/iotdb-common.properties | 0
.../src/test/resources/iotdb-datanode.properties | 0
.../session}/src/test/resources/logback.xml | 0
.../flink-iotdb-connector}/README.md | 0
.../flink-iotdb-connector}/pom.xml | 2 +-
.../iotdb/flink/DefaultIoTSerializationSchema.java | 0
.../main/java/org/apache/iotdb/flink/Event.java | 0
.../java/org/apache/iotdb/flink/IoTDBSink.java | 0
.../java/org/apache/iotdb/flink/IoTDBSource.java | 0
.../apache/iotdb/flink/IoTSerializationSchema.java | 0
.../apache/iotdb/flink/options/IoTDBOptions.java | 0
.../iotdb/flink/options/IoTDBSinkOptions.java | 0
.../iotdb/flink/options/IoTDBSourceOptions.java | 0
.../flink/DefaultIoTSerializationSchemaTest.java | 0
.../iotdb/flink/IoTDBSinkBatchInsertTest.java | 0
.../iotdb/flink/IoTDBSinkBatchTimerTest.java | 0
.../apache/iotdb/flink/IoTDBSinkInsertTest.java | 0
.../flink-tsfile-connector}/README.md | 0
.../flink-tsfile-connector}/pom.xml | 2 +-
.../apache/iotdb/flink/tsfile/RowRecordParser.java | 0
.../iotdb/flink/tsfile/RowRowRecordParser.java | 0
.../iotdb/flink/tsfile/RowTSRecordConverter.java | 0
.../iotdb/flink/tsfile/TSRecordConverter.java | 0
.../iotdb/flink/tsfile/TSRecordOutputFormat.java | 0
.../iotdb/flink/tsfile/TsFileInputFormat.java | 0
.../iotdb/flink/tsfile/TsFileOutputFormat.java | 0
.../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 0
.../RowTSRecordOutputFormatIntegrationTest.java | 0
.../flink/tsfile/RowTSRecordOutputFormatTest.java | 0
.../flink/tsfile/RowTsFileConnectorTestBase.java | 0
.../RowTsFileInputFormatIntegrationTest.java | 0
.../flink/tsfile/RowTsFileInputFormatTest.java | 0
.../flink/tsfile/RowTsFileInputFormatTestBase.java | 0
.../tsfile/RowTsFileOutputFormatTestBase.java | 0
.../util/TSFileConfigUtilCompletenessTest.java | 0
.../apache/iotdb/flink/util/TsFileWriteUtil.java | 0
.../grafana-connector}/img/add_data_source.png | Bin
.../grafana-connector}/img/add_graph.png | Bin
.../grafana-connector}/img/edit_data_source.png | Bin
.../grafana-connector}/pom.xml | 2 +-
.../grafana-connector}/readme.md | 0
.../grafana-connector}/readme_zh.md | 0
.../web/grafana/TsfileWebDemoApplication.java | 0
.../apache/iotdb/web/grafana/bean/TimeValues.java | 0
.../iotdb/web/grafana/conf/MyConfiguration.java | 0
.../controller/DatabaseConnectController.java | 0
.../org/apache/iotdb/web/grafana/dao/BasicDao.java | 0
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 0
.../web/grafana/interceptor/LoginInterceptor.java | 0
.../grafana/service/DatabaseConnectService.java | 0
.../service/impl/DatabaseConnectServiceImpl.java | 0
.../src/main/resources/application.properties | 0
.../web/grafana/dao/impl/BasicDaoImplTest.java | 0
.../grafana-plugin}/.gitignore | 0
.../grafana-plugin}/.prettierrc.js | 0
.../grafana-plugin}/CHANGELOG.md | 0
.../grafana-plugin}/LICENSE | 0
.../grafana-plugin}/Magefile.go | 0
.../grafana-plugin}/README.md | 0
.../grafana-plugin}/backend-compile.bat | 0
.../grafana-plugin}/backend-compile.sh | 0
.../grafana-plugin}/go.mod | 0
.../grafana-plugin}/jest.config.js | 0
.../grafana-plugin}/package.json | 0
.../grafana-plugin}/pkg/main.go | 0
.../pkg/plugin/iotdb_resource_handler.go | 0
.../grafana-plugin}/pkg/plugin/plugin.go | 0
.../grafana-plugin}/pom.xml | 2 +-
.../grafana-plugin}/src/ConfigEditor.tsx | 0
.../grafana-plugin}/src/QueryEditor.tsx | 0
.../src/componments/AggregateFun.tsx | 0
.../src/componments/ControlValue.tsx | 0
.../grafana-plugin}/src/componments/FillValue.tsx | 0
.../grafana-plugin}/src/componments/Form.tsx | 0
.../grafana-plugin}/src/componments/FromValue.tsx | 0
.../grafana-plugin}/src/componments/GroupBy.tsx | 0
.../src/componments/SelectValue.tsx | 0
.../grafana-plugin}/src/componments/TimeSeries.tsx | 0
.../grafana-plugin}/src/componments/WhereValue.tsx | 0
.../grafana-plugin}/src/datasource.ts | 0
.../grafana-plugin}/src/functions.ts | 0
.../grafana-plugin}/src/img/addIoTDBDataSource.png | Bin
.../grafana-plugin}/src/img/logo.svg | 0
.../grafana-plugin}/src/img/showData.png | Bin
.../grafana-plugin}/src/module.ts | 0
.../grafana-plugin}/src/plugin.json | 0
.../grafana-plugin}/src/types.ts | 0
.../grafana-plugin}/tsconfig.json | 0
.../grafana-plugin}/yarn.lock | 0
{hadoop => iotdb-connector/hadoop}/README.md | 0
{hadoop => iotdb-connector/hadoop}/pom.xml | 2 +-
.../iotdb/hadoop/fileSystem/HDFSConfUtil.java | 0
.../apache/iotdb/hadoop/fileSystem/HDFSFile.java | 0
.../apache/iotdb/hadoop/fileSystem/HDFSInput.java | 0
.../apache/iotdb/hadoop/fileSystem/HDFSOutput.java | 0
.../org/apache/iotdb/hadoop/tsfile/IReaderSet.java | 0
.../iotdb/hadoop/tsfile/TSFHadoopException.java | 0
.../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 0
.../apache/iotdb/hadoop/tsfile/TSFInputSplit.java | 0
.../iotdb/hadoop/tsfile/TSFOutputFormat.java | 0
.../iotdb/hadoop/tsfile/TSFRecordReader.java | 0
.../iotdb/hadoop/tsfile/TSFRecordWriter.java | 0
.../iotdb/hadoop/tsfile/record/HDFSTSRecord.java | 0
.../apache/iotdb/hadoop/tsfile/TSFHadoopTest.java | 0
.../iotdb/hadoop/tsfile/TSFInputSplitTest.java | 0
.../iotdb/hadoop/tsfile/TsFileTestHelper.java | 0
.../iotdb/hadoop/tsfile/constant/TestConstant.java | 0
.../hadoop}/src/test/resources/logback.xml | 0
.../hive-connector}/pom.xml | 2 +-
.../org/apache/iotdb/hive/TSFHiveInputFormat.java | 0
.../org/apache/iotdb/hive/TSFHiveOutputFormat.java | 0
.../org/apache/iotdb/hive/TSFHiveRecordReader.java | 0
.../org/apache/iotdb/hive/TSFHiveRecordWriter.java | 0
.../org/apache/iotdb/hive/TsFileDeserializer.java | 0
.../java/org/apache/iotdb/hive/TsFileSerDe.java | 0
.../apache/iotdb/hive/TsFileSerDeException.java | 0
.../apache/iotdb/hive/TSFHiveInputFormatTest.java | 0
.../apache/iotdb/hive/TSFHiveRecordReaderTest.java | 0
.../apache/iotdb/hive/TsFileDeserializerTest.java | 0
.../org/apache/iotdb/hive/TsFileSerDeTest.java | 0
.../org/apache/iotdb/hive/TsFileTestHelper.java | 0
.../apache/iotdb/hive/constant/TestConstant.java | 0
.../hive-connector}/src/test/resources/logback.xml | 0
.../spark-iotdb-connector}/pom.xml | 36 +-
.../spark-iotdb-connector/scala_2.11}/pom.xml | 108 +-
.../spark-iotdb-connector/scala_2.12}/pom.xml | 103 +-
.../org/apache/iotdb/spark/db/Converter.scala | 0
.../org/apache/iotdb/spark/db/DataFrameTools.scala | 0
.../org/apache/iotdb/spark/db/DefaultSource.scala | 0
.../org/apache/iotdb/spark/db/IoTDBOptions.scala | 0
.../scala/org/apache/iotdb/spark/db/IoTDBRDD.scala | 0
.../org/apache/iotdb/spark/db/IoTDBRelation.scala | 0
.../org/apache/iotdb/spark/db/SQLConstant.scala | 0
.../org/apache/iotdb/spark/db/Transformer.scala | 0
.../scala/org/apache/iotdb/spark/db/package.scala | 0
.../spark-tsfile}/pom.xml | 52 +-
.../iotdb/spark/tsfile/io/TsFileOutputFormat.java | 0
.../iotdb/spark/tsfile/io/TsFileRecordWriter.java | 0
.../org/apache/iotdb/spark/tsfile/qp/Executor.java | 0
.../iotdb/spark/tsfile/qp/QueryProcessor.java | 0
.../spark/tsfile/qp/common/BasicOperator.java | 0
.../spark/tsfile/qp/common/FilterOperator.java | 0
.../iotdb/spark/tsfile/qp/common/Operator.java | 0
.../iotdb/spark/tsfile/qp/common/SQLConstant.java | 118 +-
.../iotdb/spark/tsfile/qp/common/SingleQuery.java | 0
.../iotdb/spark/tsfile/qp/common/TSQueryPlan.java | 0
.../qp/exception/BasicOperatorException.java | 0
.../tsfile/qp/exception/DNFOptimizeException.java | 0
.../qp/exception/LogicalOptimizeException.java | 0
.../tsfile/qp/exception/MergeFilterException.java | 0
.../qp/exception/QueryOperatorException.java | 0
.../qp/exception/QueryProcessorException.java | 0
.../tsfile/qp/exception/RemoveNotException.java | 0
.../tsfile/qp/optimizer/DNFFilterOptimizer.java | 0
.../tsfile/qp/optimizer/IFilterOptimizer.java | 0
.../qp/optimizer/MergeSingleFilterOptimizer.java | 0
.../tsfile/qp/optimizer/PhysicalOptimizer.java | 0
.../tsfile/qp/optimizer/RemoveNotOptimizer.java | 0
.../org/apache/iotdb/spark/tsfile/Converter.scala | 0
.../apache/iotdb/spark/tsfile/DefaultSource.scala | 0
.../iotdb/spark/tsfile/NarrowConverter.scala | 0
.../spark/tsfile/NarrowTsFileOutputWriter.scala | 0
.../apache/iotdb/spark/tsfile/Transformer.scala | 0
.../iotdb/spark/tsfile/TsFileWriterFactory.scala | 0
.../apache/iotdb/spark/tsfile/WideConverter.scala | 0
.../spark/tsfile/WideTsFileOutputWriter.scala | 0
.../org/apache/iotdb/spark/tsfile/package.scala | 0
.../apache/iotdb/spark/constant/TestConstant.java | 0
.../org/apache/iotdb/spark/tool/TsFileExample.java | 0
.../apache/iotdb/spark/tool/TsFileWriteTool.java | 0
.../apache/iotdb/spark/tsfile/ConverterTest.scala | 0
.../apache/iotdb/spark/tsfile/HDFSInputTest.java | 0
.../org/apache/iotdb/spark/tsfile/TSFileSuit.scala | 0
.../zeppelin-interpreter}/IoTDB-Zeppelin-Demo.zpln | 0
.../zeppelin-interpreter}/pom.xml | 2 +-
.../apache/zeppelin/iotdb/IoTDBInterpreter.java | 0
.../src/main/resources/interpreter-setting.json | 0
{openapi => iotdb-protocol/openapi}/pom.xml | 2 +-
.../src/main/openapi3/iotdb_rest_common.yaml | 0
.../openapi}/src/main/openapi3/iotdb_rest_v1.yaml | 0
.../openapi}/src/main/openapi3/iotdb_rest_v2.yaml | 0
.../thrift-commons}/pom.xml | 2 +-
.../thrift-commons}/src/main/thrift/common.thrift | 0
.../thrift-confignode}/pom.xml | 2 +-
.../src/main/thrift/confignode.thrift | 17 +-
.../thrift-influxdb}/README.md | 0
.../thrift-influxdb}/pom.xml | 2 +-
.../src/main/thrift/influxdb.thrift | 0
.../thrift-iot-consensus}/pom.xml | 2 +-
.../src/main/thrift/iotconsensus.thrift | 0
.../thrift-mlnode}/pom.xml | 2 +-
.../thrift-mlnode}/src/main/thrift/mlnode.thrift | 0
{thrift => iotdb-protocol/thrift}/README.md | 0
{thrift => iotdb-protocol/thrift}/pom.xml | 2 +-
.../thrift}/rpc-changelist.md | 0
.../thrift}/src/main/thrift/client.thrift | 13 +
.../thrift}/src/main/thrift/datanode.thrift | 23 +
.../java/org/apache/iotdb/metrics/type/Gauge.java | 1 -
.../resources/conf/iotdb-common.properties | 13 +-
.../iotdb/commons/concurrent/ThreadName.java | 2 +
.../apache/iotdb/commons/conf/CommonConfig.java | 16 +-
.../iotdb/commons/conf/CommonDescriptor.java | 9 +-
.../org/apache/iotdb/commons/path/AlignedPath.java | 15 +-
.../apache/iotdb/commons/path/PathPatternTree.java | 34 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 6 +-
.../{DefaultCollector.java => IoTDBCollector.java} | 2 +-
.../builtin/connector/DoNothingConnector.java | 4 +-
...ingConnector.java => IoTDBThriftConnector.java} | 28 +-
.../builtin/processor/DoNothingProcessor.java | 11 +-
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 13 +-
.../iotdb/commons/schema/filter/SchemaFilter.java | 3 +
.../commons/schema/filter/SchemaFilterType.java | 5 +-
.../commons/schema/filter/SchemaFilterVisitor.java | 5 +
.../commons/schema/filter/impl/DataTypeFilter.java | 65 +
.../schema/view/viewExpression/ViewExpression.java | 2 +
.../apache/iotdb/commons/service/ServiceType.java | 1 +
.../{enums => }/PerformanceOverviewMetrics.java | 4 +-
.../iotdb/commons/service/metric/enums/Metric.java | 187 +--
.../iotdb/commons/service/metric/enums/Tag.java | 26 +-
.../iotdb/commons/path/PathPatternTreeTest.java | 61 +-
.../iotdb/pipe/api/collector/EventCollector.java | 62 -
.../pipe/api/event/dml/deletion/DeletionEvent.java | 48 -
pom.xml | 99 +-
rewrite-tsfile-tool/pom.xml | 83 --
.../src/assembly/resources/sbin/rewrite-tsfile.bat | 60 -
.../src/assembly/resources/sbin/rewrite-tsfile.sh | 48 -
rewrite-tsfile-tool/src/assembly/rewriteTsFile.xml | 40 -
.../java/org/apache/iotdb/RewriteTsFileTool.java | 914 ------------
schema-engine-rocksdb/README.md | 38 -
schema-engine-rocksdb/pom.xml | 79 -
.../resources/conf/schema-rocksdb.properties | 94 --
.../src/assembly/schema-engine-rocksdb.xml | 44 -
.../schemaregion/rocksdb/CheckKeyResult.java | 50 -
.../schemaregion/rocksdb/RSchemaConfLoader.java | 185 ---
.../schemaregion/rocksdb/RSchemaConstants.java | 76 -
.../schemaregion/rocksdb/RSchemaLogger.java | 61 -
.../rocksdb/RSchemaReadWriteHandler.java | 515 -------
.../schemaregion/rocksdb/RSchemaRegion.java | 1558 --------------------
.../schemaregion/rocksdb/RSchemaUtils.java | 592 --------
.../schemaregion/rocksdb/mnode/RDatabaseMNode.java | 117 --
.../schemaregion/rocksdb/mnode/RDeviceMNode.java | 171 ---
.../schemaregion/rocksdb/mnode/RInternalMNode.java | 171 ---
.../schemaregion/rocksdb/mnode/RMNode.java | 230 ---
.../schemaregion/rocksdb/mnode/RMNodeType.java | 49 -
.../rocksdb/mnode/RMNodeValueType.java | 47 -
.../rocksdb/mnode/RMeasurementMNode.java | 249 ----
.../schemaregion/rocksdb/MRocksDBBenchmark.java | 98 --
.../schemaregion/rocksdb/MRocksDBUnitTest.java | 265 ----
.../rocksdb/RSchemaReadWriteHandlerTest.java | 77 -
.../rocksdb/RocksDBBenchmarkEngine.java | 144 --
.../schemaregion/rocksdb/RocksDBBenchmarkTask.java | 109 --
.../schemaregion/rocksdb/RocksDBTestUtils.java | 72 -
schema-engine-tag/README.md | 190 ---
schema-engine-tag/pom.xml | 81 -
.../assembly/resources/conf/schema-tag.properties | 33 -
.../src/assembly/schema-engine-tag.xml | 44 -
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 611 --------
.../tagSchemaRegion/config/TagSchemaConfig.java | 55 -
.../config/TagSchemaDescriptor.java | 93 --
.../idtable/IDTableWithDeviceIDListImpl.java | 138 --
.../tagIndex/ITagInvertedIndex.java | 61 -
.../tagIndex/Request/InsertionRequest.java | 59 -
.../tagSchemaRegion/tagIndex/TagInvertedIndex.java | 183 ---
.../tagIndex/deletion/MemChunkDeletion.java | 57 -
.../tagIndex/deletion/MemChunkGroupDeletion.java | 68 -
.../tagIndex/deletion/MemTableDeletion.java | 77 -
.../tagIndex/deletion/MemTableGroupDeletion.java | 66 -
.../tagIndex/insertion/MemChunkGroupInsertion.java | 65 -
.../tagIndex/insertion/MemChunkInsertion.java | 58 -
.../tagIndex/insertion/MemTableGroupInsertion.java | 74 -
.../tagIndex/insertion/MemTableInsertion.java | 67 -
.../tagIndex/memtable/MemChunk.java | 54 -
.../tagIndex/memtable/MemTable.java | 87 --
.../tagIndex/memtable/MemTableGroup.java | 102 --
.../tagIndex/query/MemChunkGroupQuery.java | 61 -
.../tagIndex/query/MemChunkQuery.java | 67 -
.../tagIndex/query/MemTableGroupQuery.java | 59 -
.../tagIndex/query/MemTableQuery.java | 72 -
.../tagIndex/response/QueryResponse.java | 71 -
.../tagSchemaRegion/tagIndex/wal/WALEntry.java | 134 --
.../tagSchemaRegion/tagIndex/wal/WALManager.java | 141 --
.../utils/MeasurementPathUtils.java | 80 -
.../utils/PathTagConverterUtils.java | 70 -
.../utils/ShowTimeSeriesResultUtils.java | 82 --
.../iotdb/lsm/annotation/DeletionProcessor.java | 36 -
.../iotdb/lsm/annotation/InsertionProcessor.java | 36 -
.../iotdb/lsm/annotation/QueryProcessor.java | 36 -
.../applicationcontext/ApplicationContext.java | 61 -
.../ApplicationContextGenerator.java | 119 --
.../requestcontext/DeleteRequestContext.java | 34 -
.../requestcontext/FlushRequestContext.java | 33 -
.../requestcontext/InsertRequestContext.java | 34 -
.../requestcontext/QueryRequestContext.java | 34 -
.../lsm/context/requestcontext/RequestContext.java | 108 --
.../org/apache/iotdb/lsm/engine/ILSMEngine.java | 73 -
.../org/apache/iotdb/lsm/engine/IRecoverable.java | 34 -
.../org/apache/iotdb/lsm/engine/LSMEngine.java | 176 ---
.../apache/iotdb/lsm/engine/LSMEngineBuilder.java | 290 ----
.../lsm/levelProcess/BasicLevelProcessor.java | 79 -
.../lsm/levelProcess/DeleteLevelProcessor.java | 39 -
.../lsm/levelProcess/FlushLevelProcessor.java | 38 -
.../iotdb/lsm/levelProcess/ILevelProcessor.java | 41 -
.../lsm/levelProcess/InsertLevelProcessor.java | 39 -
.../lsm/levelProcess/LevelProcessorChain.java | 45 -
.../lsm/levelProcess/QueryLevelProcessor.java | 39 -
.../apache/iotdb/lsm/manager/BasicLSMManager.java | 55 -
.../apache/iotdb/lsm/manager/DeletionManager.java | 48 -
.../org/apache/iotdb/lsm/manager/ILSMManager.java | 58 -
.../apache/iotdb/lsm/manager/InsertionManager.java | 48 -
.../org/apache/iotdb/lsm/manager/QueryManager.java | 32 -
.../apache/iotdb/lsm/manager/RecoverManager.java | 49 -
.../org/apache/iotdb/lsm/manager/WALManager.java | 126 --
.../apache/iotdb/lsm/request/IDeletionRequest.java | 30 -
.../iotdb/lsm/request/IInsertionRequest.java | 30 -
.../apache/iotdb/lsm/request/IQueryRequest.java | 35 -
.../org/apache/iotdb/lsm/request/IRequest.java | 61 -
.../org/apache/iotdb/lsm/request/RequestType.java | 27 -
.../org/apache/iotdb/lsm/response/IResponse.java | 46 -
.../iotdb/lsm/strategy/BFSAccessStrategy.java | 66 -
.../apache/iotdb/lsm/strategy/IAccessStrategy.java | 36 -
.../lsm/strategy/PostOrderAccessStrategy.java | 56 -
.../iotdb/lsm/strategy/PreOrderAccessStrategy.java | 54 -
.../iotdb/lsm/strategy/RBFSAccessStrategy.java | 85 --
.../java/org/apache/iotdb/lsm/wal/IWALReader.java | 48 -
.../java/org/apache/iotdb/lsm/wal/IWALRecord.java | 50 -
.../java/org/apache/iotdb/lsm/wal/WALReader.java | 99 --
.../java/org/apache/iotdb/lsm/wal/WALWriter.java | 111 --
.../tagSchemaRegion/TagSchemaRegionTest.java | 233 ---
.../idtable/IDTableWithDeviceIDListImplTest.java | 213 ---
.../tagIndex/TagTagInvertedIndexTest.java | 184 ---
.../tools/tsfile/print-iotdb-data-dir.bat | 2 +-
.../resources/tools/tsfile/print-iotdb-data-dir.sh | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 39 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 7 +-
.../org/apache/iotdb/db/conf/OperationType.java | 3 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 45 +-
.../iotdb/db/engine/cache/BloomFilterCache.java | 2 +-
.../db/engine/cache/CacheHitRatioMonitor.java | 2 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 11 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 17 +-
.../execute/task/AbstractCompactionTask.java | 6 +-
.../execute/task/CrossSpaceCompactionTask.java | 4 +-
.../execute/task/InnerSpaceCompactionTask.java | 4 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 16 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 8 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 10 +-
.../utils/writer/AbstractCompactionWriter.java | 4 +-
.../compaction/schedule/CompactionScheduler.java | 49 +-
.../compaction/schedule/CompactionTaskManager.java | 1 +
.../schedule/constant/CompactionType.java | 17 +-
.../schedule/constant/ProcessChunkType.java | 17 +-
.../iotdb/db/engine/flush/FlushManagerMetrics.java | 8 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 3 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 291 +---
.../db/engine/storagegroup/DataRegionMetrics.java | 8 +-
.../db/engine/storagegroup/TsFileManager.java | 1 +
.../db/engine/storagegroup/TsFileProcessor.java | 54 +-
.../db/engine/storagegroup/TsFileResource.java | 25 +-
.../db/engine/storagegroup/TsFileResourceList.java | 62 +-
.../metadata/cache/DataNodeSchemaCacheMetrics.java | 12 +-
.../db/metadata/metric/SchemaEngineMemMetric.java | 5 +-
.../iotdb/db/metadata/mtree/ConfigMTree.java | 8 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 54 +
.../traverser/basic/MeasurementTraverser.java | 6 +
.../plan/schemaregion/SchemaRegionPlanType.java | 3 +
.../plan/schemaregion/SchemaRegionPlanVisitor.java | 17 +
.../impl/SchemaRegionPlanDeserializer.java | 33 +-
.../impl/SchemaRegionPlanSerializer.java | 49 +-
.../impl/SchemaRegionPlanTxtSerializer.java | 25 +
.../impl/write/CreateLogicalViewPlanImpl.java | 6 +-
.../impl/write/DeleteLogicalViewPlanImpl.java | 25 +-
.../impl/write/PreDeleteLogicalViewPlanImpl.java | 25 +-
.../RollbackPreDeleteLogicalViewPlanImpl.java | 28 +-
.../impl/write/SchemaRegionWritePlanFactory.java | 31 +
.../write/view/IDeleteLogicalViewPlan.java | 27 +-
.../write/view/IPreDeleteLogicalViewPlan.java | 39 +-
.../view/IRollbackPreDeleteLogicalViewPlan.java | 34 +-
.../reader/SchemaReaderLimitOffsetWrapper.java | 86 ++
.../db/metadata/schemaregion/ISchemaRegion.java | 7 +
.../schemaregion/SchemaRegionMemoryImpl.java | 95 ++
.../schemaregion/SchemaRegionSchemaFileImpl.java | 15 +
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 3 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 44 +-
.../iotdb/db/mpp/aggregation/Aggregator.java | 15 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 13 +
.../db/mpp/common/header/DatasetHeaderFactory.java | 4 +
.../mpp/common/schematree/ClusterSchemaTree.java | 27 +-
.../db/mpp/common/schematree/ISchemaTree.java | 7 +
.../iotdb/db/mpp/execution/driver/DataDriver.java | 3 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 20 +-
.../execution/exchange/MPPDataExchangeManager.java | 45 +-
.../exchange/MPPDataExchangeServiceMetrics.java | 8 -
...MppDataExchangeServiceThriftHandlerMetrics.java | 35 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 16 +-
.../execution/exchange/sink/LocalSinkChannel.java | 7 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 8 +-
.../mpp/execution/exchange/sink/SinkChannel.java | 15 +-
.../exchange/source/LocalSourceHandle.java | 11 +-
.../execution/exchange/source/SourceHandle.java | 21 +-
.../execution/executor/RegionWriteExecutor.java | 4 +-
.../fragment/FragmentInstanceManager.java | 16 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 28 +-
.../schema/source/LogicalViewSchemaSource.java | 175 +++
.../schema/source/SchemaSourceFactory.java | 5 +
.../execution/operator/source/SeriesScanUtil.java | 9 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 17 +-
.../iotdb/db/mpp/metric/ChunkCacheMetrics.java | 14 +-
.../db/mpp/metric/DataExchangeCostMetricSet.java | 345 +++--
.../db/mpp/metric/DataExchangeCountMetricSet.java | 211 ++-
.../db/mpp/metric/DriverSchedulerMetricSet.java | 98 +-
.../db/mpp/metric/QueryExecutionMetricSet.java | 206 ++-
.../iotdb/db/mpp/metric/QueryMetricsManager.java | 122 +-
.../db/mpp/metric/QueryPlanCostMetricSet.java | 86 +-
.../mpp/metric/QueryRelatedResourceMetricSet.java | 162 ++
.../db/mpp/metric/QueryResourceMetricSet.java | 77 +-
.../db/mpp/metric/SeriesScanCostMetricSet.java | 1117 +++++++++-----
.../mpp/metric/TimeSeriesMetadataCacheMetrics.java | 26 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 6 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 27 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 307 +++-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 4 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 37 +
.../db/mpp/plan/analyze/cache/PartitionCache.java | 52 +-
.../db/mpp/plan/execution/IQueryExecution.java | 1 +
.../db/mpp/plan/execution/QueryExecution.java | 20 +-
.../plan/execution/config/ConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 43 +
.../config/executor/IConfigTaskExecutor.java | 4 +
.../config/metadata/ShowVariablesTask.java | 4 +
.../metadata/view/DeleteLogicalViewTask.java | 46 +
.../iotdb/db/mpp/plan/expression/Expression.java | 20 +
.../plan/expression/binary/BinaryExpression.java | 22 +
.../plan/expression/binary/WhenThenExpression.java | 7 +
.../db/mpp/plan/expression/leaf/LeafOperand.java | 5 +
.../plan/expression/multi/FunctionExpression.java | 21 +
.../expression/other/CaseWhenThenExpression.java | 17 +
.../plan/expression/ternary/BetweenExpression.java | 9 +
.../plan/expression/ternary/TernaryExpression.java | 18 +-
.../db/mpp/plan/expression/unary/InExpression.java | 26 +-
.../plan/expression/unary/IsNullExpression.java | 5 +
.../mpp/plan/expression/unary/LikeExpression.java | 5 +
.../plan/expression/unary/LogicNotExpression.java | 9 +
.../plan/expression/unary/NegationExpression.java | 11 +
.../plan/expression/unary/RegularExpression.java | 5 +
.../mpp/plan/expression/unary/UnaryExpression.java | 6 +-
.../visitor/CompleteMeasurementSchemaVisitor.java | 112 ++
.../RemoveWildcardAndViewInExpressionVisitor.java | 95 ++
.../RemoveWildcardAndViewInFilterVisitor.java | 109 ++
.../visitor/ReplaceLogicalViewVisitor.java | 188 +++
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 66 +-
.../db/mpp/plan/parser/StatementGenerator.java | 2 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 4 +
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 9 +
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 41 +-
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 4 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 20 +
.../mpp/plan/planner/plan/node/PlanNodeType.java | 20 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 25 +-
.../plan/node/load/LoadSingleTsFileNode.java | 4 +
.../metedata/read/LogicalViewSchemaScanNode.java | 126 ++
.../view/ConstructLogicalViewBlackListNode.java | 91 ++
.../write/{ => view}/CreateLogicalViewNode.java | 2 +-
.../metedata/write/view/DeleteLogicalViewNode.java | 91 ++
.../view/RollbackLogicalViewBlackListNode.java | 91 ++
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 2 +-
.../db/mpp/plan/scheduler/ClusterScheduler.java | 7 +-
.../scheduler/FixedRateFragInsStateTracker.java | 14 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 10 +-
.../plan/scheduler/IFragInstanceStateTracker.java | 4 +-
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 52 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 8 +-
.../iotdb/db/mpp/plan/statement/StatementType.java | 1 +
.../db/mpp/plan/statement/StatementVisitor.java | 13 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 55 +-
.../{ => view}/CreateLogicalViewStatement.java | 28 +-
.../metadata/view/DeleteLogicalViewStatement.java | 66 +
.../metadata/view/ShowLogicalViewStatement.java | 62 +
.../org/apache/iotdb/db/pipe/agent/PipeAgent.java | 12 +
.../db/pipe/agent/plugin/PipePluginAgent.java | 2 +-
.../pipe/agent/receiver/IoTDBThriftReceiver.java | 24 +-
.../db/pipe/agent/receiver/PipeReceiverAgent.java | 90 ++
.../db/pipe/agent/runtime/MetaSyncScheduler.java | 22 -
.../iotdb/db/pipe/agent/runtime/PipeLauncher.java | 175 +++
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 42 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 381 ++---
.../apache/iotdb/db/pipe/config/PipeConfig.java | 16 +
.../db/pipe/config/PipeConnectorConstant.java | 3 +
.../core/collector/IoTDBDataRegionCollector.java | 39 +-
.../PipeHistoricalDataRegionTsFileCollector.java | 13 +-
.../PipeRealtimeDataRegionHybridCollector.java | 55 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 3 +-
.../listener/PipeInsertionDataNodeListener.java | 14 +-
.../impl/iotdb/IoTDBThriftConnectorClient.java | 70 +
.../impl/iotdb/IoTDBThriftConnectorVersion.java | 16 +-
.../impl/iotdb/v1/IoTDBThriftConnectorV1.java | 232 +++
.../impl/iotdb/v1/IoTDBThriftReceiverV1.java | 275 ++++
.../connector/impl/iotdb/v1/PipeRequestType.java | 44 +-
.../v1/reponse/PipeTransferFilePieceResp.java | 80 +
.../iotdb/v1/request/PipeTransferFilePieceReq.java | 88 ++
.../iotdb/v1/request/PipeTransferFileSealReq.java | 79 +
.../iotdb/v1/request/PipeTransferHandshakeReq.java | 71 +
.../v1/request/PipeTransferInsertNodeReq.java | 102 ++
.../PipeConnectorSubtaskLifeCycle.java | 2 +-
.../{ => manager}/PipeConnectorSubtaskManager.java | 18 +-
.../core/event/impl/PipeTabletInsertionEvent.java | 53 +-
.../core/event/impl/PipeTsFileInsertionEvent.java | 37 +-
.../event/realtime/PipeRealtimeCollectEvent.java | 6 -
.../realtime/PipeRealtimeCollectEventFactory.java | 11 +-
.../event/view/collector/PipeEventCollector.java | 22 +-
.../execution/executor/PipeSubtaskExecutor.java | 41 +-
.../execution/scheduler/PipeSubtaskScheduler.java | 89 ++
.../execution/scheduler/PipeTaskScheduler.java | 74 -
.../db/pipe/resource/PipeResourceManager.java | 9 +
.../{ => file}/PipeFileResourceManager.java | 2 +-
.../db/pipe/resource/wal/PipeWALResource.java | 162 ++
.../pipe/resource/wal/PipeWALResourceManager.java | 111 ++
.../org/apache/iotdb/db/pipe/task/PipeBuilder.java | 8 +-
.../db/pipe/task/stage/PipeTaskCollectorStage.java | 25 +-
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 11 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 19 +-
.../db/pipe/task/subtask/PipeConnectorSubtask.java | 63 +-
.../db/pipe/task/subtask/PipeProcessorSubtask.java | 45 +-
.../iotdb/db/pipe/task/subtask/PipeSubtask.java | 62 +-
.../query/reader/chunk/DiskAlignedChunkLoader.java | 10 +-
.../db/query/reader/chunk/DiskChunkLoader.java | 10 +-
.../query/reader/chunk/MemAlignedChunkLoader.java | 10 +-
.../db/query/reader/chunk/MemChunkLoader.java | 10 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 11 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 11 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 10 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 9 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 102 +-
.../service/DataNodeInternalRPCServiceMetrics.java | 8 +-
.../apache/iotdb/db/service/RPCServiceMetrics.java | 8 +-
.../iotdb/db/service/metrics/CacheMetrics.java | 144 ++
.../db/service/metrics/CompactionMetrics.java | 396 ++++-
.../db/service/metrics/DataNodeMetricsHelper.java | 22 +-
.../iotdb/db/service/metrics/SystemMetrics.java | 43 +-
.../iotdb/db/service/metrics/WritingMetrics.java | 574 +++++++-
.../metrics/recorder/CacheMetricsRecorder.java | 57 -
.../metrics/recorder/CompactionMetricsManager.java | 240 ---
.../metrics/recorder/WritingMetricsManager.java | 351 -----
.../InternalServiceThriftHandlerMetrics.java | 8 +-
.../handler/RPCServiceThriftHandlerMetrics.java | 8 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 209 ++-
.../impl/DataNodeInternalRPCServiceImpl.java | 101 +-
.../db/sync/common/ClusterSyncInfoFetcher.java | 11 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 41 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 17 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 6 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 12 +-
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 4 +-
.../iotdb/db/wal/checkpoint/CheckpointType.java | 16 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 8 +-
.../{WALPipeHandler.java => WALEntryHandler.java} | 22 +-
.../db/wal/utils/listener/WALFlushListener.java | 10 +-
.../engine/compaction/AbstractCompactionTest.java | 53 +-
.../ReadPointCompactionPerformerTest.java | 16 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 5 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 10 +-
...eCrossSpaceCompactionWithFastPerformerTest.java | 21 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 21 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 76 +
.../SizeTieredCompactionRecoverTest.java | 52 +-
.../SizeTieredCompactionSelectorTest.java | 38 +
.../compaction/utils/CompactionCheckerUtils.java | 4 +
.../utils/MultiTsFileDeviceIteratorTest.java | 14 +
.../storagegroup/TsFileResourceListTest.java | 110 ++
.../schemaRegion/SchemaRegionBasicTest.java | 49 +
.../execution/exchange/LocalSinkChannelTest.java | 14 +-
.../execution/exchange/LocalSourceHandleTest.java | 14 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 7 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 2 +-
.../mpp/plan/analyze/ExpressionAnalyzerTest.java | 4 +-
.../core/collector/PipeRealtimeCollectTest.java | 26 +-
.../pipe/core/connector/PipeThriftRequestTest.java | 118 ++
.../pipe/resource/PipeFileResourceManagerTest.java | 1 +
...peHandlerTest.java => WALEntryHandlerTest.java} | 18 +-
.../iotdb/db/wal/utils/WALInsertNodeCacheTest.java | 8 +-
.../src/test/resources/iotdb-datanode.properties | 23 -
.../apache/iotdb/spark/db/EnvironmentUtils.java | 263 ----
.../org/apache/iotdb/spark/db/IoTDBTest.scala | 150 --
.../org/apache/iotdb/spark/db/IoTDBWriteTest.scala | 118 --
.../iotdb/spark/db/unit/DataFrameToolsTest.scala | 96 --
.../java/org/apache/iotdb/tsfile/utils/Binary.java | 20 +-
1069 files changed, 13108 insertions(+), 39346 deletions(-)
delete mode 160000 client-go
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/{coordinator => runtime}/PipeHandleLeaderChangePlan.java (99%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/runtime/PipeHandleMetaChangePlan.java
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{ => plugin}/PipePluginCoordinator.java (98%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/runtime/PipeMetaSyncer.java
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{ => runtime}/PipeRuntimeCoordinator.java (74%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{ => task}/PipeTaskCoordinator.java (91%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleMetaChangeProcedure.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeMetaSyncProcedure.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteLogicalViewProcedure.java
rename influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/constant/InfluxDBConstant.java => confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DeleteLogicalViewState.java (82%)
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleMetaChangeProcedureTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeMetaSyncProcedureTest.java
copy distribution/src/assembly/{client-cpp.xml => spark-connector.xml} (63%)
delete mode 100644 grafana-plugin/go.sum
delete mode 100644 influxdb-protocol/pom.xml
delete mode 100644 influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/IoTDBInfluxDB.java
delete mode 100644 influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/IoTDBInfluxDBFactory.java
delete mode 100644 influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/dto/SessionPoint.java
delete mode 100644 influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/impl/IoTDBInfluxDBService.java
delete mode 100644 influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/util/ParameterUtils.java
delete mode 100644 influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/session/InfluxDBSession.java
delete mode 100644 influxdb-protocol/src/test/java/org/apache/iotdb/influxdb/integration/IoTDBInfluxDBIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/spark/it/AbstractTest.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/spark/it/ReadTest.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/spark/it/Utils.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/spark/it/WriteTest.java
delete mode 100644 integration/README.md
delete mode 100644 integration/checkstyle.xml
delete mode 100644 integration/import-control.xml
delete mode 100644 integration/pom.xml
delete mode 100644 integration/src/assembly/cluster.xml
delete mode 100644 integration/src/main/java/org/apache/iotdb/db/engine/trigger/example/Accumulator.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/db/engine/trigger/example/Counter.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/db/query/udf/example/Accumulator.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/db/query/udf/example/Adder.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/db/query/udf/example/Counter.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/db/query/udf/example/ExampleUDFConstant.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/db/query/udf/example/Max.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/db/query/udf/example/Multiplier.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/db/query/udf/example/SlidingSizeWindowConstructorTester0.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/db/query/udf/example/SlidingSizeWindowConstructorTester1.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/db/query/udf/example/SlidingTimeWindowConstructionTester.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/db/query/udf/example/TerminateTester.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/db/query/udf/example/ValidateTester.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/db/query/udf/example/WindowStartEnd.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/integration/env/ClusterEnvBase.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/integration/env/ClusterEnvConfig.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/integration/env/ClusterNode.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/integration/env/ConfigFactory.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/integration/env/EnvFactory.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/integration/env/FiveNodeCluster1Env.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/integration/env/RemoteEnvConfig.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/integration/env/RemoteServerEnv.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/itbase/category/ClusterTest.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/itbase/category/LocalStandaloneTest.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/itbase/category/RemoteTest.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/itbase/env/BaseConfig.java
delete mode 100644 integration/src/main/java/org/apache/iotdb/itbase/env/BaseEnv.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IOTDBInsertIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBAlignedTimeSeriesCompactionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBCheckConfigIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBClearCacheIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBCloseIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBCompactionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBCompactionWithIDTableIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBCompressTypeIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBContinuousQueryIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBDaemonIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBDisableAlignIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBFillIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBFlushQueryMergeIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBKillQueryIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBLargeDataIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBLastIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBMaxTimeQueryIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiOverlappedChunkInUnseqIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiOverlappedPageIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiSeriesIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiStatementsIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBNewTsFileCompactionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBOverlappedPageIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryTimeoutIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryWithIDTableIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBRemovePartitionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBRepeatPatternNameIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBRewriteTsFileToolIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBRpcCompressionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSensorUpdateIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSessionTimeoutIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSetSystemReadOnlyWritableIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSizeTieredCompactionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSortedShowTimeseriesIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTimePartitionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTracingIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTtlIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBUDFWindowQueryIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFHybridQueryIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFNonAlignQueryIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBUnseqOverlappedPageIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBVersionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/env/StandaloneEnv.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/env/StandaloneEnvConfig.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/versionadaption/IoTDBDDLVersionAdaptionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/versionadaption/IoTDBDeletionVersionAdaptionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/versionadaption/IoTDBQueryVersionAdaptionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/session/IoTDBSessionAlignedABDeviceIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/session/IoTDBSessionAlignedAggregationIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/session/IoTDBSessionAlignedAggregationWithUnSeqIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/session/IoTDBSessionIteratorIT.java
delete mode 100644 integration/src/test/resources/iotdb-datanode.properties
delete mode 100644 integration/src/test/resources/logback-test.xml
rename {external-api => iotdb-api/external-api}/pom.xml (98%)
rename {external-api => iotdb-api/external-api}/src/main/java/org/apache/iotdb/external/api/IPropertiesLoader.java (100%)
rename {external-api => iotdb-api/external-api}/src/main/java/org/apache/iotdb/external/api/ISeriesNumerMonitor.java (100%)
rename {external-api => iotdb-api/external-api}/src/main/java/org/apache/iotdb/external/api/thrift/JudgableServerContext.java (100%)
rename {external-api => iotdb-api/external-api}/src/main/java/org/apache/iotdb/external/api/thrift/ServerContextFactory.java (100%)
rename {external-pipe-api => iotdb-api/external-pipe-api}/pom.xml (96%)
rename {external-pipe-api => iotdb-api/external-pipe-api}/src/main/java/org/apache/iotdb/pipe/external/api/DataType.java (100%)
rename {external-pipe-api => iotdb-api/external-pipe-api}/src/main/java/org/apache/iotdb/pipe/external/api/ExternalPipeSinkWriterStatus.java (100%)
rename {external-pipe-api => iotdb-api/external-pipe-api}/src/main/java/org/apache/iotdb/pipe/external/api/IExternalPipeSinkWriter.java (100%)
rename {external-pipe-api => iotdb-api/external-pipe-api}/src/main/java/org/apache/iotdb/pipe/external/api/IExternalPipeSinkWriterFactory.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/pom.xml (98%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/PipeCollector.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/PipeConnector.java (92%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/PipePlugin.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/PipeProcessor.java (93%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/access/Row.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/access/RowIterator.java (100%)
rename schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/IWALWriter.java => iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/EventCollector.java (62%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/customizer/PipeParameterValidator.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/customizer/PipeParameters.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/customizer/PipeRuntimeConfiguration.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/customizer/PipeStrategy.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/customizer/collector/PipeCollectorRuntimeConfiguration.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/PipeConnectorRuntimeConfiguration.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/parallel/ParallelStrategy.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/retry/EqualRetryIntervalStrategy.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/retry/ExponentialRetryIntervalStrategy.java (100%)
copy {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/retry/RetryStrategy.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/reuse/ReuseStrategy.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/customizer/processor/PipeProcessorRuntimeConfiguration.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/event/Event.java (91%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/event/EventType.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/event/dml/insertion/TabletInsertionEvent.java (94%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/event/dml/insertion/TsFileInsertionEvent.java (92%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/exception/PipeAttributeNotProvidedException.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/exception/PipeConnectionException.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/exception/PipeException.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/exception/PipeManagementException.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/exception/PipeParameterNotValidException.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/exception/PipeRuntimeCriticalException.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/exception/PipeRuntimeException.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/exception/PipeRuntimeNonCriticalException.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/exception/PipeStrategyNotValidException.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/type/Binary.java (100%)
rename {pipe-api => iotdb-api/pipe-api}/src/main/java/org/apache/iotdb/pipe/api/type/Type.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/pom.xml (98%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/SubscriptionConfiguration.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/SubscriptionFactory.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/consumer/Consumer.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/consumer/pull/PullConsumer.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/consumer/push/DataArrivalListener.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/consumer/push/ExceptionListener.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/consumer/push/PushConsumer.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/dataset/SubscriptionDataSet.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/exception/SubscriptionException.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/exception/SubscriptionStrategyNotValidException.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/strategy/SubscriptionStrategy.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/strategy/disorder/DisorderHandlingStrategy.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/strategy/disorder/IntolerableStrategy.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/strategy/disorder/WatermarkStrategy.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/strategy/topic/MultipleConnectionStrategy.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/strategy/topic/SingleTopicStrategy.java (100%)
rename {subscription-api => iotdb-api/subscription-api}/src/main/java/org/apache/iotdb/subscription/api/strategy/topic/TopicsStrategy.java (100%)
rename {trigger-api => iotdb-api/trigger-api}/pom.xml (98%)
rename {trigger-api => iotdb-api/trigger-api}/src/main/java/org/apache/iotdb/trigger/api/Trigger.java (100%)
rename {trigger-api => iotdb-api/trigger-api}/src/main/java/org/apache/iotdb/trigger/api/TriggerAttributes.java (100%)
rename {trigger-api => iotdb-api/trigger-api}/src/main/java/org/apache/iotdb/trigger/api/enums/FailureStrategy.java (100%)
rename {trigger-api => iotdb-api/trigger-api}/src/main/java/org/apache/iotdb/trigger/api/enums/TriggerEvent.java (100%)
rename {trigger-api => iotdb-api/trigger-api}/src/main/java/org/apache/iotdb/trigger/api/enums/TriggerType.java (100%)
rename {udf-api => iotdb-api/udf-api}/pom.xml (98%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/UDF.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/UDTF.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/access/Row.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/access/RowIterator.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/access/RowWindow.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/collector/PointCollector.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/customizer/config/UDFConfigurations.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/customizer/config/UDTFConfigurations.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/customizer/parameter/UDFParameterValidator.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/customizer/parameter/UDFParameters.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/customizer/strategy/AccessStrategy.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/customizer/strategy/MappableRowByRowAccessStrategy.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/customizer/strategy/RowByRowAccessStrategy.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/customizer/strategy/SessionTimeWindowAccessStrategy.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/customizer/strategy/SlidingSizeWindowAccessStrategy.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/customizer/strategy/SlidingTimeWindowAccessStrategy.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/customizer/strategy/StateWindowAccessStrategy.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/exception/UDFAttributeNotProvidedException.java (100%)
copy {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/exception/UDFException.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/exception/UDFInputSeriesDataTypeNotValidException.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/exception/UDFInputSeriesIndexNotValidException.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/exception/UDFInputSeriesNumberNotValidException.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/exception/UDFManagementException.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/exception/UDFOutputSeriesDataTypeNotValidException.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/exception/UDFParameterNotValidException.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/type/Binary.java (100%)
rename {udf-api => iotdb-api/udf-api}/src/main/java/org/apache/iotdb/udf/api/type/Type.java (100%)
rename {cli => iotdb-client/cli}/pom.xml (99%)
rename {cli => iotdb-client/cli}/src/assembly/cli.xml (100%)
rename {cli => iotdb-client/cli}/src/assembly/resources/conf/logback-cli.xml (100%)
rename {cli => iotdb-client/cli}/src/assembly/resources/sbin/start-cli.bat (100%)
rename {cli => iotdb-client/cli}/src/assembly/resources/sbin/start-cli.sh (100%)
rename {cli => iotdb-client/cli}/src/assembly/resources/tools/export-csv.bat (100%)
rename {cli => iotdb-client/cli}/src/assembly/resources/tools/export-csv.sh (100%)
rename {cli => iotdb-client/cli}/src/assembly/resources/tools/export-tsfile.bat (100%)
rename {cli => iotdb-client/cli}/src/assembly/resources/tools/export-tsfile.sh (100%)
rename {cli => iotdb-client/cli}/src/assembly/resources/tools/import-csv.bat (100%)
rename {cli => iotdb-client/cli}/src/assembly/resources/tools/import-csv.sh (100%)
rename {cli => iotdb-client/cli}/src/assembly/resources/tools/load-tsfile.bat (100%)
rename {cli => iotdb-client/cli}/src/assembly/resources/tools/load-tsfile.sh (100%)
rename {cli => iotdb-client/cli}/src/main/java/org/apache/iotdb/cli/AbstractCli.java (100%)
rename {cli => iotdb-client/cli}/src/main/java/org/apache/iotdb/cli/Cli.java (100%)
rename {cli => iotdb-client/cli}/src/main/java/org/apache/iotdb/cli/IoTDBSyntaxHighlighter.java (100%)
rename {cli => iotdb-client/cli}/src/main/java/org/apache/iotdb/cli/utils/IoTPrinter.java (100%)
rename {cli => iotdb-client/cli}/src/main/java/org/apache/iotdb/cli/utils/JlineUtils.java (100%)
rename {cli => iotdb-client/cli}/src/main/java/org/apache/iotdb/exception/ArgsErrorException.java (100%)
rename {cli => iotdb-client/cli}/src/main/java/org/apache/iotdb/tool/AbstractCsvTool.java (100%)
rename {cli => iotdb-client/cli}/src/main/java/org/apache/iotdb/tool/AbstractTsFileTool.java (100%)
rename {cli => iotdb-client/cli}/src/main/java/org/apache/iotdb/tool/ExportCsv.java (100%)
rename {cli => iotdb-client/cli}/src/main/java/org/apache/iotdb/tool/ExportTsFile.java (100%)
rename {cli => iotdb-client/cli}/src/main/java/org/apache/iotdb/tool/ImportCsv.java (100%)
rename {cli => iotdb-client/cli}/src/test/java/org/apache/iotdb/cli/AbstractCliIT.java (100%)
rename {cli => iotdb-client/cli}/src/test/java/org/apache/iotdb/cli/AbstractScript.java (100%)
rename {cli => iotdb-client/cli}/src/test/java/org/apache/iotdb/tool/integration/ExportCsvTestIT.java (100%)
rename {cli => iotdb-client/cli}/src/test/java/org/apache/iotdb/tool/integration/ImportCsvTestIT.java (100%)
rename {cli => iotdb-client/cli}/src/test/java/org/apache/iotdb/tool/unit/WriteCsvFileTestUT.java (100%)
rename {cli => iotdb-client/cli}/src/test/resources/logback.xml (100%)
rename {client-cpp => iotdb-client/client-cpp}/README.md (100%)
rename {client-cpp => iotdb-client/client-cpp}/pom.xml (93%)
rename {client-cpp => iotdb-client/client-cpp}/src/assembly/client-cpp.xml (100%)
rename {client-cpp => iotdb-client/client-cpp}/src/main/CMakeLists.txt (100%)
rename {client-cpp => iotdb-client/client-cpp}/src/main/Session.cpp (100%)
rename {client-cpp => iotdb-client/client-cpp}/src/main/Session.h (100%)
rename {client-cpp => iotdb-client/client-cpp}/src/test/CMakeLists.txt (100%)
rename {client-cpp => iotdb-client/client-cpp}/src/test/cpp/sessionIT.cpp (100%)
rename {client-cpp => iotdb-client/client-cpp}/src/test/main.cpp (100%)
create mode 160000 iotdb-client/client-go
rename {client-py => iotdb-client/client-py}/.flake8 (100%)
rename {client-py => iotdb-client/client-py}/.gitignore (100%)
rename {client-py => iotdb-client/client-py}/README.md (100%)
rename {client-py => iotdb-client/client-py}/SessionAlignedTimeseriesExample.py (100%)
rename {client-py => iotdb-client/client-py}/SessionExample.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/IoTDBContainer.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/Session.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/__init__.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/dbapi/Connection.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/dbapi/Cursor.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/dbapi/Exceptions.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/dbapi/__init__.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/dbapi/tests/__init__.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/dbapi/tests/test_connection.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/dbapi/tests/test_cursor.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/sqlalchemy/IoTDBDialect.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/sqlalchemy/IoTDBIdentifierPreparer.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/sqlalchemy/IoTDBSQLCompiler.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/sqlalchemy/IoTDBTypeCompiler.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/sqlalchemy/__init__.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/sqlalchemy/tests/__init__.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/sqlalchemy/tests/test_dialect.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/template/InternalNode.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/template/MeasurementNode.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/template/Template.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/template/TemplateNode.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/template/TemplateQueryType.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/template/__init__.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/tsfile/__init__.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/tsfile/common/__init__.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/tsfile/common/constant/TsFileConstant.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/tsfile/common/constant/__init__.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/tsfile/utils/Pair.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/tsfile/utils/ReadWriteIOUtils.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/tsfile/utils/__init__.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/utils/BitMap.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/utils/Field.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/utils/IoTDBConnectionException.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/utils/IoTDBConstants.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/utils/IoTDBRpcDataSet.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/utils/NumpyTablet.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/utils/RowRecord.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/utils/SessionDataSet.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/utils/Tablet.py (100%)
rename {client-py => iotdb-client/client-py}/iotdb/utils/__init__.py (100%)
rename {client-py => iotdb-client/client-py}/pom.xml (94%)
rename {client-py => iotdb-client/client-py}/pyproject.toml (100%)
rename {client-py => iotdb-client/client-py}/release.sh (100%)
rename {client-py => iotdb-client/client-py}/requirements.txt (100%)
rename {client-py => iotdb-client/client-py}/requirements_dev.txt (100%)
rename {client-py => iotdb-client/client-py}/setup.py (100%)
rename {client-py => iotdb-client/client-py}/tests/__init__.py (100%)
rename {client-py => iotdb-client/client-py}/tests/tablet_performance_comparison.py (100%)
rename {client-py => iotdb-client/client-py}/tests/test_aligned_timeseries.py (100%)
rename {client-py => iotdb-client/client-py}/tests/test_dataframe.py (100%)
rename {client-py => iotdb-client/client-py}/tests/test_delete_data.py (100%)
rename {client-py => iotdb-client/client-py}/tests/test_numpy_tablet.py (100%)
rename {client-py => iotdb-client/client-py}/tests/test_one_device.py (100%)
rename {client-py => iotdb-client/client-py}/tests/test_session.py (100%)
rename {client-py => iotdb-client/client-py}/tests/test_tablet.py (100%)
rename {client-py => iotdb-client/client-py}/tests/test_template.py (100%)
rename {client-py => iotdb-client/client-py}/tests/test_todf.py (100%)
rename {compile-tools => iotdb-client/compile-tools}/README.md (100%)
rename {compile-tools => iotdb-client/compile-tools}/pom.xml (99%)
rename {compile-tools => iotdb-client/compile-tools}/thrift/pom.xml (100%)
rename {isession => iotdb-client/isession}/pom.xml (96%)
rename {isession => iotdb-client/isession}/src/main/java/org/apache/iotdb/isession/ISession.java (100%)
rename {isession => iotdb-client/isession}/src/main/java/org/apache/iotdb/isession/SessionConfig.java (100%)
rename {isession => iotdb-client/isession}/src/main/java/org/apache/iotdb/isession/SessionDataSet.java (98%)
rename {isession => iotdb-client/isession}/src/main/java/org/apache/iotdb/isession/pool/ISessionPool.java (100%)
rename {isession => iotdb-client/isession}/src/main/java/org/apache/iotdb/isession/pool/SessionDataSetWrapper.java (100%)
rename {isession => iotdb-client/isession}/src/main/java/org/apache/iotdb/isession/template/Template.java (100%)
rename {isession => iotdb-client/isession}/src/main/java/org/apache/iotdb/isession/template/TemplateNode.java (100%)
rename {isession => iotdb-client/isession}/src/main/java/org/apache/iotdb/isession/util/SystemStatus.java (100%)
rename {isession => iotdb-client/isession}/src/main/java/org/apache/iotdb/isession/util/Version.java (100%)
rename {jdbc => iotdb-client/jdbc}/README.md (100%)
rename {jdbc => iotdb-client/jdbc}/osgi.bnd (100%)
rename {jdbc => iotdb-client/jdbc}/pom.xml (99%)
rename {jdbc => iotdb-client/jdbc}/src/main/feature/feature.xml (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/AbstractIoTDBJDBCResultSet.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/Activator.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/Config.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/Constant.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/Field.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/GroupedLSBWatermarkEncoder.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/IoTDBConnection.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/IoTDBConnectionParams.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSource.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSourceFactory.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/IoTDBDriver.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/IoTDBPreparedStatement.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/IoTDBResultMetadata.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/IoTDBSQLException.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/IoTDBTracingInfo.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/IoTDBURLException.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/StringUtils.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/Utils.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/java/org/apache/iotdb/jdbc/WatermarkEncoder.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/main/resources/services/META-INF/java.sql.Driver (100%)
rename {jdbc => iotdb-client/jdbc}/src/test/java/org/apache/iotdb/jdbc/BatchTest.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/test/java/org/apache/iotdb/jdbc/IoTDBConnectionTest.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/test/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadataTest.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/test/java/org/apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/test/java/org/apache/iotdb/jdbc/IoTDBPreparedStatementTest.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/test/java/org/apache/iotdb/jdbc/IoTDBResultMetadataTest.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/test/java/org/apache/iotdb/jdbc/IoTDBStatementTest.java (100%)
rename {jdbc => iotdb-client/jdbc}/src/test/java/org/apache/iotdb/jdbc/UtilsTest.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/pom.xml (99%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/AutoResizingBuffer.java (93%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/AutoScalingBufferReadTransport.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/AutoScalingBufferWriteTransport.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/BatchExecutionException.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/ConfigNodeConnectionException.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/ConfigurableTByteBuffer.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/InfluxDBSynchronizedHandler.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/IoTDBConnectionException.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/IoTDBJDBCDataSet.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/NoValidValueException.java (100%)
copy {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/NonOpenTransport.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/RedirectException.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/RpcStat.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/RpcTransportFactory.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/RpcUtils.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/StatementExecutionException.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/SynchronizedHandler.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/TCompressedElasticFramedTransport.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/TConfigurationConst.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/TElasticFramedTransport.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/TNonblockingSocketWrapper.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/TSStatusCode.java (96%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/TSnappyElasticFramedTransport.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/TSocketWrapper.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/TimeoutChangeableTFastFramedTransport.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/TimeoutChangeableTSnappyFramedTransport.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/main/java/org/apache/iotdb/rpc/TimeoutChangeableTransport.java (100%)
rename {service-rpc => iotdb-client/service-rpc}/src/test/java/org/apache/iotdb/rpc/TSStatusCodeTest.java (100%)
rename {session => iotdb-client/session}/pom.xml (99%)
rename {session => iotdb-client/session}/src/main/java/org/apache/iotdb/session/InsertConsumer.java (100%)
rename {session => iotdb-client/session}/src/main/java/org/apache/iotdb/session/Session.java (99%)
rename {session => iotdb-client/session}/src/main/java/org/apache/iotdb/session/SessionConnection.java (100%)
rename {session => iotdb-client/session}/src/main/java/org/apache/iotdb/session/pool/SessionPool.java (99%)
rename {session => iotdb-client/session}/src/main/java/org/apache/iotdb/session/template/InternalNode.java (100%)
rename {session => iotdb-client/session}/src/main/java/org/apache/iotdb/session/template/MeasurementNode.java (100%)
rename {session => iotdb-client/session}/src/main/java/org/apache/iotdb/session/template/TemplateQueryType.java (100%)
rename {session => iotdb-client/session}/src/main/java/org/apache/iotdb/session/util/SessionUtils.java (100%)
rename {session => iotdb-client/session}/src/main/java/org/apache/iotdb/session/util/ThreadUtils.java (100%)
rename {session => iotdb-client/session}/src/test/java/org/apache/iotdb/session/SessionCacheLeaderUT.java (100%)
rename {session => iotdb-client/session}/src/test/java/org/apache/iotdb/session/TabletTest.java (100%)
rename {session => iotdb-client/session}/src/test/java/org/apache/iotdb/session/pool/SessionPoolTest.java (100%)
rename {session => iotdb-client/session}/src/test/java/org/apache/iotdb/session/util/ThreadUtilsTest.java (100%)
rename {session => iotdb-client/session}/src/test/resources/iotdb-common.properties (100%)
rename {session => iotdb-client/session}/src/test/resources/iotdb-datanode.properties (100%)
rename {session => iotdb-client/session}/src/test/resources/logback.xml (100%)
rename {flink-iotdb-connector => iotdb-connector/flink-iotdb-connector}/README.md (100%)
rename {flink-iotdb-connector => iotdb-connector/flink-iotdb-connector}/pom.xml (97%)
rename {flink-iotdb-connector => iotdb-connector/flink-iotdb-connector}/src/main/java/org/apache/iotdb/flink/DefaultIoTSerializationSchema.java (100%)
rename {flink-iotdb-connector => iotdb-connector/flink-iotdb-connector}/src/main/java/org/apache/iotdb/flink/Event.java (100%)
rename {flink-iotdb-connector => iotdb-connector/flink-iotdb-connector}/src/main/java/org/apache/iotdb/flink/IoTDBSink.java (100%)
rename {flink-iotdb-connector => iotdb-connector/flink-iotdb-connector}/src/main/java/org/apache/iotdb/flink/IoTDBSource.java (100%)
rename {flink-iotdb-connector => iotdb-connector/flink-iotdb-connector}/src/main/java/org/apache/iotdb/flink/IoTSerializationSchema.java (100%)
rename {flink-iotdb-connector => iotdb-connector/flink-iotdb-connector}/src/main/java/org/apache/iotdb/flink/options/IoTDBOptions.java (100%)
rename {flink-iotdb-connector => iotdb-connector/flink-iotdb-connector}/src/main/java/org/apache/iotdb/flink/options/IoTDBSinkOptions.java (100%)
rename {flink-iotdb-connector => iotdb-connector/flink-iotdb-connector}/src/main/java/org/apache/iotdb/flink/options/IoTDBSourceOptions.java (100%)
rename {flink-iotdb-connector => iotdb-connector/flink-iotdb-connector}/src/test/java/org/apache/iotdb/flink/DefaultIoTSerializationSchemaTest.java (100%)
rename {flink-iotdb-connector => iotdb-connector/flink-iotdb-connector}/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchInsertTest.java (100%)
rename {flink-iotdb-connector => iotdb-connector/flink-iotdb-connector}/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchTimerTest.java (100%)
rename {flink-iotdb-connector => iotdb-connector/flink-iotdb-connector}/src/test/java/org/apache/iotdb/flink/IoTDBSinkInsertTest.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/README.md (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/pom.xml (98%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/main/java/org/apache/iotdb/flink/tsfile/RowRecordParser.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/main/java/org/apache/iotdb/flink/tsfile/RowRowRecordParser.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/main/java/org/apache/iotdb/flink/tsfile/RowTSRecordConverter.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/main/java/org/apache/iotdb/flink/tsfile/TSRecordConverter.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/main/java/org/apache/iotdb/flink/tsfile/TSRecordOutputFormat.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/main/java/org/apache/iotdb/flink/tsfile/TsFileOutputFormat.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/main/java/org/apache/iotdb/flink/tsfile/util/TSFileConfigUtil.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/test/java/org/apache/iotdb/flink/tsfile/RowTSRecordOutputFormatIntegrationTest.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/test/java/org/apache/iotdb/flink/tsfile/RowTSRecordOutputFormatTest.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileConnectorTestBase.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatIntegrationTest.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTestBase.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileOutputFormatTestBase.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/test/java/org/apache/iotdb/flink/util/TSFileConfigUtilCompletenessTest.java (100%)
rename {flink-tsfile-connector => iotdb-connector/flink-tsfile-connector}/src/test/java/org/apache/iotdb/flink/util/TsFileWriteUtil.java (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/img/add_data_source.png (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/img/add_graph.png (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/img/edit_data_source.png (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/pom.xml (99%)
rename {grafana-connector => iotdb-connector/grafana-connector}/readme.md (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/readme_zh.md (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/TsfileWebDemoApplication.java (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/conf/MyConfiguration.java (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/controller/DatabaseConnectController.java (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/dao/BasicDao.java (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImpl.java (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/interceptor/LoginInterceptor.java (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/service/DatabaseConnectService.java (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/service/impl/DatabaseConnectServiceImpl.java (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/src/main/resources/application.properties (100%)
rename {grafana-connector => iotdb-connector/grafana-connector}/src/test/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImplTest.java (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/.gitignore (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/.prettierrc.js (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/CHANGELOG.md (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/LICENSE (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/Magefile.go (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/README.md (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/backend-compile.bat (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/backend-compile.sh (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/go.mod (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/jest.config.js (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/package.json (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/pkg/main.go (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/pkg/plugin/iotdb_resource_handler.go (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/pkg/plugin/plugin.go (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/pom.xml (99%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/ConfigEditor.tsx (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/QueryEditor.tsx (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/componments/AggregateFun.tsx (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/componments/ControlValue.tsx (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/componments/FillValue.tsx (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/componments/Form.tsx (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/componments/FromValue.tsx (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/componments/GroupBy.tsx (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/componments/SelectValue.tsx (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/componments/TimeSeries.tsx (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/componments/WhereValue.tsx (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/datasource.ts (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/functions.ts (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/img/addIoTDBDataSource.png (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/img/logo.svg (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/img/showData.png (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/module.ts (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/plugin.json (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/src/types.ts (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/tsconfig.json (100%)
rename {grafana-plugin => iotdb-connector/grafana-plugin}/yarn.lock (100%)
rename {hadoop => iotdb-connector/hadoop}/README.md (100%)
rename {hadoop => iotdb-connector/hadoop}/pom.xml (99%)
rename {hadoop => iotdb-connector/hadoop}/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSConfUtil.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSFile.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSInput.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSOutput.java (100%)
copy {hadoop => iotdb-connector/hadoop}/src/main/java/org/apache/iotdb/hadoop/tsfile/IReaderSet.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFHadoopException.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFInputFormat.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFInputSplit.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFOutputFormat.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordReader.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordWriter.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/main/java/org/apache/iotdb/hadoop/tsfile/record/HDFSTSRecord.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFHadoopTest.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFInputSplitTest.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/test/java/org/apache/iotdb/hadoop/tsfile/TsFileTestHelper.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/test/java/org/apache/iotdb/hadoop/tsfile/constant/TestConstant.java (100%)
rename {hadoop => iotdb-connector/hadoop}/src/test/resources/logback.xml (100%)
rename {hive-connector => iotdb-connector/hive-connector}/pom.xml (99%)
rename {hive-connector => iotdb-connector/hive-connector}/src/main/java/org/apache/iotdb/hive/TSFHiveInputFormat.java (100%)
rename {hive-connector => iotdb-connector/hive-connector}/src/main/java/org/apache/iotdb/hive/TSFHiveOutputFormat.java (100%)
rename {hive-connector => iotdb-connector/hive-connector}/src/main/java/org/apache/iotdb/hive/TSFHiveRecordReader.java (100%)
rename {hive-connector => iotdb-connector/hive-connector}/src/main/java/org/apache/iotdb/hive/TSFHiveRecordWriter.java (100%)
rename {hive-connector => iotdb-connector/hive-connector}/src/main/java/org/apache/iotdb/hive/TsFileDeserializer.java (100%)
rename {hive-connector => iotdb-connector/hive-connector}/src/main/java/org/apache/iotdb/hive/TsFileSerDe.java (100%)
rename {hive-connector => iotdb-connector/hive-connector}/src/main/java/org/apache/iotdb/hive/TsFileSerDeException.java (100%)
rename {hive-connector => iotdb-connector/hive-connector}/src/test/java/org/apache/iotdb/hive/TSFHiveInputFormatTest.java (100%)
rename {hive-connector => iotdb-connector/hive-connector}/src/test/java/org/apache/iotdb/hive/TSFHiveRecordReaderTest.java (100%)
rename {hive-connector => iotdb-connector/hive-connector}/src/test/java/org/apache/iotdb/hive/TsFileDeserializerTest.java (100%)
rename {hive-connector => iotdb-connector/hive-connector}/src/test/java/org/apache/iotdb/hive/TsFileSerDeTest.java (100%)
rename {hive-connector => iotdb-connector/hive-connector}/src/test/java/org/apache/iotdb/hive/TsFileTestHelper.java (100%)
rename {hive-connector => iotdb-connector/hive-connector}/src/test/java/org/apache/iotdb/hive/constant/TestConstant.java (100%)
rename {hive-connector => iotdb-connector/hive-connector}/src/test/resources/logback.xml (100%)
copy {example/session => iotdb-connector/spark-iotdb-connector}/pom.xml (56%)
copy {spark-iotdb-connector => iotdb-connector/spark-iotdb-connector/scala_2.11}/pom.xml (51%)
rename {spark-iotdb-connector => iotdb-connector/spark-iotdb-connector/scala_2.12}/pom.xml (53%)
rename {spark-iotdb-connector => iotdb-connector/spark-iotdb-connector}/src/main/scala/org/apache/iotdb/spark/db/Converter.scala (100%)
rename {spark-iotdb-connector => iotdb-connector/spark-iotdb-connector}/src/main/scala/org/apache/iotdb/spark/db/DataFrameTools.scala (100%)
rename {spark-iotdb-connector => iotdb-connector/spark-iotdb-connector}/src/main/scala/org/apache/iotdb/spark/db/DefaultSource.scala (100%)
rename {spark-iotdb-connector => iotdb-connector/spark-iotdb-connector}/src/main/scala/org/apache/iotdb/spark/db/IoTDBOptions.scala (100%)
rename {spark-iotdb-connector => iotdb-connector/spark-iotdb-connector}/src/main/scala/org/apache/iotdb/spark/db/IoTDBRDD.scala (100%)
rename {spark-iotdb-connector => iotdb-connector/spark-iotdb-connector}/src/main/scala/org/apache/iotdb/spark/db/IoTDBRelation.scala (100%)
rename {spark-iotdb-connector => iotdb-connector/spark-iotdb-connector}/src/main/scala/org/apache/iotdb/spark/db/SQLConstant.scala (100%)
rename {spark-iotdb-connector => iotdb-connector/spark-iotdb-connector}/src/main/scala/org/apache/iotdb/spark/db/Transformer.scala (100%)
rename {spark-iotdb-connector => iotdb-connector/spark-iotdb-connector}/src/main/scala/org/apache/iotdb/spark/db/package.scala (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/pom.xml (65%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/io/TsFileOutputFormat.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/io/TsFileRecordWriter.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/Executor.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/QueryProcessor.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/BasicOperator.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/FilterOperator.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/Operator.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/SQLConstant.java (59%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/SingleQuery.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/TSQueryPlan.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/BasicOperatorException.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/DNFOptimizeException.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/LogicalOptimizeException.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/MergeFilterException.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/QueryOperatorException.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/QueryProcessorException.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/RemoveNotException.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/DNFFilterOptimizer.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/IFilterOptimizer.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/MergeSingleFilterOptimizer.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/PhysicalOptimizer.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/RemoveNotOptimizer.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/scala/org/apache/iotdb/spark/tsfile/Converter.scala (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/scala/org/apache/iotdb/spark/tsfile/DefaultSource.scala (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/scala/org/apache/iotdb/spark/tsfile/NarrowConverter.scala (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/scala/org/apache/iotdb/spark/tsfile/NarrowTsFileOutputWriter.scala (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/scala/org/apache/iotdb/spark/tsfile/Transformer.scala (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/scala/org/apache/iotdb/spark/tsfile/TsFileWriterFactory.scala (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/scala/org/apache/iotdb/spark/tsfile/WideConverter.scala (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/scala/org/apache/iotdb/spark/tsfile/WideTsFileOutputWriter.scala (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/main/scala/org/apache/iotdb/spark/tsfile/package.scala (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/test/scala/org/apache/iotdb/spark/constant/TestConstant.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/test/scala/org/apache/iotdb/spark/tool/TsFileExample.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/test/scala/org/apache/iotdb/spark/tool/TsFileWriteTool.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/test/scala/org/apache/iotdb/spark/tsfile/ConverterTest.scala (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/test/scala/org/apache/iotdb/spark/tsfile/HDFSInputTest.java (100%)
rename {spark-tsfile => iotdb-connector/spark-tsfile}/src/test/scala/org/apache/iotdb/spark/tsfile/TSFileSuit.scala (100%)
rename {zeppelin-interpreter => iotdb-connector/zeppelin-interpreter}/IoTDB-Zeppelin-Demo.zpln (100%)
rename {zeppelin-interpreter => iotdb-connector/zeppelin-interpreter}/pom.xml (98%)
rename {zeppelin-interpreter => iotdb-connector/zeppelin-interpreter}/src/main/java/org/apache/zeppelin/iotdb/IoTDBInterpreter.java (100%)
rename {zeppelin-interpreter => iotdb-connector/zeppelin-interpreter}/src/main/resources/interpreter-setting.json (100%)
rename {openapi => iotdb-protocol/openapi}/pom.xml (99%)
rename {openapi => iotdb-protocol/openapi}/src/main/openapi3/iotdb_rest_common.yaml (100%)
rename {openapi => iotdb-protocol/openapi}/src/main/openapi3/iotdb_rest_v1.yaml (100%)
rename {openapi => iotdb-protocol/openapi}/src/main/openapi3/iotdb_rest_v2.yaml (100%)
rename {thrift-commons => iotdb-protocol/thrift-commons}/pom.xml (97%)
rename {thrift-commons => iotdb-protocol/thrift-commons}/src/main/thrift/common.thrift (100%)
rename {thrift-confignode => iotdb-protocol/thrift-confignode}/pom.xml (98%)
rename {thrift-confignode => iotdb-protocol/thrift-confignode}/src/main/thrift/confignode.thrift (99%)
rename {thrift-influxdb => iotdb-protocol/thrift-influxdb}/README.md (100%)
rename {thrift-influxdb => iotdb-protocol/thrift-influxdb}/pom.xml (98%)
rename {thrift-influxdb => iotdb-protocol/thrift-influxdb}/src/main/thrift/influxdb.thrift (100%)
rename {thrift-iot-consensus => iotdb-protocol/thrift-iot-consensus}/pom.xml (98%)
rename {thrift-iot-consensus => iotdb-protocol/thrift-iot-consensus}/src/main/thrift/iotconsensus.thrift (100%)
rename {thrift-mlnode => iotdb-protocol/thrift-mlnode}/pom.xml (98%)
rename {thrift-mlnode => iotdb-protocol/thrift-mlnode}/src/main/thrift/mlnode.thrift (100%)
rename {thrift => iotdb-protocol/thrift}/README.md (100%)
rename {thrift => iotdb-protocol/thrift}/pom.xml (98%)
rename {thrift => iotdb-protocol/thrift}/rpc-changelist.md (100%)
rename {thrift => iotdb-protocol/thrift}/src/main/thrift/client.thrift (98%)
rename {thrift => iotdb-protocol/thrift}/src/main/thrift/datanode.thrift (96%)
rename node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/collector/{DefaultCollector.java => IoTDBCollector.java} (97%)
copy node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{DoNothingConnector.java => IoTDBThriftConnector.java} (58%)
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/DataTypeFilter.java
rename node-commons/src/main/java/org/apache/iotdb/commons/service/metric/{enums => }/PerformanceOverviewMetrics.java (98%)
delete mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/EventCollector.java
delete mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/dml/deletion/DeletionEvent.java
delete mode 100644 rewrite-tsfile-tool/pom.xml
delete mode 100644 rewrite-tsfile-tool/src/assembly/resources/sbin/rewrite-tsfile.bat
delete mode 100644 rewrite-tsfile-tool/src/assembly/resources/sbin/rewrite-tsfile.sh
delete mode 100644 rewrite-tsfile-tool/src/assembly/rewriteTsFile.xml
delete mode 100644 rewrite-tsfile-tool/src/main/java/org/apache/iotdb/RewriteTsFileTool.java
delete mode 100644 schema-engine-rocksdb/README.md
delete mode 100644 schema-engine-rocksdb/pom.xml
delete mode 100644 schema-engine-rocksdb/src/assembly/resources/conf/schema-rocksdb.properties
delete mode 100644 schema-engine-rocksdb/src/assembly/schema-engine-rocksdb.xml
delete mode 100644 schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/CheckKeyResult.java
delete mode 100644 schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaConfLoader.java
delete mode 100644 schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaConstants.java
delete mode 100644 schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaLogger.java
delete mode 100644 schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaReadWriteHandler.java
delete mode 100644 schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaRegion.java
delete mode 100644 schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaUtils.java
delete mode 100644 schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RDatabaseMNode.java
delete mode 100644 schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RDeviceMNode.java
delete mode 100644 schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RInternalMNode.java
delete mode 100644 schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMNode.java
delete mode 100644 schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMNodeType.java
delete mode 100644 schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMNodeValueType.java
delete mode 100644 schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMeasurementMNode.java
delete mode 100644 schema-engine-rocksdb/src/test/org/apache/iotdb/db/metadata/schemaregion/rocksdb/MRocksDBBenchmark.java
delete mode 100644 schema-engine-rocksdb/src/test/org/apache/iotdb/db/metadata/schemaregion/rocksdb/MRocksDBUnitTest.java
delete mode 100644 schema-engine-rocksdb/src/test/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaReadWriteHandlerTest.java
delete mode 100644 schema-engine-rocksdb/src/test/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RocksDBBenchmarkEngine.java
delete mode 100644 schema-engine-rocksdb/src/test/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RocksDBBenchmarkTask.java
delete mode 100644 schema-engine-rocksdb/src/test/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RocksDBTestUtils.java
delete mode 100644 schema-engine-tag/README.md
delete mode 100644 schema-engine-tag/pom.xml
delete mode 100644 schema-engine-tag/src/assembly/resources/conf/schema-tag.properties
delete mode 100644 schema-engine-tag/src/assembly/schema-engine-tag.xml
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/TagSchemaRegion.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/config/TagSchemaConfig.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/config/TagSchemaDescriptor.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/idtable/IDTableWithDeviceIDListImpl.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/ITagInvertedIndex.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/Request/InsertionRequest.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/TagInvertedIndex.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/deletion/MemChunkDeletion.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/deletion/MemChunkGroupDeletion.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/deletion/MemTableDeletion.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/deletion/MemTableGroupDeletion.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/insertion/MemChunkGroupInsertion.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/insertion/MemChunkInsertion.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/insertion/MemTableGroupInsertion.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/insertion/MemTableInsertion.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/memtable/MemChunk.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/memtable/MemTable.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/memtable/MemTableGroup.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/query/MemChunkGroupQuery.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/query/MemChunkQuery.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/query/MemTableGroupQuery.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/query/MemTableQuery.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/response/QueryResponse.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/wal/WALEntry.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/wal/WALManager.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/utils/MeasurementPathUtils.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/utils/PathTagConverterUtils.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/utils/ShowTimeSeriesResultUtils.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/annotation/DeletionProcessor.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/annotation/InsertionProcessor.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/annotation/QueryProcessor.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/applicationcontext/ApplicationContext.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/applicationcontext/ApplicationContextGenerator.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/DeleteRequestContext.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/FlushRequestContext.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/InsertRequestContext.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/QueryRequestContext.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/RequestContext.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/engine/ILSMEngine.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/engine/IRecoverable.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/engine/LSMEngine.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/engine/LSMEngineBuilder.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/BasicLevelProcessor.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/DeleteLevelProcessor.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/FlushLevelProcessor.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/ILevelProcessor.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/InsertLevelProcessor.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/LevelProcessorChain.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/QueryLevelProcessor.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/BasicLSMManager.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/DeletionManager.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/ILSMManager.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/InsertionManager.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/QueryManager.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/RecoverManager.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/WALManager.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IDeletionRequest.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IInsertionRequest.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IQueryRequest.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IRequest.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/RequestType.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/response/IResponse.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/BFSAccessStrategy.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/IAccessStrategy.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/PostOrderAccessStrategy.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/PreOrderAccessStrategy.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/RBFSAccessStrategy.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/IWALReader.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/IWALRecord.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/WALReader.java
delete mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/WALWriter.java
delete mode 100644 schema-engine-tag/src/test/java/org/apache/iotdb/db/metadata/tagSchemaRegion/TagSchemaRegionTest.java
delete mode 100644 schema-engine-tag/src/test/java/org/apache/iotdb/db/metadata/tagSchemaRegion/idtable/IDTableWithDeviceIDListImplTest.java
delete mode 100644 schema-engine-tag/src/test/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/TagTagInvertedIndexTest.java
copy service-rpc/src/main/java/org/apache/iotdb/rpc/NonOpenTransport.java => server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/write/DeleteLogicalViewPlanImpl.java (61%)
copy service-rpc/src/main/java/org/apache/iotdb/rpc/NonOpenTransport.java => server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/write/PreDeleteLogicalViewPlanImpl.java (61%)
rename schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/Request/QueryRequest.java => server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/write/RollbackPreDeleteLogicalViewPlanImpl.java (59%)
rename service-rpc/src/main/java/org/apache/iotdb/rpc/NonOpenTransport.java => server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/view/IDeleteLogicalViewPlan.java (54%)
rename schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/Request/DeletionRequest.java => server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/view/IPreDeleteLogicalViewPlan.java (54%)
rename pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/retry/RetryStrategy.java => server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/view/IRollbackPreDeleteLogicalViewPlan.java (55%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/query/reader/SchemaReaderLimitOffsetWrapper.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/LogicalViewSchemaSource.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/metric/QueryRelatedResourceMetricSet.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/view/DeleteLogicalViewTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/visitor/CompleteMeasurementSchemaVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/visitor/RemoveWildcardAndViewInExpressionVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/visitor/RemoveWildcardAndViewInFilterVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/visitor/ReplaceLogicalViewVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/LogicalViewSchemaScanNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/view/ConstructLogicalViewBlackListNode.java
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/{ => view}/CreateLogicalViewNode.java (99%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/view/DeleteLogicalViewNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/view/RollbackLogicalViewBlackListNode.java
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{ => view}/CreateLogicalViewStatement.java (90%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/view/DeleteLogicalViewStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/view/ShowLogicalViewStatement.java
rename hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/IReaderSet.java => server/src/main/java/org/apache/iotdb/db/pipe/agent/receiver/IoTDBThriftReceiver.java (56%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/agent/receiver/PipeReceiverAgent.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/MetaSyncScheduler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeLauncher.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/IoTDBThriftConnectorClient.java
rename udf-api/src/main/java/org/apache/iotdb/udf/api/exception/UDFException.java => server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/IoTDBThriftConnectorVersion.java (74%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/v1/IoTDBThriftConnectorV1.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/v1/IoTDBThriftReceiverV1.java
rename schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/memtable/MemChunkGroup.java => server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/v1/PipeRequestType.java (53%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/v1/reponse/PipeTransferFilePieceResp.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/v1/request/PipeTransferFilePieceReq.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/v1/request/PipeTransferFileSealReq.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/v1/request/PipeTransferHandshakeReq.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/v1/request/PipeTransferInsertNodeReq.java
rename server/src/main/java/org/apache/iotdb/db/pipe/core/connector/{ => manager}/PipeConnectorSubtaskLifeCycle.java (98%)
rename server/src/main/java/org/apache/iotdb/db/pipe/core/connector/{ => manager}/PipeConnectorSubtaskManager.java (86%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/execution/scheduler/PipeSubtaskScheduler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/execution/scheduler/PipeTaskScheduler.java
rename server/src/main/java/org/apache/iotdb/db/pipe/resource/{ => file}/PipeFileResourceManager.java (99%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/resource/wal/PipeWALResource.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/resource/wal/PipeWALResourceManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/CacheMetrics.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/recorder/CacheMetricsRecorder.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/recorder/CompactionMetricsManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/recorder/WritingMetricsManager.java
rename server/src/main/java/org/apache/iotdb/db/wal/utils/{WALPipeHandler.java => WALEntryHandler.java} (91%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/pipe/core/connector/PipeThriftRequestTest.java
rename server/src/test/java/org/apache/iotdb/db/wal/node/{WALPipeHandlerTest.java => WALEntryHandlerTest.java} (94%)
delete mode 100644 spark-iotdb-connector/src/test/resources/iotdb-datanode.properties
delete mode 100644 spark-iotdb-connector/src/test/scala/org/apache/iotdb/spark/db/EnvironmentUtils.java
delete mode 100644 spark-iotdb-connector/src/test/scala/org/apache/iotdb/spark/db/IoTDBTest.scala
delete mode 100644 spark-iotdb-connector/src/test/scala/org/apache/iotdb/spark/db/IoTDBWriteTest.scala
delete mode 100644 spark-iotdb-connector/src/test/scala/org/apache/iotdb/spark/db/unit/DataFrameToolsTest.scala