This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch jira6061
in repository https://gitbox.apache.org/repos/asf/iotdb.git
omit 9a62a640dd0 fix code smell
omit d0ed322fa00 fix
add 3def1f80976 [IOTDB-6100] Pipe: Fix running in hybrid mode will cause
wal cannot be deleted & some pipe data lost due to wrong ProducerType of
Disruptor (#10790)
add ebc95a772b6 [IOTDB-6094] Load: Fix error in if/else judgment of
tsfileResource exists or not & Reduce warn log when timeseries exist (#10762)
add 038b7f45e94 build: Changed the build to build a statically linked
thrift executable for Linux (Also fixed the problem also enabling uinx profiles
on Macs) (#10788)
add b3a4bdf813f [IOTDB-6101] Pipe: Support tsfile cascade transport
(#10795)
add 4136802f214 Stop generating FilterExpression if we don't specify the
time filter in last query session api
add 2676f2c2b33 Removed front-end request parameters output in Grafana
backend logs (#10784)
add 3f5816aafcd Fixed iotdb common.sh getting null iotdb port (#10781)
add c16b0944297 Optimize leader change event (#10797)
add 862728c2f49 fix: Fixed the name of the profile used to activate the
integration-tests on jenkins. (#10806)
add 0fd475041a6 Multi-Cluster IT framework (#10518)
add e609295edc0 Perfect some error messages of Memorypool
add ad061f96a15 Fix compaction force decoding check (#10801)
add 2cde87171fa Enhance cn_confignode_target_list comments (#10812)
add 644e4a989f5 Totally remove influxdb-protocol related files (#10814)
add 685bfa983c2 Fix compaction log keyword bug (#10785)
add 9fbc0318f47 [IOTDB-6104] Remove tmp directory for udf query completely
while query end
add 63caecc8c36 Fix error log when start confignode and datanode (#10820)
add 1f321df57b7 [To Master] Fixed the prompt after CSV file import (#10824)
add 2e6d9527c04 [IOTDB-6105] Load: NPE when analyzing tsfile (#10821)
add ff3239bf829 [IOTDB-6106] Fixed the timeout parameter not working in
thrift asyncClient (#10822)
add 29d414b2937 session module add UT (#10815)
add 031495a6301 Pipe: refactor connector packages and rename v1/v2 to
sync/async (#10840)
add da7e66db404 fix parameter schemaRegionPerNode load error (#10841)
add 80427a00c5f Enhance the event notification mechanism of
StatisticsService (#10829)
add 59a0dcf11a1 Refactoring DeleteOutdatedFileTask in WalNode (#10765)
add ccd73310fac fix inaccurate statistics for monitoring the number of
unseq Tsfile on cross compaction (#10651)
add 47a14313621 add memory estimator on inner space compaction (#10688)
add 7dd7cf78956 Fix a concurrent bug when recover last flush time and
compact (#10839)
add 3dc1490cfc8 [IOTDB-6108] Fix AlignedTVList memory calculation is
imprecise (#10827)
add 11af323b79d Pipe: Remove parameters from iotdb-common.properties that
users will not modify (#10851)
add 459a394a86b [IOTDB-6113] Load: Fix setDatabase does not print logs and
set failure except DATABASE_ALREADY_EXISTS (#10854)
add 98128a4f02e Update the description of schemaRegionPerNode in
common.properties (#10857)
add 0133c139538 [IOTDB-6111] Fix Region creation bugs (#10844)
add f7ca23cbd00 Fix SchemaFileSketchTool is not found
add cdcb4a691d3 [IOTDB-6112] Fix Limit & Offset push down doesn't take
effect while there exist time filter
add 8e0256658e0 Remove useless dependency bugsnag (#10861)
add b0bd6065a42 Replace dependency commons-lang to commons-lang3
add 621b66a871e Remove useless dependency h2-mvstore
add 44d6bec0f39 Pipe IT: Changed IoTDBPipeDemoIT timeout to 10 mins to
allow pipe-internal retries when unstable cases occuring (#10867)
add 16a9f3fe760 Bump
com.googlecode.maven-download-plugin:download-maven-plugin (#10747)
add 89645c6889f Delete useless airline, concurrent-200 and jaxb-runtime
dependencies (#10866)
add 3e9ddc77c86 Pipe IT: fix the usage of Awaitility.awit (#10869)
add b445540475a [IOTDB-6116] Disassociate the IoTConsensus retry logic
from the forkjoinPool (#10872)
add 679c495b043 [RatisConsensus] Unify read timeout to Thrift connection
timeout (#10876)
add 9acb3594a18 Fix Region migrate bug (#10862)
add 80f9a80e50f [IOTDB-6118] Pipe: Support transfer data through air gap
(IoTDBAirGapConnector) (#10853)
add 0a90c45486d Pipe IT: Stablelized pipe IT by prohibiting exceptions
from assertEqual function (#10881)
add 0b28f31379d fix dataMigrationExample error (#10886)
add 6bef0b0b232 fix: Hopefully fixed the build of the cpp-example on
windows systems (#10891)
add 709e7ef8694 Upgrade guava to avoid vulnerability issue (#10892)
add 052ff28cf89 Override existing jar instead of deleting it when
registering UDF
add 97e083efcec [IOTDB-6115] Fix Limit & Offset push down doesn't take
effect while there exist null value
add a45248d4959 Rename iotdb-thrift module to iotdb-thrift-datanode
(#10884)
add 29e038d6a96 Fix memory leak when deleting database in PB_Tree mode
(#10885)
add 38b36006b2a [IOTDB-6117] Pipe: Optimize RPC requests from CN to DN. CN
send exactly one pipeMeta to each DN upon create/start/stop/drop pipe (#10875)
add 5f6db2e308a Fix some ITs of UDFManagement
add 2c2f40bdb45 Implement intersect with prefix pattern for PartialPath
and PathPatternTree
add af250e0b9ca [IOTDB-6122] Pipe: Progress Index markers an incorrect
value when load a tsfile with tsfileResource (#10908)
add 30a006118d0 reduce wal log output level (#10873)
add 144e5428fbb [IOTDB-6114] Pipe: Support multi-cluster data sync (#10868)
add 8d79a5e4e7c Add hot load compaction configs (#10758)
add 0cd30225af5 Move SchemaConstant to common package
add 40617cd3940 Revert removed dependencies to avoid write performance
declining (#10921)
add d614139f71f Optimize client cpp package (#10923)
add 51e6d17b821 [IOTDB-6120] Push down limit/offset in query with group by
time
add 23340404c99 [IOTDB-6080] Pipe: Introduce batch mode for tablet
transferring (#10912)
add 1dce787c39e [Metric] Fix flush point statistics (#10915)
add 6357533a25c [IOTDB-6125] Fix DataPartition allocation bug when insert
big batch data (#10924)
add e891a5d1f31 [IOTDB-6121] Consensus layer interface and exception
handling refactoring (#10896)
add fe7b3a4dff2 [IOTDB-6125] Fix DataPartition allocation bug when insert
big batch data (#10938)
add 332521a3241 [IOTDB-6083] Pipe: Fix subscrption running with the
pattern option causing OOM & make PipeRawTabletInsertionEvent able to report
progress to avoid losing data (#10865)
add 6f7751bc1c1 [IOTDB-6082] Improve disk space metrics (#10925)
add 55bea920618 Pipe: Swapped the start order of realtimeExtractor and
historicalExtractor to avoid losing data (#10927)
add 4341c152a77 [IOTDB-6103] Adding count_time aggregation feature (#10756)
add e9fe0b1082d Feature/simplified tsfile examples (#10906)
add 97a5ab693b4 Feature/test externalized iotdb tools thrift (#10893)
add 810ec62f824 [IOTDB-6124] Add scope filter parameter for tree visitor
framework
add 05432f6d061 Use new released iotdb-tools-thrift to build thrift files
(#10948)
add 489be30b4db Feature/streamlined grafana plugin profile (#10907)
add c4b72fc76ec [IOTDB-6126] Pipe: Added PipeHeartbeatEvent to trigger
delay reporting, batch transferring and async retrying (#10940)
add 48bb45b056f Remove some useless configs (#10949)
add 40f2ff4d2aa Bump word-wrap from 1.2.3 to 1.2.5 in
/iotdb-connector/grafana-plugin (#10955)
add b7bafc1882e Bump semver from 5.7.1 to 5.7.2 in
/iotdb-connector/grafana-plugin (#10547)
add 0a5d4ec993f [IOTDB-6123] Pipe: reduce the de/ser to slove the slow log
transfer problem (#10913)
add df262ee6c0d Fix client-cpp-example build error (#10956)
add bd588e27682 [RatisConsensus] Fix flaky unit tests after linearizable
read (#10942)
add 1ae952ce14c [IOTDB-6127] Pipe: buffered events in processor stage can
not be consumed by connector (#10962)
add 3073fe63bc3 [IOTDB-6029] flink-sql-iotdb-connector (#10958)
add daebc419e0e Pipe: Increase the injection frequency of HeartBeatEvent
to reduce the delay in log transferring (#10970)
add 8424f821475 Accelerate the deletion execution (#10967)
add f1a4012424f Pipe: drop HeartbeatEvent when pipe is stopped to avoid
OOM (#10977)
add f80c2894f42 Fix point priority reader array index out of bound
exception (#10919)
add c307a455819 Reimplement compaction memory estimator (#10951)
add 7a005340bb1 add lazy page reader for aligned page reader to avoid huge
memory cost when reading rows of aligned timeseries (#10966)
add 7356c8a435c upgrade ratis snapshot version to 2.5.2-8efe8a1-SNAPSHOT
(#10971)
add 35ba1df5892 fix
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (9a62a640dd0)
\
N -- N -- N refs/heads/jira6061 (35ba1df5892)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.gitattributes | 17 +
.github/workflows/client-cpp.yml | 16 +-
.github/workflows/pipe-it-2cluster.yml | 66 ++
CONTRIBUTING.md | 2 +-
Jenkinsfile | 2 +-
LICENSE-binary | 4 +-
README.md | 9 +-
distribution/pom.xml | 94 ++-
distribution/src/assembly/client-cpp.xml | 2 +-
example/client-cpp-example/pom.xml | 4 +-
example/client-cpp-example/src/CMakeLists.txt | 10 +-
.../src/main/java/org/apache/iotdb/SSLClient.java | 2 +-
.../org/apache/iotdb/DataMigrationExample.java | 3 +-
.../tsfile/TsFileWriteAlignedWithTSRecord.java | 8 +-
.../iotdb/tsfile/TsFileWriteAlignedWithTablet.java | 6 +-
.../iotdb/tsfile/TsFileWriteWithTSRecord.java | 8 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 6 +-
integration-test/pom.xml | 113 +++
.../java/org/apache/iotdb/it/env/EnvFactory.java | 11 +-
.../main/java/org/apache/iotdb/it/env/EnvType.java | 4 +-
.../env/{EnvFactory.java => MultiEnvFactory.java} | 51 +-
.../iotdb/it/env/cluster/ClusterConstant.java | 221 +++++
.../iotdb/it/env/cluster/ConfigNodeWrapper.java | 175 ----
.../iotdb/it/env/cluster/DataNodeWrapper.java | 217 -----
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 140 +++-
.../it/env/cluster/{ => config}/MppBaseConfig.java | 4 +-
.../env/cluster/{ => config}/MppClusterConfig.java | 2 +-
.../env/cluster/{ => config}/MppCommonConfig.java | 30 +-
.../cluster/{ => config}/MppConfigNodeConfig.java | 2 +-
.../cluster/{ => config}/MppDataNodeConfig.java | 2 +-
.../it/env/cluster/{ => config}/MppJVMConfig.java | 2 +-
.../{ => config}/MppSharedCommonConfig.java | 9 +-
.../it/env/cluster/{ => env}/AbstractEnv.java | 93 ++-
.../it/env/cluster/{ => env}/Cluster1Env.java | 3 +-
.../iotdb/it/env/cluster/env/MultiClusterEnv.java | 24 +-
.../iotdb/it/env/cluster/{ => env}/SimpleEnv.java | 2 +-
.../cluster/{ => node}/AbstractNodeWrapper.java | 283 +++++--
.../it/env/cluster/node/ConfigNodeWrapper.java | 201 +++++
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 256 ++++++
.../remote/{ => config}/RemoteClusterConfig.java | 2 +-
.../remote/{ => config}/RemoteCommonConfig.java | 6 +-
.../{ => config}/RemoteConfigNodeConfig.java | 2 +-
.../remote/{ => config}/RemoteDataNodeConfig.java | 2 +-
.../env/remote/{ => config}/RemoteJVMConfig.java | 2 +-
.../it/env/remote/{ => env}/RemoteServerEnv.java | 8 +-
.../apache/iotdb/it/framework/IoTDBTestRunner.java | 10 +-
.../iotdb/itbase/category/MultiClusterIT1.java | 9 +-
.../iotdb/itbase/category/MultiClusterIT2.java | 9 +-
.../iotdb/itbase/category/MultiClusterIT3.java | 9 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 4 +-
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 4 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +
.../apache/iotdb/cli/it/StartClientScriptIT.java | 1 +
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 8 +-
.../it/cluster/IoTDBClusterNodeGetterIT.java | 4 +-
.../it/cluster/IoTDBClusterRestartIT.java | 10 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 18 +-
.../IoTDBAutoRegionGroupExtensionIT2.java | 160 ++++
.../it/partition/IoTDBPartitionCreationIT.java | 130 +--
.../it/partition/IoTDBPartitionDurableIT.java | 8 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 4 +-
.../aggregation/IoTDBCountTimeAlignedDeviceIT.java | 304 +++++++
.../iotdb/db/it/aggregation/IoTDBCountTimeIT.java | 339 ++++++++
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 50 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 84 +-
.../apache/iotdb/pipe/it/IoTDBPipeDataSyncIT.java | 132 +++
.../iotdb/pipe/it/IoTDBPipeSingleEnvDemoIT.java | 77 ++
.../iotdb/session/it/IoTDBSessionComplexIT.java | 2 +-
.../org/apache/iotdb/pipe/api/PipeConnector.java | 2 +-
.../event/dml/insertion/TabletInsertionEvent.java | 2 +-
.../event/dml/insertion/TsFileInsertionEvent.java | 4 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 2 +-
iotdb-client/client-cpp/pom.xml | 10 +-
iotdb-client/client-py/pom.xml | 2 +-
iotdb-client/service-rpc/pom.xml | 5 -
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 25 -
.../iotdb/rpc/StatementExecutionException.java | 6 -
iotdb-client/session/pom.xml | 5 +
.../apache/iotdb/session/pool/SessionPoolTest.java | 90 ++-
.../flink-sql-iotdb-connector}/pom.xml | 66 +-
.../flink/sql/client/IoTDBWebSocketClient.java | 75 ++
.../org/apache/iotdb/flink/sql/common/Options.java | 55 ++
.../org/apache/iotdb/flink/sql/common/Utils.java | 144 ++++
.../sql/exception/IllegalIoTDBPathException.java | 12 +-
.../sql/exception/IllegalOptionException.java | 12 +-
.../sql/exception/IllegalSchemaException.java | 12 +-
.../sql/exception/IllegalUrlPathException.java | 12 +-
.../exception/UnsupportedDataTypeException.java | 12 +-
.../sql/factory/IoTDBDynamicTableFactory.java | 189 +++++
.../sql/function/IoTDBBoundedScanFunction.java | 163 ++++
.../flink/sql/function/IoTDBCDCSourceFunction.java | 256 ++++++
.../flink/sql/function/IoTDBLookupFunction.java | 151 ++++
.../flink/sql/function/IoTDBSinkFunction.java | 125 +++
.../flink/sql/provider/IoTDBDynamicTableSink.java | 64 ++
.../sql/provider/IoTDBDynamicTableSource.java | 76 ++
.../iotdb/flink/sql/wrapper/SchemaWrapper.java | 33 +-
.../iotdb/flink/sql/wrapper/TabletWrapper.java | 29 +-
.../org.apache.flink.table.factories.Factory | 5 +-
iotdb-connector/grafana-plugin/backend-compile.sh | 4 +-
iotdb-connector/grafana-plugin/go.mod | 4 +-
.../grafana-plugin/pkg/plugin/plugin.go | 2 -
iotdb-connector/grafana-plugin/pom.xml | 177 ++--
iotdb-connector/grafana-plugin/yarn.lock | 24 +-
iotdb-connector/pom.xml | 10 +-
.../resources/conf/iotdb-confignode.properties | 5 +-
.../confignode/client/DataNodeRequestType.java | 3 +-
.../client/async/AsyncDataNodeClientPool.java | 9 +-
.../client/async/handlers/AsyncClientHandler.java | 3 +-
.../confignode/conf/ConfigNodeDescriptor.java | 6 +-
.../confignode/manager/ClusterQuotaManager.java | 52 +-
.../iotdb/confignode/manager/ConfigManager.java | 18 +-
.../iotdb/confignode/manager/ModelManager.java | 75 +-
.../confignode/manager/PermissionManager.java | 39 +-
.../iotdb/confignode/manager/TriggerManager.java | 56 +-
.../iotdb/confignode/manager/UDFManager.java | 28 +-
.../manager/consensus/ConsensusManager.java | 95 ++-
.../iotdb/confignode/manager/cq/CQManager.java | 42 +-
.../confignode/manager/cq/CQScheduleTask.java | 26 +-
.../iotdb/confignode/manager/load/LoadManager.java | 8 +-
.../manager/load/balancer/PartitionBalancer.java | 21 +-
.../manager/load/balancer/RegionBalancer.java | 17 +-
.../manager/load/balancer/RouteBalancer.java | 4 +-
.../partition/DataPartitionPolicyTable.java | 27 +
.../region/GreedyRegionGroupAllocator.java | 41 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 4 +-
.../manager/load/cache/region/RegionCache.java | 5 +-
.../load/cache/region/RegionHeartbeatSample.java | 5 +
.../manager/load/service/StatisticsService.java | 18 +-
.../iotdb/confignode/manager/node/NodeManager.java | 73 +-
.../manager/partition/PartitionManager.java | 227 ++++--
.../manager/pipe/plugin/PipePluginCoordinator.java | 23 +-
.../pipe/runtime/PipeLeaderChangeHandler.java | 4 +-
.../manager/pipe/task/PipeTaskCoordinator.java | 14 +-
.../manager/schema/ClusterSchemaManager.java | 284 +++++--
.../partition/DatabasePartitionTable.java | 4 +-
.../persistence/partition/RegionGroup.java | 11 +
.../confignode/persistence/pipe/PipeTaskInfo.java | 9 +
.../persistence/schema/ClusterSchemaInfo.java | 6 +-
.../confignode/persistence/schema/ConfigMTree.java | 10 +-
.../schema/mnode/info/ConfigMNodeInfo.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 60 +-
.../procedure/env/DataNodeRemoveHandler.java | 14 +-
.../procedure/impl/cq/CreateCQProcedure.java | 113 ++-
.../procedure/impl/model/CreateModelProcedure.java | 18 +-
.../procedure/impl/model/DropModelProcedure.java | 7 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 31 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 27 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 13 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 19 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 23 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 55 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 23 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 45 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 45 +-
.../impl/schema/DeleteDatabaseProcedure.java | 3 +-
.../impl/schema/SetTemplateProcedure.java | 77 +-
.../statemachine/CreateRegionGroupsProcedure.java | 7 +-
.../impl/trigger/CreateTriggerProcedure.java | 22 +-
.../procedure/store/ConfigProcedureStore.java | 13 +-
.../iotdb/confignode/service/ConfigNode.java | 8 +-
.../service/thrift/ConfigNodeRPCService.java | 5 -
.../thrift/ConfigNodeRPCServiceProcessor.java | 12 +-
iotdb-core/consensus/pom.xml | 4 +-
.../org/apache/iotdb/consensus/IConsensus.java | 166 ++--
.../iotdb/consensus/common/ConsensusGroup.java | 1 -
.../org/apache/iotdb/consensus/common/Peer.java | 1 -
.../org/apache/iotdb/consensus/common/Utils.java | 13 +-
.../common/request/ByteBufferConsensusRequest.java | 12 +-
.../common/response/ConsensusGenericResponse.java | 64 --
.../common/response/ConsensusReadResponse.java | 69 --
.../common/response/ConsensusWriteResponse.java | 82 --
.../iotdb/consensus/config/ConsensusConfig.java | 18 +-
.../consensus/exception/NodeReadOnlyException.java | 31 -
.../PeerNotInConsensusGroupException.java | 6 +-
.../exception/RatisUnderRecoveryException.java | 3 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 237 +++---
.../consensus/iot/IoTConsensusServerImpl.java | 8 +
.../iot/client/AsyncIoTConsensusServiceClient.java | 1 +
.../consensus/iot/client/DispatchLogHandler.java | 52 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 4 +
.../iot/service/IoTConsensusRPCService.java | 8 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 261 +++---
.../iotdb/consensus/ratis/SnapshotStorage.java | 2 +-
.../iotdb/consensus/simple/SimpleConsensus.java | 142 ++--
...verImpl.java => SimpleConsensusServerImpl.java} | 4 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 147 ++--
.../apache/iotdb/consensus/iot/StabilityTest.java | 106 ++-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 187 ++---
.../iotdb/consensus/ratis/RecoverReadTest.java | 58 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 102 ++-
.../iotdb/consensus/simple/RecoveryTest.java | 22 +-
.../consensus/simple/SimpleConsensusTest.java | 228 +++---
iotdb-core/datanode/pom.xml | 17 +-
.../resources/conf/iotdb-datanode.properties | 2 +-
.../resources/tools/schema/print-pb-tree-file.sh | 2 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 3 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 1 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 51 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 108 ++-
.../db/consensus/DataRegionConsensusImpl.java | 291 ++++---
.../db/consensus/SchemaRegionConsensusImpl.java | 208 ++---
.../dataregion/DataExecutionVisitor.java | 23 +
.../metadata/MNodeTypeMismatchException.java | 2 +-
.../db/pipe/agent/receiver/PipeReceiverAgent.java | 69 +-
.../pipe/agent/runtime/PipeCronEventInjector.java | 70 ++
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 19 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 134 +++-
.../config/constant/PipeConnectorConstant.java | 18 +
.../config/constant/PipeExtractorConstant.java | 4 +
.../payload/airgap/AirGapOneByteResponse.java} | 9 +-
.../airgap/AirGapPseudoTPipeTransferRequest.java} | 9 +-
.../{v1 => payload/evolvable}/PipeRequestType.java | 9 +-
...oTDBThriftAsyncPipeTransferBatchReqBuilder.java | 89 +++
...IoTDBThriftSyncPipeTransferBatchReqBuilder.java | 80 ++
.../builder/PipeTransferBatchReqBuilder.java | 97 +++
.../reponse/PipeTransferFilePieceResp.java | 2 +-
.../request/PipeTransferFilePieceReq.java | 33 +-
.../request/PipeTransferFileSealReq.java | 30 +-
.../request/PipeTransferHandshakeReq.java | 26 +-
.../request/PipeTransferTabletBatchReq.java | 205 +++++
.../request/PipeTransferTabletBinaryReq.java} | 81 +-
.../request/PipeTransferTabletInsertNodeReq.java} | 46 +-
.../request/PipeTransferTabletRawReq.java} | 152 ++--
.../legacy}/DeletionPipeData.java | 6 +-
.../pipedata => payload/legacy}/PipeData.java | 4 +-
.../legacy}/TsFilePipeData.java | 6 +-
.../IoTDBConnector.java} | 17 +-
.../IoTDBConnectorRequestVersion.java} | 7 +-
.../protocol/airgap/IoTDBAirGapConnector.java | 387 +++++++++
.../legacy/IoTDBLegacyPipeConnector.java} | 25 +-
.../thrift/async/IoTDBThriftAsyncConnector.java} | 231 +++---
.../PipeTransferTabletBatchEventHandler.java} | 65 +-
.../PipeTransferTabletInsertNodeEventHandler.java} | 10 +-
.../PipeTransferTabletInsertionEventHandler.java | 13 +-
.../PipeTransferTabletRawEventHandler.java} | 10 +-
.../PipeTransferTsFileInsertionEventHandler.java | 14 +-
.../thrift/sync/IoTDBThriftSyncConnector.java} | 171 ++--
.../sync/IoTDBThriftSyncConnectorClient.java} | 6 +-
.../websocket/WebSocketConnectorServer.java | 216 +++++
.../protocol/websocket/WebsocketConnector.java | 139 ++++
.../apache/iotdb/db/pipe/event/EnrichedEvent.java | 16 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 141 ++++
.../db/pipe/event/common/row/PipeRowCollector.java | 18 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 47 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 102 ++-
.../tablet/TabletInsertionDataContainer.java | 29 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 21 +-
.../tsfile/TsFileInsertionDataContainer.java | 34 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 8 +-
.../event/realtime/PipeRealtimeEventFactory.java | 17 +-
.../pipe/extractor/IoTDBDataRegionExtractor.java | 7 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 23 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 16 +
.../PipeRealtimeDataRegionHybridExtractor.java | 133 ++-
.../PipeRealtimeDataRegionLogExtractor.java | 51 +-
.../PipeRealtimeDataRegionTsFileExtractor.java | 51 +-
.../realtime/assigner/DisruptorQueue.java | 85 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 28 +-
.../listener/PipeInsertionDataNodeListener.java | 26 +-
.../matcher/CachedSchemaPatternMatcher.java | 6 +
.../db/pipe/processor/PipeDoNothingProcessor.java | 112 ---
.../pipe/receiver/airgap/IoTDBAirGapReceiver.java | 200 +++++
.../receiver/airgap/IoTDBAirGapReceiverAgent.java | 97 +++
.../legacy/IoTDBLegacyPipeReceiverAgent.java} | 26 +-
.../legacy/loader/DeletionLoader.java | 2 +-
.../legacy/loader/ILoader.java | 2 +-
.../legacy/loader/TsFileLoader.java | 4 +-
.../thrift}/IoTDBThriftReceiver.java | 6 +-
.../thrift/IoTDBThriftReceiverAgent.java} | 37 +-
.../thrift}/IoTDBThriftReceiverV1.java | 167 ++--
.../db/pipe/resource/wal/PipeWALResource.java | 4 +
.../pipe/resource/wal/PipeWALResourceManager.java | 12 +-
.../pipe/task/connection/BlockingPendingQueue.java | 2 +-
.../pipe/task/connection/PipeEventCollector.java | 54 +-
.../connection/UnboundedBlockingPendingQueue.java | 12 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 4 +-
.../subtask/connector/PipeConnectorSubtask.java | 25 +-
.../connector/PipeConnectorSubtaskManager.java | 27 +-
.../subtask/processor/PipeProcessorSubtask.java | 17 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 2 +-
.../iotdb/db/protocol/session/SessionManager.java | 8 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 18 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 161 ++--
.../thrift/impl/DataNodeRegionManager.java | 39 +-
.../common/schematree/ClusterSchemaTree.java | 2 +-
.../visitor/SchemaTreeDeviceVisitor.java | 6 +
.../visitor/SchemaTreeMeasurementVisitor.java | 7 +
.../schematree/visitor/SchemaTreeVisitor.java | 36 +
.../visitor/SchemaTreeVisitorFactory.java | 23 +
.../execution/aggregation/AccumulatorFactory.java | 3 +-
.../execution/aggregation/Aggregator.java | 13 +-
.../execution/aggregation/CountAccumulator.java | 1 -
...tAccumulator.java => CountTimeAccumulator.java} | 21 +-
.../SlidingWindowAggregatorFactory.java | 1 +
.../execution/executor/RegionReadExecutor.java | 18 +-
.../execution/executor/RegionWriteExecutor.java | 111 ++-
.../execution/load/LoadTsFileManager.java | 12 +-
.../queryengine/execution/memory/MemoryPool.java | 13 +-
.../operator/process/AbstractIntoOperator.java | 4 -
.../operator/process/DeviceViewIntoOperator.java | 8 +-
.../execution/operator/process/IntoOperator.java | 9 +-
.../operator/schema/source/DeviceSchemaSource.java | 2 +-
.../schema/source/LogicalViewSchemaSource.java | 2 +-
.../schema/source/TimeSeriesSchemaSource.java | 2 +-
.../AbstractSeriesAggregationScanOperator.java | 10 +-
.../operator/source/AlignedSeriesScanOperator.java | 9 +-
.../operator/source/AlignedSeriesScanUtil.java | 85 +-
.../db/queryengine/plan/analyze/Analysis.java | 26 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 890 +++++++--------------
.../plan/analyze/ExpressionAnalyzer.java | 2 +
.../plan/analyze/ExpressionTypeAnalyzer.java | 4 +-
.../queryengine/plan/analyze/ExpressionUtils.java | 3 +-
.../plan/analyze/LoadTsfileAnalyzer.java | 543 +++++++++++++
.../queryengine/plan/execution/QueryExecution.java | 4 +-
.../plan/execution/config/ConfigTaskVisitor.java | 10 +-
.../config/executor/ClusterConfigTaskExecutor.java | 38 +-
.../config/executor/IConfigTaskExecutor.java | 10 +-
.../execution/config/sys/pipe/CreatePipeTask.java | 2 +-
.../execution/config/sys/pipe/DropPipeTask.java | 2 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 2 +-
.../execution/config/sys/pipe/StartPipeTask.java | 2 +-
.../execution/config/sys/pipe/StopPipeTask.java | 2 +-
.../plan/expression/ExpressionFactory.java | 7 +
.../plan/expression/binary/BinaryExpression.java | 4 +
.../plan/expression/leaf/TimestampOperand.java | 5 +-
.../plan/expression/multi/FunctionExpression.java | 18 +
...java => CountTimeAggregationAmountVisitor.java} | 33 +-
.../visitor/ExpressionNormalizeVisitor.java | 3 +-
.../visitor/GetMeasurementExpressionVisitor.java | 3 +-
.../visitor/LowercaseNormalizeVisitor.java | 3 +-
.../cartesian/BindSchemaForExpressionVisitor.java | 19 +
.../cartesian/BindSchemaForPredicateVisitor.java | 18 +
...catDeviceAndBindSchemaForExpressionVisitor.java | 23 +-
.../plan/optimization/LimitOffsetPushDown.java | 117 +++
.../db/queryengine/plan/parser/ASTVisitor.java | 38 +-
.../plan/parser/StatementGenerator.java | 21 +-
.../plan/planner/LogicalPlanBuilder.java | 72 +-
.../plan/planner/LogicalPlanVisitor.java | 98 ++-
.../plan/planner/OperatorTreeGenerator.java | 74 +-
.../plan/planner/distribution/SourceRewriter.java | 8 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 1 +
.../plan/planner/plan/node/PlanNodeType.java | 7 +-
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../plan/node/load/LoadSingleTsFileNode.java | 11 +-
.../planner/plan/node/load/LoadTsFileNode.java | 4 -
.../plan/node/source/AlignedSeriesScanNode.java | 37 +-
.../planner/plan/node/write/DeleteDataNode.java | 12 +-
.../plan/node/write/InsertMultiTabletsNode.java | 6 +
.../plan/planner/plan/node/write/InsertNode.java | 12 +-
.../planner/plan/node/write/InsertRowsNode.java | 15 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 6 +
.../plan/node/write/PipeEnrichedInsertNode.java | 276 +++++++
.../scheduler/load/LoadTsFileDispatcherImpl.java | 11 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 11 +-
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 58 +-
.../plan/statement/component/OrderByComponent.java | 8 +-
.../plan/statement/crud/InsertBaseStatement.java | 3 +-
.../plan/statement/crud/LoadTsFileStatement.java | 40 +-
.../crud/PipeEnrichedInsertBaseStatement.java | 224 ++++++
.../crud/PipeEnrichedLoadTsFileStatement.java | 132 +++
.../plan/statement/crud/QueryStatement.java | 109 ++-
.../metadata/DatabaseSchemaStatement.java | 9 +
.../pipe/CreatePipeStatement.java | 2 +-
.../{sys => metadata}/pipe/DropPipeStatement.java | 2 +-
.../{sys => metadata}/pipe/ShowPipesStatement.java | 2 +-
.../{sys => metadata}/pipe/StartPipeStatement.java | 2 +-
.../{sys => metadata}/pipe/StopPipeStatement.java | 2 +-
.../schemaregion/SchemaRegionLoader.java | 2 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 2 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 2 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 2 +-
.../mtree/impl/mem/mnode/info/DeviceInfo.java | 2 +-
.../mnode/iterator/AbstractTraverserIterator.java | 2 +-
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 16 +-
.../mtree/impl/pbtree/CachedMTreeStore.java | 1 +
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 2 +-
.../mtree/impl/pbtree/cache/CacheManager.java | 1 +
.../impl/pbtree/cache/CacheMemoryManager.java | 4 +
.../mtree/impl/pbtree/schemafile/RecordUtils.java | 2 +-
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 2 +-
.../mtree/loader/MNodeFactoryLoader.java | 2 +-
.../schemaregion/mtree/traverser/Traverser.java | 48 +-
.../schemaengine/schemaregion/tag/TagManager.java | 2 +-
.../schemaregion/utils/ResourceByPathUtils.java | 30 +-
.../schemaengine/schemaregion/view/ViewPaths.java | 2 +-
.../template/ClusterTemplateManager.java | 3 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 22 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 25 +-
.../iotdb/db/service/RegionMigrateService.java | 101 +--
.../db/service/TemporaryQueryDataFileService.java | 2 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 3 +-
.../metrics/IoTDBInternalLocalReporter.java | 6 +-
.../iotdb/db/storageengine/StorageEngine.java | 5 +-
.../db/storageengine/dataregion/DataRegion.java | 13 +-
.../dataregion/HashLastFlushTimeMap.java | 15 +-
.../exception/CompactionExceptionHandler.java | 11 +-
.../execute/task/AbstractCompactionTask.java | 2 +
.../execute/task/CrossSpaceCompactionTask.java | 24 +-
.../execute/task/InnerSpaceCompactionTask.java | 58 +-
.../compaction/execute/utils/CompactionUtils.java | 53 ++
.../fast/AlignedSeriesCompactionExecutor.java | 28 +-
.../executor/fast/SeriesCompactionExecutor.java | 11 +-
.../utils/executor/fast/element/PageElement.java | 9 +-
.../utils/executor/fast/element/PointElement.java | 7 +-
.../execute/utils/log/CompactionLogAnalyzer.java | 16 +-
.../execute/utils/reader/PointPriorityReader.java | 14 +-
.../compaction/schedule/CompactionTaskManager.java | 1 -
.../compaction/selector/ICompactionSelector.java | 4 +-
.../estimator/AbstractCompactionEstimator.java | 120 ++-
.../estimator/AbstractCrossSpaceEstimator.java | 27 +-
.../estimator/AbstractInnerSpaceEstimator.java | 13 +-
.../estimator/CompactionEstimateUtils.java | 95 +++
.../selector/estimator/CompactionTaskInfo.java | 101 +++
.../FastCompactionInnerCompactionEstimator.java | 80 ++
.../FastCrossSpaceCompactionEstimator.java | 81 ++
.../compaction/selector/estimator/FileInfo.java | 48 ++
.../estimator/InplaceCompactionEstimator.java | 172 ----
.../ReadChunkInnerCompactionEstimator.java | 73 ++
.../ReadPointCrossCompactionEstimator.java | 272 -------
.../impl/RewriteCrossSpaceCompactionSelector.java | 21 +-
.../utils/CrossCompactionTaskResource.java | 6 +-
.../dataregion/flush/MemTableFlushTask.java | 59 +-
.../memtable/AlignedReadOnlyMemChunk.java | 12 +-
.../dataregion/memtable/TsFileProcessor.java | 151 ++--
.../read/reader/chunk/DiskAlignedChunkLoader.java | 13 +-
.../read/reader/chunk/MemAlignedChunkLoader.java | 11 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 8 +-
.../read/reader/chunk/MemAlignedPageReader.java | 41 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 16 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 19 +-
.../dataregion/tsfile/TsFileManager.java | 17 +
.../dataregion/tsfile/TsFileResource.java | 25 +-
.../wal/checkpoint/CheckpointManager.java | 2 +-
.../storageengine/dataregion/wal/node/WALNode.java | 245 ++++--
.../file/UnsealedTsFileRecoverPerformer.java | 2 +-
.../dataregion/wal/utils/WALEntryHandler.java | 36 +-
.../dataregion/wal/utils/WALEntryPosition.java | 14 +-
.../dataregion/wal/utils/WALInsertNodeCache.java | 96 ++-
.../db/storageengine/rescon/memory/SystemInfo.java | 3 +
.../quotas/DataNodeThrottleQuotaManager.java | 1 +
.../rescon/quotas/DefaultOperationQuota.java | 14 +-
.../db/trigger/executor/TriggerFireVisitor.java | 20 +
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 65 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 3 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 6 +-
.../iotdb/db/utils/constant/SqlConstant.java | 3 +
.../db/utils/datastructure/AlignedTVList.java | 46 ++
.../mtree/schemafile/SchemaFileLogTest.java | 2 +-
.../schemaRegion/SchemaRegionManagementTest.java | 2 +-
.../iotdb/db/pipe/connector/PipeConnectorTest.java | 24 +-
.../iotdb/db/pipe/connector/PipeReceiverTest.java | 8 +-
.../db/pipe/connector/PipeThriftRequestTest.java | 25 +-
.../PipeProcessorSubtaskExecutorTest.java | 4 +-
.../db/pipe/extractor/PipeRealtimeExtractTest.java | 3 +-
.../common/schematree/ClusterSchemaTreeTest.java | 178 +++++
.../ClusterSchemaTreeTestWithRelease.java | 16 +
.../MockSchemaTreeMeasurementVisitor.java | 6 +
.../execution/aggregation/AccumulatorTest.java | 44 +
.../execution/executor/RegionReadExecutorTest.java | 31 +-
.../executor/RegionWriteExecutorTest.java | 24 +-
.../operator/AlignedSeriesScanOperatorTest.java | 15 +-
.../execution/operator/OperatorMemoryTest.java | 4 +-
.../queryengine/plan/analyze/AnalyzeFailTest.java | 72 ++
.../plan/optimization/LimitOffsetPushDownTest.java | 271 +++++++
.../plan/plan/QueryLogicalPlanUtil.java | 5 +-
.../plan/statement/sys/pipe/PipeStatementTest.java | 10 +-
.../scheduler/load/LoadTsFileSchedulerTest.java | 3 +-
.../DataNodeInternalRPCServiceImplTest.java | 8 +-
.../TsFileResourceProgressIndexTest.java | 39 +
.../FastCompactionPerformerWithEmptyPageTest.java | 137 ++++
.../inner/InnerSpaceCompactionExceptionTest.java | 4 +-
.../utils/CompactionTaskMemCostEstimatorTest.java | 106 +++
.../compaction/utils/CompactionTestFileWriter.java | 99 ++-
.../dataregion/memtable/TsFileProcessorTest.java | 97 +++
.../reader/chunk/MemAlignedChunkLoaderTest.java | 2 +-
.../dataregion/wal/node/WALEntryHandlerTest.java | 6 +-
.../wal/utils/WALInsertNodeCacheTest.java | 8 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 2 +-
.../iotdb/db/tools/PBTreeFileSketchTest.java | 2 +-
.../datanode1conf/iotdb-common.properties | 2 +-
.../datanode2conf/iotdb-common.properties | 3 +-
.../datanode3conf/iotdb-common.properties | 2 +-
.../iotdb/metrics/AbstractMetricService.java | 45 +-
.../metrics/metricsets/system/SystemMetrics.java | 69 +-
.../metrics/reporter/iotdb/IoTDBReporter.java | 6 +-
iotdb-core/mlnode/pom.xml | 2 +-
iotdb-core/node-commons/pom.xml | 5 -
.../resources/conf/iotdb-common.properties | 98 +--
.../src/assembly/resources/sbin/iotdb-common.sh | 15 +-
.../iotdb/commons/client/ClientPoolFactory.java | 2 +-
.../async/AsyncConfigNodeIServiceClient.java | 1 +
.../async/AsyncDataNodeInternalServiceClient.java | 1 +
.../AsyncDataNodeMPPDataExchangeServiceClient.java | 1 +
.../async/AsyncPipeDataTransferServiceClient.java | 1 +
.../iotdb/commons/concurrent/ThreadName.java | 17 +-
.../WrappedScheduledExecutorService.java | 2 +-
.../WrappedSingleThreadExecutorService.java | 2 +-
.../WrappedSingleThreadScheduledExecutor.java | 2 +-
.../threadpool/WrappedThreadPoolExecutor.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 44 +-
.../iotdb/commons/conf/CommonDescriptor.java | 19 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 4 +-
.../iotdb/commons/consensus/ConsensusGroupId.java | 38 +-
.../commons/executable/ExecutableManager.java | 11 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 158 +++-
.../iotdb/commons/path/PathPatternTreeUtils.java | 53 ++
.../apache/iotdb/commons/path/PathPatternUtil.java | 4 +-
.../apache/iotdb/commons/path/fa/FAFactory.java | 14 +-
.../apache/iotdb/commons/path/fa/IPatternFA.java | 17 +-
.../iotdb/commons/path/fa/dfa/PatternDFA.java | 60 ++
.../iotdb/commons/path/fa/dfa/graph/NFAGraph.java | 67 +-
.../commons/path/fa/match/IStateMatchInfo.java | 2 +
.../commons/path/fa/match/StateMultiMatchInfo.java | 14 +-
.../path/fa/match/StateSingleMatchInfo.java | 10 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 24 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 16 +-
...tConnectorV1.java => IoTDBAirGapConnector.java} | 10 +-
...nectorV1.java => IoTDBLegacyPipeConnector.java} | 10 +-
...ectorV1.java => IoTDBThriftAsyncConnector.java} | 10 +-
.../builtin/connector/IoTDBThriftConnector.java | 54 +-
...nectorV1.java => IoTDBThriftSyncConnector.java} | 10 +-
...yncConnector.java => PlaceholderConnector.java} | 12 +-
...iftConnectorV2.java => WebSocketConnector.java} | 10 +-
.../builtin/processor/DoNothingProcessor.java | 15 +-
.../commons/pipe/task/meta/PipeMetaKeeper.java | 4 +
.../iotdb/commons/schema}/SchemaConstant.java | 18 +-
.../commons/schema/tree/AbstractTreeVisitor.java | 136 +++-
.../iotdb/commons/schema/tree/ITreeNode.java | 4 +
.../apache/iotdb/commons/service/ServiceType.java | 6 +-
.../iotdb/commons/service/ThriftService.java | 3 +-
.../commons/service/metric/MetricService.java | 3 +-
.../iotdb/commons/structure/BalanceTreeMap.java | 4 +
.../udf/builtin/BuiltinAggregationFunction.java | 5 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 2 +-
.../iotdb/commons/client/ClientManagerTest.java | 128 ++-
.../client/mock/MockInternalRPCService.java | 4 -
.../apache/iotdb/commons/path/PartialPathTest.java | 68 ++
.../iotdb/commons/path/PathPatternTreeTest.java | 121 +++
.../apache/iotdb/commons/path/PatternDFATest.java | 45 ++
.../pipe/plugin/builtin/BuiltinPipePluginTest.java | 16 +-
.../file/metadata/AlignedTimeSeriesMetadata.java | 34 +-
.../read/TsFileAlignedSeriesReaderIterator.java | 2 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 12 +-
.../read/reader/chunk/AlignedChunkReader.java | 32 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 130 +--
.../page/LazyLoadAlignedPagePointReader.java | 97 +++
.../read/reader/series/FileSeriesReader.java | 2 +-
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 4 +-
.../org/apache/iotdb/tsfile/utils/PublicBAOS.java | 1 +
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 2 +-
.../reader/LazyLoadAlignedPagePointReaderTest.java | 177 ++++
.../tsfile/write/TsFileIntegrityCheckingTool.java | 3 +-
iotdb-protocol/pom.xml | 4 +-
.../thrift-commons/src/main/thrift/common.thrift | 3 +-
.../pom.xml | 4 +-
.../src/main/thrift/iotconsensus.thrift | 0
.../{thrift => thrift-datanode}/README.md | 0
iotdb-protocol/{thrift => thrift-datanode}/pom.xml | 4 +-
.../{thrift => thrift-datanode}/rpc-changelist.md | 0
.../src/main/thrift/client.thrift | 0
.../src/main/thrift/datanode.thrift | 11 +
pom.xml | 47 +-
tools/README.md | 183 -----
tools/pom.xml | 33 -
tools/thrift/pom.xml | 162 ----
tools/thrift/src/main/assembly/thrift.xml | 64 --
567 files changed, 17296 insertions(+), 7045 deletions(-)
create mode 100644 .github/workflows/pipe-it-2cluster.yml
copy integration-test/src/main/java/org/apache/iotdb/it/env/{EnvFactory.java
=> MultiEnvFactory.java} (57%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/ClusterConstant.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/ConfigNodeWrapper.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/DataNodeWrapper.java
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
config}/MppBaseConfig.java (97%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
config}/MppClusterConfig.java (98%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
config}/MppCommonConfig.java (88%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
config}/MppConfigNodeConfig.java (97%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
config}/MppDataNodeConfig.java (97%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
config}/MppJVMConfig.java (98%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
config}/MppSharedCommonConfig.java (97%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
env}/AbstractEnv.java (90%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
env}/Cluster1Env.java (92%)
copy
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusResponse.java
=>
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/env/MultiClusterEnv.java
(55%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
env}/SimpleEnv.java (96%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
node}/AbstractNodeWrapper.java (52%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/ConfigNodeWrapper.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/DataNodeWrapper.java
rename integration-test/src/main/java/org/apache/iotdb/it/env/remote/{ =>
config}/RemoteClusterConfig.java (97%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/remote/{ =>
config}/RemoteCommonConfig.java (97%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/remote/{ =>
config}/RemoteConfigNodeConfig.java (95%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/remote/{ =>
config}/RemoteDataNodeConfig.java (95%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/remote/{ =>
config}/RemoteJVMConfig.java (96%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/remote/{ =>
env}/RemoteServerEnv.java (97%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT1.java
(84%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2.java
(84%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT3.java
(84%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBAutoRegionGroupExtensionIT2.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBCountTimeAlignedDeviceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBCountTimeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeDataSyncIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeSingleEnvDemoIT.java
copy {iotdb-protocol/thrift-iot-consensus =>
iotdb-connector/flink-sql-iotdb-connector}/pom.xml (56%)
create mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/client/IoTDBWebSocketClient.java
create mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/common/Options.java
create mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/common/Utils.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalIoTDBPathException.java
(82%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalOptionException.java
(82%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalSchemaException.java
(82%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalUrlPathException.java
(82%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/UnsupportedDataTypeException.java
(81%)
create mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/factory/IoTDBDynamicTableFactory.java
create mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBBoundedScanFunction.java
create mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBCDCSourceFunction.java
create mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBLookupFunction.java
create mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBSinkFunction.java
create mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/provider/IoTDBDynamicTableSink.java
create mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/provider/IoTDBDynamicTableSource.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/LowercaseNormalizeVisitor.java
=>
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/wrapper/SchemaWrapper.java
(54%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusResponse.java
=>
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/wrapper/TabletWrapper.java
(54%)
copy
iotdb-core/datanode/src/test/resources/datanode3conf/iotdb-common.properties =>
iotdb-connector/flink-sql-iotdb-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
(84%)
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusGenericResponse.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusReadResponse.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusWriteResponse.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/exception/NodeReadOnlyException.java
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/simple/{SimpleServerImpl.java
=> SimpleConsensusServerImpl.java} (94%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeCronEventInjector.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/airgap/AirGapOneByteResponse.java}
(79%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/airgap/AirGapPseudoTPipeTransferRequest.java}
(80%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1 =>
payload/evolvable}/PipeRequestType.java (88%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/builder/IoTDBThriftAsyncPipeTransferBatchReqBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/builder/IoTDBThriftSyncPipeTransferBatchReqBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/builder/PipeTransferBatchReqBuilder.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1 =>
payload/evolvable}/reponse/PipeTransferFilePieceResp.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1 =>
payload/evolvable}/request/PipeTransferFilePieceReq.java (72%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1 =>
payload/evolvable}/request/PipeTransferFileSealReq.java (71%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1 =>
payload/evolvable}/request/PipeTransferHandshakeReq.java (72%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/PipeTransferTabletBatchReq.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1/request/PipeTransferInsertNodeReq.java
=> payload/evolvable/request/PipeTransferTabletBinaryReq.java} (55%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1/request/PipeTransferInsertNodeReq.java
=> payload/evolvable/request/PipeTransferTabletInsertNodeReq.java} (65%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1/request/PipeTransferTabletReq.java
=> payload/evolvable/request/PipeTransferTabletRawReq.java} (75%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{legacy/pipedata
=> payload/legacy}/DeletionPipeData.java (93%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{legacy/pipedata
=> payload/legacy}/PipeData.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{legacy/pipedata
=> payload/legacy}/TsFilePipeData.java (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{base/IoTDBThriftConnector.java
=> protocol/IoTDBConnector.java} (80%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{IoTDBThriftConnectorRequestVersion.java
=> protocol/IoTDBConnectorRequestVersion.java} (85%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/airgap/IoTDBAirGapConnector.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{legacy/IoTDBSyncConnector.java
=> protocol/legacy/IoTDBLegacyPipeConnector.java} (92%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v2/IoTDBThriftConnectorV2.java
=> protocol/thrift/async/IoTDBThriftAsyncConnector.java} (67%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v2/handler/PipeTransferTabletInsertionEventHandler.java
=> protocol/thrift/async/handler/PipeTransferTabletBatchEventHandler.java}
(56%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v2/handler/PipeTransferInsertNodeTabletInsertionEventHandler.java
=>
protocol/thrift/async/handler/PipeTransferTabletInsertNodeEventHandler.java}
(83%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v2 =>
protocol/thrift/async}/handler/PipeTransferTabletInsertionEventHandler.java
(90%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v2/handler/PipeTransferRawTabletInsertionEventHandler.java
=> protocol/thrift/async/handler/PipeTransferTabletRawEventHandler.java} (83%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v2 =>
protocol/thrift/async}/handler/PipeTransferTsFileInsertionEventHandler.java
(91%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1/IoTDBThriftConnectorV1.java
=> protocol/thrift/sync/IoTDBThriftSyncConnector.java} (64%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1/IoTDBThriftConnectorClient.java
=> protocol/thrift/sync/IoTDBThriftSyncConnectorClient.java} (90%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/websocket/WebSocketConnectorServer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/websocket/WebsocketConnector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/heartbeat/PipeHeartbeatEvent.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/PipeDoNothingProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/airgap/IoTDBAirGapReceiver.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/airgap/IoTDBAirGapReceiverAgent.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/legacy/IoTDBSyncReceiver.java
=> receiver/legacy/IoTDBLegacyPipeReceiverAgent.java} (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> receiver}/legacy/loader/DeletionLoader.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> receiver}/legacy/loader/ILoader.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> receiver}/legacy/loader/TsFileLoader.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{agent/receiver =>
receiver/thrift}/IoTDBThriftReceiver.java (87%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{agent/receiver/PipeReceiverAgent.java
=> receiver/thrift/IoTDBThriftReceiverAgent.java} (70%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/v1 =>
receiver/thrift}/IoTDBThriftReceiverV1.java (73%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/aggregation/{CountAccumulator.java
=> CountTimeAccumulator.java} (84%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/LoadTsfileAnalyzer.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/{LowercaseNormalizeVisitor.java
=> CountTimeAggregationAmountVisitor.java} (50%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/PipeEnrichedInsertNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/PipeEnrichedInsertBaseStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/PipeEnrichedLoadTsFileStatement.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{sys
=> metadata}/pipe/CreatePipeStatement.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{sys
=> metadata}/pipe/DropPipeStatement.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{sys
=> metadata}/pipe/ShowPipesStatement.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{sys
=> metadata}/pipe/StartPipeStatement.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{sys
=> metadata}/pipe/StopPipeStatement.java (96%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/CompactionEstimateUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/CompactionTaskInfo.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/FastCompactionInnerCompactionEstimator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/FastCrossSpaceCompactionEstimator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/FileInfo.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/InplaceCompactionEstimator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/ReadChunkInnerCompactionEstimator.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/ReadPointCrossCompactionEstimator.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/FastCompactionPerformerWithEmptyPageTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/CompactionTaskMemCostEstimatorTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/path/PathPatternTreeUtils.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBThriftConnectorV1.java
=> IoTDBAirGapConnector.java} (73%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBThriftConnectorV1.java
=> IoTDBLegacyPipeConnector.java} (72%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBThriftConnectorV1.java
=> IoTDBThriftAsyncConnector.java} (73%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBThriftConnectorV1.java
=> IoTDBThriftSyncConnector.java} (73%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBSyncConnector.java
=> PlaceholderConnector.java} (86%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBThriftConnectorV2.java
=> WebSocketConnector.java} (73%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/schemaengine =>
node-commons/src/main/java/org/apache/iotdb/commons/schema}/SchemaConstant.java
(88%)
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/page/LazyLoadAlignedPagePointReader.java
create mode 100644
iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/LazyLoadAlignedPagePointReaderTest.java
rename iotdb-protocol/{thrift-iot-consensus => thrift-consensus}/pom.xml (95%)
rename iotdb-protocol/{thrift-iot-consensus =>
thrift-consensus}/src/main/thrift/iotconsensus.thrift (100%)
rename iotdb-protocol/{thrift => thrift-datanode}/README.md (100%)
rename iotdb-protocol/{thrift => thrift-datanode}/pom.xml (96%)
rename iotdb-protocol/{thrift => thrift-datanode}/rpc-changelist.md (100%)
rename iotdb-protocol/{thrift =>
thrift-datanode}/src/main/thrift/client.thrift (100%)
rename iotdb-protocol/{thrift =>
thrift-datanode}/src/main/thrift/datanode.thrift (98%)
delete mode 100644 tools/README.md
delete mode 100644 tools/pom.xml
delete mode 100644 tools/thrift/pom.xml
delete mode 100644 tools/thrift/src/main/assembly/thrift.xml
