You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/04/28 09:19:46 UTC
[iotdb] branch groupbylevelOperator updated (6a79fd5918 -> 52002fcdbb)
This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a change to branch groupbylevelOperator
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6a79fd5918 modification
add 6bd0f2cb0f [IOTDB-2848] Consensus snapshot interface (#5497)
add 564b286edd Format SerializeTask in WALBuffer (#5603)
add a019934b42 Add Thread re-interrupt when catching exception (#5604)
add 1b6a0bc26b [IOTDB-2619][User Docs] Grafana Plugin: Alerting (#5605)
add 380cda196c [IOTDB-2803]Supplement the remaining metadata write plannode and change SchemaRegion to accept plannode parameter (#5529)
add 2927a82915 Bump junit from 4.11 to 4.13.1 in /zeppelin-interpreter (#5428)
add fa7372aa56 Bump jackson-databind from 2.6.7 to 2.12.6.1 in /spark-iotdb-connector (#5425)
add 731965beb0 Separate SchemaRegion Memory Implementation (#5584)
add 67dafed0e6 Add Driver.failed() call in FragmentInstanceScheduler (#5593)
add 55812435d9 Change the result of ConfigExecution from Void to TsBlock (#5609)
add ec3f49549a [IOTDB-2965] Skip failed mlog and snapshot items when upgrading happens (#5608)
add aadd8cae72 [IOTDB-2619][User Docs EN] Grafana Plugin: Alerting (#5612)
add 7ce6033609 [IOTDB-2942] [IOTDB-2944] Delete duplicate data structure in node-commons and extend TDataNodeLocation (#5592)
add fa43cd6998 [rocksdb] add rocksdb docs (#5598)
add 9ff33b3f15 [IOTDB-2932]Fix localPartitionTable concurrent bug (#5607)
add 8db887692a Fix class path in SchemaFileSketcher.sh and mLogParser.sh (#5618)
add 254ca0532b fix the UT of ConfigExecution (#5621)
add 7af14c96ea [rocksdb] add rocksdb properties (#5588)
add d74157cd40 [IOTDB-2880]Add procedure framework (#5477)
add df250d3a1e [IOTDB-2970] Code style: Avoid wildcard imports (#5622)
add 2df96fee1e [rocksdb] updated the interface support (#5625)
add 75620dd4d6 [IOTDB-2971] Fix sink handle memory leak (#5626)
add b2520b31b0 [IOTDB-2880] Fix import check style (#5629)
add f9226c380d Add FragmentInstanceStateMachine for FragmentInstance State change (#5615)
add 9522cfb39e [IOTDB-2835]Fix empty page in selfcheck method of TsFileSequenceReader (#5552)
add 650a7a8e94 fix the bug when matching multi-wildcard in pattern tree (#5631)
add 6952eed0e6 Add block cancel when GetBlockTask throws exception (#5628)
add 1a2ea0c03a Add ColumnMerger to merge multipul input columns of same sensor into one column (#5630)
add 25983540e7 Fix CI (#5639)
add 7a500adb6e [IOTDB-2880] Fix NPE occured in ci test (#5634)
add f037de3705 fix concurrent bug of CachedMNodeContainer.putIfAbsent (#5632)
add 8df96c5ce2 Fix the issue that EndTime in FragmentInstanceContext is not set (#5636)
add dc344e5b70 [IOTDB-2740] Equal size bucket sampling UDFs: EQUAL_SIZE_BUCKET_RANDOM_SAMPLE, EQUAL_SIZE_BUCKET_AGG_SAMPLE, EQUAL_SIZE_BUCKET_M4_SAMPLE (#5518)
add 677f58763b change jenkins timeout from 2 hours to 3 hours
add 9504a2b703 [IOTDB-2976] Add English and Chinese docs for count devices and count storage groups (#5635)
add 61dde93485 filter non schemaRegionDir (#5640)
add a547fef5ca Serialize measurement schema of insert node to wal entry (#5638)
add d939abfc5e Refactor attributes in PlanNode (#5616)
add d3a8516172 Fix TimeJoinNode clone and serde bug (#5644)
add 39619ff619 [IOTDB-2982] Recover tsfile after datanode restart (#5643)
add ce064f429c Add config example for new cluster (#5624)
add 949abc4294 [IOTDB-2979] Optimize the serialization and deserialization of thrift data structures (#5637)
add a27cd2e58b [IOTDB-2984] RatisConsensus Recovery Logic (#5648)
add 9685c5b67b [IOTDB-2930]Fix concurrent UnPin bug & Improve template implementation (#5647)
add d47339793f [IOTDB-2989] Expression Serialize & Deserialize (#5649)
add f03f0205ab [IOTDB-2933] detect sender exit and set pipestatus=STOP (#5557)
add ecd19464f4 Fix import wildcard violation
add 467add666d [IOTDB-2945] Reconstruct ConfigNode manage layer and persistence layer (#5627)
add 74bcc7edc9 [IOTDB-2955] Design and implement ClientManager for thrift client's pooling management (#5595)
add dde44dcbe2 [IOTDB-2996] Fix wildcard import in test folders (#5652)
add ff4161643b will not delete empty .pst now (#5653)
add 907c06e52f Fix schema file with cache of size 1 (#5651)
add dd37fc1097 [IOTDB-2966]fix CompactionTaskManagerTest CI (#5610)
add 407c076424 [IOTDB-2999][Metric] remove useless config and fix default value error. (#5657)
add 138bd00ff9 Optimize source handle error handling (#5659)
add a7b0f198af Support set storage group in standalone mpp mode (#5655)
add 3d040c9855 fix the issue that FragmentInstance's status cannot be updated to FINISHED in some scenario (#5660)
add f7bd1ad8c3 [IOTDB-2912] MPP: FilterOperator (#5645)
add fc62a59a40 [IOTDB-2958]create a simple schemaCache for datanode metadata (#5602)
add 94bded4094 [IOTDB-2968] RatisConsensus snapshot implementation (#5623)
add 3c23ae3f39 [IOTDB-3007] Separate DataNode and IoTDB (#5668)
add 648212e1c4 [IOTDB-3005] Increase read and write permissions in ConfigExecution (#5664)
add 3dc1675e62 [IOTDB-2845] Implementation of DeviceViewOperator Part1 (#5613)
add 54faa59849 Implement MultiColumnMerger to support querying data of one timeseries distributed on different DataNodes (#5663)
add c22c1405ba extract interface from path (#5662)
add 7d5630159c Use logical clock to fix clientManager test (#5671)
add 718305dfcc [IOTDB-3003] data sync pipe recover bug & other issues (#5665)
add 90d417fe7b [IOTDB-2803]fix some UT code smell and refine plannode serialize (#5667)
add 56b5f80e77 [IOTDB-3000] ConfigNode supports MTreeAboveSG (#5670)
add 506b515c83 [IOTDB-3012][De-Singleton-1] remove singleton pattern for some classes (#5672)
add f365a1199a Update dbeaver user guide (#5675)
add 8fb2737aba [IOTDB-3013] Using Client Pool to replace previous DataBlockServiceClientFactory and InternalServiceClientFactory (#5674)
add 787456ac3e [IOTDB-3014] [Rocksdb_based] fix OOM (#5677)
add 714b81a50a [IOTDB-2983] Serialization error in Partial insert (#5680)
add b633df56ca Skip node commons test in C++ client CI (#5681)
add 5708dfd192 [IOTDB-3017] Reorder expression priority according to standard (#5669)
add 4bf3dbb674 [IOTDB-2960]Add partition cache (#5685)
add 9b5f18318e Set correct InternalEndpoint and DataBlockEndpoint when planning (#5679)
add 6946f3031a [IOTDB-2938]Some improvements and bug fix for New Sync (#5563)
add 112758a997 [IOTDB-2701]User guide for Sync (#5676)
add 300903d2bb Update the description of ** (#5690)
add dd5071df75 New schema tree traverse implementation (#5686)
add 660fc05f31 [IOTDB-2998] Pooling RatisConsensus Raft client (#5683)
add b06d314762 [IOTDB-3015] Authenticate login via confignode (#5678)
add 5f6a986b1c [IOTDB-2753] Insert a time series with a null value and report 500 (#5694)
add b16c381e22 fix typo in DataNodeTSIServiceImpl (#5698)
add 71fc0921db [IOTDB-2803][new cluster][mpp] Adapt count devices / timeseries to mpp (#5654)
add 7a3fbda6df fix create bitmap when converting tsblocks to dataset (#5697)
add e6513969dd Disable sonar check for PRs from fork repo (#5700)
add c636e680d0 Serialize DataNodeID into system.properties of datanode (#5691)
add b4611ed823 [IOTDB-3019] Feature/show storage group (#5687)
add a0c3f07740 Move time partition calculation from StorageEngine to StorageEngineV2 (#5703)
add ca4f3cfc81 [IOTDB-2933] Implement expression classes for IN, LIKE, and REGEXP expressions (#5706)
add 29944af738 Add javadoc and rename some class in FragmentInstanceManager and Driver related (#5701)
add a9fd419fbd [IOTDB-2967] New writing process of cluster (#5656)
add 9cc21e1dfb Fix Sesssion InsertRecord bug (#5712)
add 52002fcdbb fix conflict
No new revisions were added by this update.
Summary of changes:
.github/workflows/client-cpp.yml | 4 +-
.github/workflows/sonar-coveralls.yml | 5 +-
Jenkinsfile | 2 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 15 +-
checkstyle.xml | 7 +-
client-cpp/pom.xml | 7 +-
client-py/pom.xml | 8 +
.../iotdb/cluster/log/applier/DataLogApplier.java | 6 +-
.../log/manage/PartitionedSnapshotLogManager.java | 2 +-
.../iotdb/cluster/metadata/CSchemaProcessor.java | 43 +-
.../apache/iotdb/cluster/metadata/MetaPuller.java | 3 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 5 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 8 +-
.../query/manage/ClusterSessionManager.java | 1 +
.../cluster/query/reader/ClusterReaderFactory.java | 20 +-
.../iotdb/cluster/server/ClusterRPCService.java | 5 -
.../server/clusterinfo/ClusterInfoServer.java | 5 -
.../server/handlers/caller/LogCatchUpHandler.java | 4 +-
.../server/raft/DataRaftHeartBeatService.java | 6 -
.../iotdb/cluster/server/raft/DataRaftService.java | 6 -
.../server/raft/MetaRaftHeartBeatService.java | 6 -
.../iotdb/cluster/server/raft/MetaRaftService.java | 6 -
.../iotdb/cluster/integration/SingleNodeTest.java | 5 +-
.../iotdb/cluster/log/CommitLogCallbackTest.java | 2 +-
.../iotdb/cluster/log/CommitLogTaskTest.java | 5 +-
.../FilePartitionedSnapshotLogManagerTest.java | 2 +
.../query/ClusterPhysicalGeneratorTest.java | 2 +-
.../cluster/server/member/DataGroupMemberTest.java | 2 +
.../cluster/server/member/MetaGroupMemberTest.java | 5 +-
confignode/pom.xml | 10 -
.../resources/conf/iotdb-confignode.properties | 30 +-
.../iotdb/confignode/cli/TemporaryClient.java | 40 +-
.../client/ConfigNodeClientPoolFactory.java | 74 ++
.../iotdb/confignode/conf/ConfigNodeConf.java | 90 +-
.../confignode/conf/ConfigNodeDescriptor.java | 33 +-
.../request/ConfigRequest.java} | 91 +-
.../request/ConfigRequestType.java} | 13 +-
.../request/auth/AuthorReq.java} | 86 +-
.../request/read/GetDataNodeInfoReq.java} | 18 +-
.../request/read/GetOrCountStorageGroupReq.java | 77 ++
.../request/read/GetOrCreateDataPartitionReq.java} | 54 +-
.../read/GetOrCreateSchemaPartitionReq.java} | 36 +-
.../request/write/CreateDataPartitionReq.java} | 60 +-
.../request/write/CreateRegionsReq.java} | 37 +-
.../request/write/CreateSchemaPartitionReq.java} | 43 +-
.../request/write/DeleteStorageGroupReq.java} | 12 +-
.../request/write/RegisterDataNodeReq.java} | 37 +-
.../request/write/SetDataReplicationFactorReq.java | 80 ++
.../write/SetSchemaReplicationFactorReq.java | 80 ++
.../request/write/SetStorageGroupReq.java} | 33 +-
.../request/write/SetTTLReq.java} | 47 +-
.../request/write/SetTimePartitionIntervalReq.java | 80 ++
...InfoDataSet.java => CountStorageGroupResp.java} | 36 +-
...DataSet.java => DataNodeConfigurationResp.java} | 10 +-
...InfoDataSet.java => DataNodeLocationsResp.java} | 34 +-
.../consensus/response/DataPartitionDataSet.java | 113 ---
...gurationDataSet.java => DataPartitionResp.java} | 42 +-
...ionInfoDataSet.java => PermissionInfoResp.java} | 6 +-
.../consensus/response/SchemaPartitionDataSet.java | 86 --
...onInfoDataSet.java => SchemaPartitionResp.java} | 37 +-
...emaDataSet.java => StorageGroupSchemaResp.java} | 23 +-
.../statemachine/PartitionRegionStateMachine.java | 47 +-
.../physical/UnknownPhysicalPlanTypeException.java | 4 +-
.../confignode/manager/ClusterSchemaManager.java | 224 +++++
.../iotdb/confignode/manager/ConfigManager.java | 196 ++--
.../iotdb/confignode/manager/ConsensusManager.java | 12 +-
.../iotdb/confignode/manager/DataNodeManager.java | 45 +-
.../apache/iotdb/confignode/manager/Manager.java | 66 +-
.../iotdb/confignode/manager/PartitionManager.java | 107 +--
.../confignode/manager/PermissionManager.java | 31 +-
.../iotdb/confignode/manager/RegionManager.java | 155 ----
.../confignode/partition/StorageGroupSchema.java | 121 ---
...{AuthorInfoPersistence.java => AuthorInfo.java} | 81 +-
.../confignode/persistence/ClusterSchemaInfo.java | 320 +++++++
...aNodeInfoPersistence.java => DataNodeInfo.java} | 78 +-
...tionInfoPersistence.java => PartitionInfo.java} | 159 +++-
.../persistence/RegionInfoPersistence.java | 223 -----
.../physical/sys/RegisterDataNodePlan.java | 79 --
.../iotdb/confignode/service/ConfigNode.java | 42 +-
.../confignode/service/ConfigNodeCommandLine.java | 2 +-
.../service/executor/ConfigRequestExecutor.java | 131 +++
.../confignode/service/executor/PlanExecutor.java | 116 ---
...odeRPCServer.java => ConfigNodeRPCService.java} | 37 +-
.../{server => }/ConfigNodeRPCServiceHandler.java | 6 +-
...erMBean.java => ConfigNodeRPCServiceMBean.java} | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 306 +++++++
.../server/ConfigNodeRPCServerProcessor.java | 240 -----
.../iotdb/confignode/cli/TemporaryClientDemo.java | 4 +-
.../confignode/consensus/RatisConsensusDemo.java | 151 ----
.../consensus/request/ConfigRequestSerDeTest.java | 491 ++++++++++
.../manager/ConfigManagerManualTest.java | 133 ---
.../physical/SerializeDeserializeUT.java | 404 ---------
...java => ConfigNodeRPCServiceProcessorTest.java} | 306 ++++---
.../utils/ConfigNodeEnvironmentUtils.java | 4 +-
.../confignode1conf/iotdb-confignode.properties | 37 +-
.../resources/confignode1conf}/logback.xml | 0
.../confignode2conf/iotdb-confignode.properties | 37 +-
.../resources/confignode2conf}/logback.xml | 0
.../confignode3conf/iotdb-confignode.properties | 37 +-
.../resources/confignode3conf}/logback.xml | 0
consensus/pom.xml | 5 -
.../apache/iotdb/consensus/ConsensusFactory.java | 7 +-
.../org/apache/iotdb/consensus/IConsensus.java | 5 +-
.../org/apache/iotdb/consensus/common/Peer.java | 8 +-
.../iotdb/consensus/common/SnapshotMeta.java | 47 +-
.../ratis/ApplicationStateMachineProxy.java | 81 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 107 +++
.../iotdb/consensus/ratis/RatisConsensus.java | 241 +++--
.../iotdb/consensus/ratis/RequestMessage.java | 2 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 100 +++
.../org/apache/iotdb/consensus/ratis/Utils.java | 33 +-
.../consensus/standalone/StandAloneConsensus.java | 6 +-
.../consensus/standalone/StandAloneServerImpl.java | 20 +
.../consensus/statemachine/EmptyStateMachine.java | 20 +
.../consensus/statemachine/IStateMachine.java | 51 ++
.../iotdb/consensus/ratis/RatisConsensusTest.java | 132 +--
.../apache/iotdb/consensus/ratis/SnapshotTest.java | 120 +++
.../apache/iotdb/consensus/ratis/TestUtils.java | 203 +++++
.../standalone/StandAloneConsensusTest.java | 48 +-
.../tests/tools/importCsv/AbstractScript.java | 7 +-
docs/Development/ContributeGuide.md | 16 +
.../Data-Concept/Data-Model-and-Terminology.md | 2 +-
.../Data-Modeling/SchemaRegion-rocksdb.md | 93 ++
docs/UserGuide/Ecosystem Integration/DBeaver.md | 22 +-
.../Ecosystem Integration/Grafana Plugin.md | 141 ++-
docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 119 ++-
docs/UserGuide/Operate-Metadata/Node.md | 45 +
docs/UserGuide/Operate-Metadata/Storage-Group.md | 60 ++
docs/UserGuide/Query-Data/Select-Expression.md | 150 +++-
docs/zh/Development/ContributeGuide.md | 17 +
.../Data-Modeling/SchemaRegion-rocksdb.md | 93 ++
docs/zh/UserGuide/Ecosystem Integration/DBeaver.md | 28 +-
.../Ecosystem Integration/Grafana Plugin.md | 143 ++-
docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 23 +-
docs/zh/UserGuide/Operate-Metadata/Node.md | 45 +
.../zh/UserGuide/Operate-Metadata/Storage-Group.md | 60 ++
docs/zh/UserGuide/Query-Data/Select-Expression.md | 150 +++-
.../iotdb/hadoop/tsfile/TSFMRReadExample.java | 5 +-
.../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 11 +-
.../iotdb/hadoop/tsfile/record/HDFSTSRecord.java | 8 +-
.../iotdb/hadoop/tsfile/TSFInputSplitTest.java | 3 +-
.../org/apache/iotdb/hive/TSFHiveInputFormat.java | 6 +-
.../org/apache/iotdb/hive/TsFileDeserializer.java | 10 +-
.../apache/iotdb/hive/TsFileDeserializerTest.java | 11 +-
.../org/apache/iotdb/hive/TsFileSerDeTest.java | 11 +-
.../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 2 +-
.../influxdb/integration/IoTDBInfluxDBIT.java | 2 +-
.../apache/iotdb/db/integration/IoTDBAliasIT.java | 5 +-
.../iotdb/db/integration/IoTDBCompleteIT.java | 6 +-
.../apache/iotdb/db/integration/IoTDBDaemonIT.java | 16 +-
.../org/apache/iotdb/db/integration/IoTDBInIT.java | 7 +-
.../{IoTDBInIT.java => IoTDBInsertNullIT.java} | 152 ++--
.../iotdb/db/integration/IoTDBMaxTimeQueryIT.java | 9 +-
.../db/integration/IoTDBPartialInsertionIT.java | 62 ++
.../db/integration/IoTDBResultMetadataIT.java | 13 +-
.../db/integration/IoTDBSchemaTemplateIT.java | 11 +-
.../iotdb/db/integration/IoTDBSelectSchemaIT.java | 12 +-
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 190 ++++
...ggregationWithoutValueFilterWithDeletionIT.java | 11 +-
...upBySlidingWindowQueryWithoutValueFilterIT.java | 9 +-
.../groupby/IOTDBGroupByInnerIntervalIT.java | 13 +-
.../db/integration/groupby/IoTDBGroupByFillIT.java | 11 +-
.../sync/IoTDBSyncReceiverCollectorIT.java | 12 +-
.../db/integration/sync/IoTDBSyncReceiverIT.java | 6 +-
.../sync/IoTDBSyncReceiverLoaderIT.java | 4 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 327 ++++++-
.../iotdb/db/integration/sync/SyncTestUtil.java | 11 +-
.../db/integration/sync/TransportClientMock.java | 12 +-
.../db/integration/sync/TransportHandlerMock.java | 61 ++
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 3 +-
.../dropwizard/DropwizardMetricManager.java | 25 +-
.../iotdb/metrics/dropwizard/MetricName.java | 6 +-
.../reporter/DropwizardMetricsExporter.java | 10 +-
.../metrics/dropwizard/reporter/IoTDBReporter.java | 16 +-
.../dropwizard/DropwizardMetricManagerTest.java | 12 +-
.../org/apache/iotdb/metrics/MetricManager.java | 6 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 20 +-
.../micrometer/MicrometerMetricManager.java | 21 +-
node-commons/pom.xml | 20 +-
.../commons/client/AsyncBaseClientFactory.java | 47 +
.../iotdb/commons/client/BaseClientFactory.java | 22 +-
.../commons/client/ClientFactoryProperty.java | 95 ++
.../apache/iotdb/commons/client/ClientManager.java | 95 ++
.../iotdb/commons/client/ClientPoolProperty.java | 84 ++
.../iotdb/commons/client/IClientManager.java | 30 +-
.../iotdb/commons/client/IClientPoolFactory.java | 11 +-
.../async/AsyncConfigNodeIServiceClient.java | 145 +++
.../async/AsyncDataNodeDataBlockServiceClient.java | 146 +++
.../async/AsyncDataNodeInternalServiceClient.java | 157 ++++
.../client/sync/SyncConfigNodeIServiceClient.java | 119 +++
.../sync/SyncDataNodeDataBlockServiceClient.java | 120 +++
.../sync/SyncDataNodeInternalServiceClient.java | 131 +++
.../iotdb/commons/cluster/DataNodeLocation.java | 81 --
.../org/apache/iotdb/commons/cluster/Endpoint.java | 92 --
.../iotdb/commons/concurrent/ThreadName.java | 3 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 44 +-
.../iotdb/commons/consensus/DataRegionId.java | 21 +-
.../iotdb/commons/consensus/PartitionRegionId.java | 21 +-
.../iotdb/commons/consensus/SchemaRegionId.java | 21 +-
.../exception/runtime/ThriftSerDeException.java | 10 +-
.../iotdb/commons/partition/DataPartition.java | 69 +-
.../commons/partition/DataPartitionQueryParam.java | 8 +-
.../apache/iotdb/commons/partition/Partition.java | 3 +-
.../iotdb/commons/partition/RegionReplicaSet.java | 141 ---
.../iotdb/commons/partition/SchemaPartition.java | 31 +-
.../iotdb/commons/partition/TimePartitionSlot.java | 64 --
.../executor/SeriesPartitionExecutor.java | 4 +-
.../partition/executor/hash/APHashExecutor.java | 6 +-
.../partition/executor/hash/BKDRHashExecutor.java | 6 +-
.../partition/executor/hash/JSHashExecutor.java | 6 +-
.../partition/executor/hash/SDBMHashExecutor.java | 6 +-
.../apache/iotdb/commons/service/JMXService.java | 13 +-
.../apache/iotdb/commons/service/ServiceType.java | 3 +-
.../iotdb/commons/service/ThriftService.java | 4 +-
.../commons/utils/BasicStructureSerDeUtil.java | 6 +-
.../apache/iotdb/commons/utils/CommonUtils.java | 12 +-
.../commons/utils/ThriftCommonsSerDeUtils.java | 165 ++++
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 69 ++
.../apache/iotdb/commons/ClientManagerTest.java | 459 ++++++++++
.../apache/iotdb/commons/ConsensusGroupIdTest.java | 23 +-
.../commons/utils/BasicStructureSerDeUtilTest.java | 18 +-
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 116 +++
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 67 ++
pom.xml | 10 +
{consensus => procedure}/pom.xml | 70 +-
.../iotdb/procedure/CompletedProcedureCleaner.java | 88 ++
.../procedure/CompletedProcedureRetainer.java | 19 +-
.../apache/iotdb/procedure/InternalProcedure.java | 61 ++
.../java/org/apache/iotdb/procedure/Procedure.java | 895 ++++++++++++++++++
.../apache/iotdb/procedure/ProcedureExecutor.java | 995 +++++++++++++++++++++
.../apache/iotdb/procedure/ProcedureLockState.java | 11 +-
.../apache/iotdb/procedure/RootProcedureStack.java | 177 ++++
.../iotdb/procedure/StateMachineProcedure.java | 329 +++++++
.../apache/iotdb/procedure/StoppableThread.java | 36 +-
.../iotdb/procedure/TimeoutExecutorThread.java | 107 +++
.../iotdb/procedure/conf/ProcedureNodeConfig.java | 153 ++++
.../conf/ProcedureNodeConfigDescriptor.java | 144 +--
.../procedure/conf/ProcedureNodeConstant.java | 29 +-
.../procedure/env/ClusterProcedureEnvironment.java | 7 +-
.../exception/ProcedureAbortedException.java | 12 +-
.../procedure/exception/ProcedureException.java | 30 +-
.../exception/ProcedureSuspendedException.java | 25 +-
.../exception/ProcedureTimeoutException.java | 9 +-
.../exception/ProcedureYieldException.java | 19 +-
.../scheduler/AbstractProcedureScheduler.java | 211 +++++
.../procedure/scheduler/ProcedureScheduler.java | 109 +++
.../scheduler/SimpleProcedureScheduler.java | 78 ++
.../iotdb/procedure/service/ProcedureNode.java | 69 +-
.../procedure/service/ProcedureNodeMBean.java | 4 +-
.../iotdb/procedure/service/ProcedureServer.java | 118 +++
.../service/ProcedureServerCommandLine.java | 52 ++
.../service/ProcedureServerProcessor.java | 77 ++
.../procedure/service/ProcedureServiceHanlder.java | 46 +-
.../iotdb/procedure/store/IProcedureStore.java | 49 +-
.../iotdb/procedure/store/ProcedureStore.java | 195 ++++
.../apache/iotdb/procedure/store/ProcedureWAL.java | 106 +++
.../apache/iotdb/procedure/NoopProcedureStore.java | 49 +-
.../org/apache/iotdb/procedure/TestLockRegime.java | 30 +-
.../org/apache/iotdb/procedure/TestProcEnv.java | 57 ++
.../apache/iotdb/procedure/TestProcedureBase.java | 83 ++
.../iotdb/procedure/TestProcedureExecutor.java | 111 +++
.../apache/iotdb/procedure/TestSTMProcedure.java | 57 ++
.../iotdb/procedure/entity/IncProcedure.java | 57 ++
.../iotdb/procedure/entity/NoopProcedure.java | 27 +-
.../procedure/entity/SimpleLockProcedure.java | 80 ++
.../iotdb/procedure/entity/SimpleSTMProcedure.java | 97 ++
.../iotdb/procedure/entity/SleepProcedure.java | 31 +-
.../iotdb/procedure/entity/StuckProcedure.java | 59 ++
.../iotdb/procedure/entity/StuckSTMProcedure.java | 112 +++
.../procedure/service/TestProcedureService.java | 87 ++
.../iotdb/procedure/store/TestProcedureStore.java | 111 +++
.../iotdb/procedure/util/ProcedureTestUtil.java | 66 ++
server/pom.xml | 19 +-
.../resources/conf/iotdb-engine.properties | 18 +
.../resources/conf/schema-rocksdb.properties | 94 ++
.../resources/tools/schema/SchemaFileSketcher.sh | 2 +-
.../assembly/resources/tools/schema/mLogParser.sh | 2 +-
.../db/auth/authorizer/AuthorizerManager.java | 71 +-
.../db/auth/authorizer/ClusterAuthorizer.java | 111 ++-
.../apache/iotdb/db/client/ConfigNodeClient.java | 61 +-
.../iotdb/db/client/DataNodeClientPoolFactory.java | 148 +++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 80 ++
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 33 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 22 +
.../apache/iotdb/db/consensus/ConsensusImpl.java | 4 +-
.../statemachine/DataRegionStateMachine.java | 19 +
.../statemachine/SchemaRegionStateMachine.java | 24 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 11 -
.../apache/iotdb/db/engine/StorageEngineV2.java | 11 +
.../engine/compaction/CompactionTaskManager.java | 28 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 27 +-
.../io/LocalTextModificationAccessor.java | 7 +-
.../db/engine/storagegroup/TsFileProcessor.java | 4 +-
.../db/engine/storagegroup/TsFileResource.java | 6 +-
.../LocalConfigNode.java | 144 +--
.../localconfignode/LocalDataPartitionTable.java | 126 +++
.../LocalSchemaPartitionTable.java | 62 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 46 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 186 ++++
.../iotdb/db/metadata/cache/SchemaCacheEntity.java | 114 +++
.../db/metadata/mnode/IStorageGroupMNode.java | 12 +
.../db/metadata/mnode/StorageGroupEntityMNode.java | 18 +
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 43 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 308 +++++++
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 9 +
...reeBelowSG.java => MTreeBelowSGCachedImpl.java} | 222 +++--
...reeBelowSG.java => MTreeBelowSGMemoryImpl.java} | 942 ++++++++-----------
.../mtree/store/disk/CachedMNodeContainer.java | 15 +
.../mtree/store/disk/cache/CacheManager.java | 35 +-
.../mtree/store/disk/schemafile/RecordUtils.java | 6 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 72 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 269 ------
.../iotdb/db/metadata/path/MeasurementPath.java | 197 ----
.../apache/iotdb/db/metadata/path/PartialPath.java | 96 --
.../db/metadata/schemaregion/ISchemaRegion.java | 247 ++++-
.../db/metadata/schemaregion/SchemaEngine.java | 69 +-
...hemaRegion.java => SchemaRegionMemoryImpl.java} | 677 ++++++--------
...Region.java => SchemaRegionSchemaFileImpl.java} | 199 ++---
.../schemaregion/rocksdb/RSchemaConfLoader.java | 185 ++++
.../rocksdb/RSchemaReadWriteHandler.java | 27 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 207 ++---
.../rocksdb/mnode/RStorageGroupMNode.java | 18 +
.../db/metadata/tree/AbstractTreeVisitor.java | 376 ++++++++
.../tree/AbstractTreeVisitorWithLimitOffset.java | 106 +++
.../apache/iotdb/db/metadata/tree/ITreeNode.java | 7 +-
.../db/metadata/upgrade/MetadataUpgrader.java | 41 +-
.../ResourceByPathUtils.java} | 535 ++++++-----
.../SchemaExecutionVisitor.java} | 59 +-
.../iotdb/db/mpp/buffer/DataBlockManager.java | 87 +-
.../iotdb/db/mpp/buffer/DataBlockService.java | 13 +-
.../mpp/buffer/DataBlockServiceClientFactory.java | 117 ---
.../iotdb/db/mpp/buffer/IDataBlockManager.java | 11 +-
.../buffer/IDataBlockManagerCallback.java} | 7 +-
.../apache/iotdb/db/mpp/buffer/ISinkHandle.java | 30 +-
.../apache/iotdb/db/mpp/buffer/ISourceHandle.java | 20 +-
.../org/apache/iotdb/db/mpp/buffer/SinkHandle.java | 129 ++-
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 92 +-
.../iotdb/db/mpp/common/MPPQueryContext.java | 27 +-
.../iotdb/db/mpp/common/ResultNodeContext.java | 8 +-
.../iotdb/db/mpp/common/filter/InFilter.java | 8 +-
.../iotdb/db/mpp/common/header/DatasetHeader.java | 13 +-
.../iotdb/db/mpp/common/header/HeaderConstant.java | 40 +
.../db/mpp/common/schematree/DeviceSchemaInfo.java | 40 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 34 +-
.../mpp/common/schematree/SchemaTreeVisitor.java | 235 -----
.../schematree/{ => node}/SchemaEntityNode.java | 2 +-
.../schematree/{ => node}/SchemaInternalNode.java | 2 +-
.../{ => node}/SchemaMeasurementNode.java | 2 +-
.../common/schematree/{ => node}/SchemaNode.java | 6 +-
.../visitor/SchemaTreeDeviceVisitor.java | 61 ++
.../visitor/SchemaTreeMeasurementVisitor.java | 80 ++
.../schematree/visitor/SchemaTreeVisitor.java | 60 ++
.../apache/iotdb/db/mpp/execution/Coordinator.java | 58 +-
.../apache/iotdb/db/mpp/execution/DataDriver.java | 193 +---
.../org/apache/iotdb/db/mpp/execution/Driver.java | 440 ++++++++-
.../iotdb/db/mpp/execution/DriverContext.java | 13 +-
.../db/mpp/execution/FragmentInstanceContext.java | 98 +-
.../mpp/execution/FragmentInstanceExecution.java | 74 +-
...k.java => FragmentInstanceFailureListener.java} | 9 +-
.../db/mpp/execution/FragmentInstanceManager.java | 63 +-
.../db/mpp/execution/FragmentInstanceState.java | 2 +-
.../execution/FragmentInstanceStateMachine.java | 182 ++++
.../db/mpp/execution/{Driver.java => IDriver.java} | 31 +-
.../iotdb/db/mpp/execution/QueryExecution.java | 51 +-
.../iotdb/db/mpp/execution/SchemaDriver.java | 140 +--
.../mpp/execution/config/AuthorizerConfigTask.java | 41 +-
.../db/mpp/execution/config/ConfigExecution.java | 47 +-
.../db/mpp/execution/config/ConfigTaskResult.java | 61 ++
.../db/mpp/execution/config/ConfigTaskVisitor.java | 15 +
.../iotdb/db/mpp/execution/config/IConfigTask.java | 2 +-
.../db/mpp/execution/config/SampleConfigTask.java | 47 -
.../mpp/execution/config/SetStorageGroupTask.java | 70 +-
.../mpp/execution/config/ShowStorageGroupTask.java | 113 +++
.../scheduler/AbstractFragInsStateTracker.java | 47 +-
.../mpp/execution/scheduler/ClusterScheduler.java | 15 +-
.../scheduler/FixedRateFragInsStateTracker.java | 16 +-
.../scheduler/InternalServiceClientFactory.java | 112 ---
.../scheduler/SimpleFragInstanceDispatcher.java | 68 +-
.../execution/scheduler/SimpleQueryTerminator.java | 53 +-
.../execution/scheduler/StandaloneScheduler.java | 63 +-
.../org/apache/iotdb/db/mpp/operator/Operator.java | 4 +-
.../mpp/operator/process/DeviceMergeOperator.java | 56 --
.../mpp/operator/process/DeviceViewOperator.java | 152 ++++
.../db/mpp/operator/process/FilterOperator.java | 155 ++++
.../db/mpp/operator/process/LimitOperator.java | 4 +-
.../db/mpp/operator/process/TimeJoinOperator.java | 59 +-
.../db/mpp/operator/process/TransformOperator.java | 127 +--
.../mpp/operator/process/merge/ColumnMerger.java | 60 ++
.../operator/process/merge/MultiColumnMerger.java | 96 ++
.../operator/process/merge/SingleColumnMerger.java | 124 +++
.../db/mpp/operator/schema/CountMergeOperator.java | 133 +++
.../mpp/operator/schema/DevicesCountOperator.java | 90 ++
.../operator/schema/DevicesSchemaScanOperator.java | 20 +-
.../schema/LevelTimeSeriesCountOperator.java | 100 +++
.../mpp/operator/schema/SchemaFetchOperator.java | 3 +-
.../mpp/operator/schema/SchemaMergeOperator.java | 31 +-
.../operator/schema/TimeSeriesCountOperator.java | 90 ++
.../schema/TimeSeriesSchemaScanOperator.java | 17 +-
.../db/mpp/operator/source/ExchangeOperator.java | 11 +-
.../source/SeriesAggregateScanOperator.java | 6 +-
...ractExecutor.java => AbstractDriverThread.java} | 19 +-
...InstanceScheduler.java => DriverScheduler.java} | 139 +--
...anceTaskExecutor.java => DriverTaskThread.java} | 17 +-
...l.java => DriverTaskTimeoutSentinelThread.java} | 13 +-
.../iotdb/db/mpp/schedule/ExecutionContext.java | 4 +-
.../FragmentInstanceAbortedException.java} | 35 +-
...nstanceScheduler.java => IDriverScheduler.java} | 11 +-
.../iotdb/db/mpp/schedule/ITaskScheduler.java | 35 +-
.../db/mpp/schedule/queue/L1PriorityQueue.java | 37 +-
.../db/mpp/schedule/queue/L2PriorityQueue.java | 66 +-
.../{FragmentInstanceTask.java => DriverTask.java} | 64 +-
...agmentInstanceTaskID.java => DriverTaskID.java} | 16 +-
...stanceTaskStatus.java => DriverTaskStatus.java} | 4 +-
.../apache/iotdb/db/mpp/sql/analyze/Analysis.java | 4 +-
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 417 +++------
.../mpp/sql/analyze/ClusterPartitionFetcher.java | 472 ++++++++--
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 6 +-
.../mpp/sql/analyze/FakePartitionFetcherImpl.java | 125 ++-
.../db/mpp/sql/analyze/FakeSchemaFetcherImpl.java | 7 +-
.../db/mpp/sql/analyze/IPartitionFetcher.java | 4 +
.../iotdb/db/mpp/sql/analyze/SchemaValidator.java | 57 ++
.../sql/analyze/StandalonePartitionFetcher.java | 74 +-
.../mpp/sql/analyze/StandaloneSchemaFetcher.java | 38 +-
.../iotdb/db/mpp/sql/constant/StatementType.java | 4 +-
.../apache/iotdb/db/mpp/sql/parser/ASTVisitor.java | 225 ++++-
.../db/mpp/sql/parser/StatementGenerator.java | 25 +-
.../db/mpp/sql/planner/DistributionPlanner.java | 88 +-
.../{plan => }/IFragmentParallelPlaner.java | 4 +-
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 129 ++-
.../iotdb/db/mpp/sql/planner/LogicalPlanner.java | 289 ++----
.../iotdb/db/mpp/sql/planner/QueryPlanBuilder.java | 43 +-
.../{plan => }/SimpleFragmentParallelPlanner.java | 18 +-
.../{plan => }/WriteFragmentParallelPlanner.java | 5 +-
.../db/mpp/sql/planner/plan/FragmentInstance.java | 46 +-
.../db/mpp/sql/planner/plan/PlanFragment.java | 8 +-
.../sql/planner/plan/node/PlanGraphPrinter.java | 2 +-
.../db/mpp/sql/planner/plan/node/PlanNode.java | 8 +
.../db/mpp/sql/planner/plan/node/PlanNodeId.java | 16 -
.../db/mpp/sql/planner/plan/node/PlanNodeType.java | 44 +-
.../db/mpp/sql/planner/plan/node/PlanVisitor.java | 35 +-
.../mpp/sql/planner/plan/node/WritePlanNode.java | 4 +-
...MergeNode.java => AbstractSchemaMergeNode.java} | 50 +-
...emaMergeNode.java => CountSchemaMergeNode.java} | 45 +-
...esSchemaScanNode.java => DevicesCountNode.java} | 75 +-
.../node/metedata/read/DevicesSchemaScanNode.java | 29 +-
...ScanNode.java => LevelTimeSeriesCountNode.java} | 67 +-
.../plan/node/metedata/read/SchemaFetchNode.java | 20 +-
.../plan/node/metedata/read/SchemaScanNode.java | 36 +-
...maMergeNode.java => SeriesSchemaMergeNode.java} | 33 +-
...chemaScanNode.java => TimeSeriesCountNode.java} | 75 +-
.../metedata/read/TimeSeriesSchemaScanNode.java | 23 +-
.../node/metedata/write/AlterTimeSeriesNode.java | 147 ++-
.../plan/node/metedata/write/AuthorNode.java | 351 --------
.../write/CreateAlignedTimeSeriesNode.java | 145 +--
.../node/metedata/write/CreateTimeSeriesNode.java | 41 +-
.../planner/plan/node/process/AggregateNode.java | 31 +-
.../planner/plan/node/process/DeviceMergeNode.java | 53 +-
.../planner/plan/node/process/ExchangeNode.java | 30 +-
.../sql/planner/plan/node/process/FillNode.java | 9 +-
.../sql/planner/plan/node/process/FilterNode.java | 10 +-
.../planner/plan/node/process/FilterNullNode.java | 81 +-
.../plan/node/process/GroupByLevelNode.java | 82 +-
.../sql/planner/plan/node/process/LimitNode.java | 9 +-
.../sql/planner/plan/node/process/OffsetNode.java | 9 +-
.../sql/planner/plan/node/process/SortNode.java | 11 +-
.../planner/plan/node/process/TimeJoinNode.java | 116 ++-
.../planner/plan/node/sink/FragmentSinkNode.java | 30 +-
.../plan/node/source/SeriesAggregateScanNode.java | 50 +-
.../planner/plan/node/source/SeriesScanNode.java | 37 +-
.../sql/planner/plan/node/source/SourceNode.java | 6 +-
.../plan/node/write/InsertMultiTabletsNode.java | 118 ++-
.../sql/planner/plan/node/write/InsertNode.java | 123 ++-
.../sql/planner/plan/node/write/InsertRowNode.java | 410 ++++++---
.../planner/plan/node/write/InsertRowsNode.java | 116 ++-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 96 +-
.../planner/plan/node/write/InsertTabletNode.java | 566 ++++++------
.../Aggregation.java} | 21 +-
.../planner/plan/parameter/AggregationStep.java | 73 ++
.../plan/parameter/FilterNullParameter.java | 88 ++
.../plan/parameter/GroupByTimeParameter.java} | 81 +-
.../plan/{ => parameter}/InputLocation.java | 35 +-
.../planner/plan/{ => parameter}/OutputColumn.java | 38 +-
.../db/mpp/sql/rewriter/ConcatPathRewriter.java | 11 +-
.../db/mpp/sql/rewriter/WildcardsRemover.java | 16 +-
...{ConfigStatement.java => IConfigStatement.java} | 12 +-
.../db/mpp/sql/statement/StatementVisitor.java | 109 +--
.../statement/component/FilterNullComponent.java | 5 +-
.../component/GroupByLevelController.java | 10 +-
.../statement/component/GroupByTimeComponent.java | 73 --
.../mpp/sql/statement/component/ResultColumn.java | 2 +-
.../sql/statement/component/SelectComponent.java | 4 +-
.../statement/crud/AggregationQueryStatement.java | 13 +-
.../crud/BatchInsert.java} | 15 +-
.../sql/statement/crud/InsertBaseStatement.java | 31 -
.../crud/InsertMultiTabletsStatement.java | 11 -
.../mpp/sql/statement/crud/InsertRowStatement.java | 103 +--
.../crud/InsertRowsOfOneDeviceStatement.java | 36 +-
.../sql/statement/crud/InsertRowsStatement.java | 18 -
.../sql/statement/crud/InsertTabletStatement.java | 51 +-
.../mpp/sql/statement/crud/LastQueryStatement.java | 2 +-
.../db/mpp/sql/statement/crud/QueryStatement.java | 21 +-
.../mpp/sql/statement/crud/UDAFQueryStatement.java | 2 +-
...upStatement.java => CountDevicesStatement.java} | 23 +-
...ent.java => CountLevelTimeSeriesStatement.java} | 24 +-
.../statement/metadata/CountNodesStatement.java} | 14 +-
...rageGroupStatement.java => CountStatement.java} | 26 +-
.../metadata/CountStorageGroupStatement.java} | 13 +-
...tatement.java => CountTimeSeriesStatement.java} | 23 +-
.../metadata/SetStorageGroupStatement.java | 11 +-
.../metadata/ShowStorageGroupStatement.java | 9 +-
.../db/mpp/sql/statement/sys/AuthorStatement.java | 36 +-
.../protocol/influxdb/function/InfluxFunction.java | 2 +-
.../influxdb/function/InfluxFunctionFactory.java | 8 +-
.../db/protocol/influxdb/handler/QueryHandler.java | 4 +-
.../protocol/influxdb/input/InfluxLineParser.java | 5 +-
.../influxdb/operator/InfluxSelectComponent.java | 4 +-
.../protocol/influxdb/sql/InfluxDBSqlVisitor.java | 7 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 29 +-
.../qp/logical/crud/AggregationQueryOperator.java | 4 +-
.../db/qp/logical/crud/LastQueryOperator.java | 2 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 4 +-
.../iotdb/db/qp/logical/crud/SelectComponent.java | 4 +-
.../db/qp/logical/crud/UDAFQueryOperator.java | 4 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 9 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 28 +-
.../db/qp/physical/crud/InsertTabletPlan.java | 69 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 2 +-
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 12 +
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 140 +--
.../iotdb/db/qp/strategy/LogicalGenerator.java | 2 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 2 +-
.../iotdb/db/qp/utils/GroupByLevelController.java | 2 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 4 +-
.../iotdb/db/query/executor/QueryRouter.java | 7 +-
.../db/query/executor/RawDataQueryExecutor.java | 7 +-
.../iotdb/db/query/expression/Expression.java | 133 ++-
.../iotdb/db/query/expression/ExpressionType.java | 120 +--
.../iotdb/db/query/expression/ResultColumn.java | 21 +-
.../expression/binary/AdditionExpression.java | 19 +-
.../query/expression/binary/BinaryExpression.java | 17 +-
.../expression/binary/DivisionExpression.java | 19 +-
.../query/expression/binary/EqualToExpression.java | 20 +-
.../expression/binary/GreaterEqualExpression.java | 19 +-
.../expression/binary/GreaterThanExpression.java | 20 +-
.../expression/binary/LessEqualExpression.java | 19 +-
.../expression/binary/LessThanExpression.java | 19 +-
.../expression/binary/LogicAndExpression.java | 20 +-
.../query/expression/binary/LogicOrExpression.java | 20 +-
.../query/expression/binary/ModuloExpression.java | 19 +-
.../binary/MultiplicationExpression.java | 19 +-
.../expression/binary/NonEqualExpression.java | 19 +-
.../expression/binary/SubtractionExpression.java | 19 +-
.../{unary => leaf}/ConstantOperand.java | 49 +-
.../db/query/expression/leaf/LeafOperand.java | 25 +-
.../{unary => leaf}/TimeSeriesOperand.java | 38 +-
.../{unary => multi}/FunctionExpression.java | 48 +-
.../db/query/expression/unary/InExpression.java | 86 ++
.../db/query/expression/unary/LikeExpression.java | 69 ++
.../query/expression/unary/LogicNotExpression.java | 186 +---
.../query/expression/unary/NegationExpression.java | 188 +---
.../query/expression/unary/RegularExpression.java | 81 ++
...ogicNotExpression.java => UnaryExpression.java} | 138 ++-
.../db/query/factory/AggregateResultFactory.java | 17 +-
.../query/reader/series/SeriesAggregateReader.java | 20 +-
.../reader/series/SeriesRawDataBatchReader.java | 39 +-
.../reader/series/SeriesReaderByTimestamp.java | 6 +-
.../api/customizer/parameter/UDFParameters.java | 2 +-
.../db/query/udf/builtin/BuiltinFunction.java | 5 +-
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 487 ++++++++++
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 238 +++++
.../builtin/UDTFEqualSizeBucketRandomSample.java | 68 ++
.../udf/builtin/UDTFEqualSizeBucketSample.java | 48 +
.../db/query/udf/core/executor/UDTFContext.java | 2 +-
.../db/query/udf/core/executor/UDTFExecutor.java | 2 +-
.../udf/core/layer/ConstantIntermediateLayer.java | 2 +-
.../query/udf/core/layer/LayerMemoryAssigner.java | 2 +-
.../udf/core/reader/ConstantLayerPointReader.java | 2 +-
.../query/udf/service/UDFRegistrationService.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 189 +++-
.../iotdb/db/service/InfluxDBRPCService.java | 5 -
.../apache/iotdb/db/service/InternalService.java | 5 -
.../java/org/apache/iotdb/db/service/IoTDB.java | 18 +-
.../org/apache/iotdb/db/service/RPCService.java | 5 -
.../iotdb/db/service/metrics/MetricsService.java | 4 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 71 +-
.../service/thrift/impl/InternalServiceImpl.java | 60 +-
.../apache/iotdb/db/sync/conf/SyncConstant.java | 54 +-
.../apache/iotdb/db/sync/conf/SyncPathUtil.java | 81 +-
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 2 +-
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 34 +-
.../db/sync/pipedata/queue/PipeDataQueue.java | 2 +
.../iotdb/db/sync/receiver/ReceiverService.java | 70 +-
.../db/sync/receiver/collector/Collector.java | 4 +-
.../db/sync/receiver/manager/ReceiverManager.java | 130 +--
.../db/sync/receiver/recovery/ReceiverLog.java | 20 +-
.../receiver/recovery/ReceiverLogAnalyzer.java | 34 +-
.../db/sync/sender/manager/SchemaSyncManager.java | 24 +-
.../iotdb/db/sync/sender/pipe/IoTDBPipeSink.java | 18 +
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 10 +
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 61 +-
.../db/sync/sender/recovery/SenderLogAnalyzer.java | 25 +-
.../db/sync/sender/recovery/SenderLogger.java | 12 +-
.../db/sync/sender/recovery/TsFilePipeLogger.java | 2 +-
.../iotdb/db/sync/sender/service/MsgManager.java | 114 +++
.../db/sync/sender/service/SenderService.java | 83 +-
.../db/sync/sender/service/TransportHandler.java | 47 +-
.../db/sync/transport/client/TransportClient.java | 56 +-
.../transport/server/TransportServerManager.java | 5 -
.../transport/server/TransportServiceImpl.java | 63 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 6 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 87 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 128 +--
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 6 +-
.../db/wal/recover/file/TsFilePlanRedoer.java | 19 +-
.../apache/iotdb/db/wal/utils/WALWriteUtils.java | 42 +
.../db/engine/cache/BloomFilterCacheTest.java | 5 +-
.../compaction/inner/InnerCompactionTest.java | 20 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 2 +-
.../db/engine/storagegroup/DataRegionTest.java | 44 +-
.../engine/storagegroup/TsFileProcessorV2Test.java | 25 +-
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 95 ++
.../apache/iotdb/db/metadata/mnode/MNodeTest.java | 4 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 18 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 7 +-
.../db/metadata/mtree/schemafile/SegmentTest.java | 5 +-
.../schemaregion/rocksdb/MRocksDBUnitTest.java | 29 +-
.../rocksdb/RSchemaRegionAdvancedTest.java | 4 +-
.../db/metadata/upgrade/MetadataUpgradeTest.java | 7 +
.../apache/iotdb/db/mpp/buffer/SinkHandleTest.java | 200 +++--
.../iotdb/db/mpp/buffer/SourceHandleTest.java | 199 +++--
.../apache/iotdb/db/mpp/buffer/StubSinkHandle.java | 14 +-
.../db/mpp/common/schematree/SchemaTreeTest.java | 171 +++-
.../db/mpp/execution/ConfigExecutionTest.java | 87 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 39 +-
...eratorTest.java => DeviceViewOperatorTest.java} | 134 +--
.../iotdb/db/mpp/operator/LimitOperatorTest.java | 26 +-
.../db/mpp/operator/MultiColumnMergerTest.java | 208 +++++
.../operator/SeriesAggregateScanOperatorTest.java | 31 +-
.../db/mpp/operator/SeriesScanOperatorTest.java | 19 +-
.../db/mpp/operator/SingleColumnMergerTest.java | 209 +++++
.../db/mpp/operator/TimeJoinOperatorTest.java | 148 ++-
.../operator/schema/CountMergeOperatorTest.java | 193 ++++
.../operator/schema/SchemaCountOperatorTest.java | 231 +++++
.../operator/schema/SchemaFetchOperatorTest.java | 2 +-
.../operator/schema/SchemaScanOperatorTest.java | 37 +-
.../db/mpp/schedule/DefaultTaskSchedulerTest.java | 203 +++--
...SchedulerTest.java => DriverSchedulerTest.java} | 84 +-
...va => DriverTaskTimeoutSentinelThreadTest.java} | 182 ++--
.../db/mpp/schedule/queue/L1PriorityQueueTest.java | 22 +
.../db/mpp/schedule/queue/L2PriorityQueueTest.java | 27 +
.../db/mpp/sql/plan/DistributionPlannerTest.java | 214 +++--
.../db/mpp/sql/plan/FragmentInstanceIdTest.java | 2 +-
.../db/mpp/sql/plan/FragmentInstanceSerdeTest.java | 61 +-
.../iotdb/db/mpp/sql/plan/LogicalPlanPrinter.java | 11 +-
.../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 441 +--------
.../iotdb/db/mpp/sql/plan/QueryPlannerTest.java | 35 +-
.../read/DeviceSchemaScanNodeSerdeTest.java | 13 +-
.../metadata/read/SchemaCountNodeSerdeTest.java | 92 ++
.../read/TimeSeriesSchemaScanNodeSerdeTest.java | 13 +-
.../plan/node/process/AggregateNodeSerdeTest.java | 10 +-
.../node/process/DeviceMergeNodeSerdeTest.java | 13 +-
.../plan/node/process/ExchangeNodeSerdeTest.java | 19 +-
.../sql/plan/node/process/FillNodeSerdeTest.java | 14 +-
.../sql/plan/node/process/FilterNodeSerdeTest.java | 14 +-
.../plan/node/process/FilterNullNodeSerdeTest.java | 19 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 21 +-
.../sql/plan/node/process/LimitNodeSerdeTest.java | 21 +-
.../sql/plan/node/process/OffsetNodeSerdeTest.java | 38 +-
.../sql/plan/node/process/SortNodeSerdeTest.java | 19 +-
.../plan/node/process/TimeJoinNodeSerdeTest.java | 23 +-
.../plan/node/sink/FragmentSinkNodeSerdeTest.java | 6 +-
.../source/SeriesAggregateScanNodeSerdeTest.java | 16 +-
.../plan/node/source/SeriesScanNodeSerdeTest.java | 10 +-
.../write/InsertMultiTabletsNodeSerdeTest.java | 101 +++
.../plan/node/write/InsertRowNodeSerdeTest.java | 136 ++-
.../plan/node/write/InsertRowsNodeSerdeTest.java | 72 ++
.../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 74 ++
.../plan/node/write/InsertTabletNodeSerdeTest.java | 98 +-
.../influxdb/sql/InfluxDBLogicalGeneratorTest.java | 8 +-
.../db/protocol/mqtt/PayloadFormatManagerTest.java | 2 +-
.../iotdb/db/protocol/mqtt/PublishHandlerTest.java | 14 +-
.../iotdb/db/qp/physical/SerializedSizeTest.java | 2 +-
.../dataset/EngineDataSetWithValueFilterTest.java | 5 +-
.../SerializableBinaryTVListTest.java | 3 +-
.../datastructure/SerializableFloatTVListTest.java | 3 +-
.../datastructure/SerializableIntTVListTest.java | 3 +-
.../datastructure/SerializableLongTVListTest.java | 3 +-
.../valuefilter/RawQueryWithValueFilterTest.java | 4 +-
.../iotdb/db/service/InternalServiceImplTest.java | 172 +++-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 29 +-
.../iotdb/db/sync/pipedata/PipeDataTest.java | 7 +-
.../sync/receiver/manager/ReceiverManagerTest.java | 14 +-
.../receiver/recovery/ReceiverLogAnalyzerTest.java | 23 +-
.../db/sync/transport/TransportServiceTest.java | 5 +-
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 8 +-
.../iotdb/db/utils/MathQueryDataSetUtilsTest.java | 2 +-
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 8 +-
.../org/apache/iotdb/db/wal/DisableWALTest.java | 2 +-
.../org/apache/iotdb/db/wal/WALManagerTest.java | 4 +-
.../iotdb/db/wal/buffer/WALBufferCommonTest.java | 3 +-
.../db/wal/checkpoint/CheckpointManagerTest.java | 4 +-
.../apache/iotdb/db/wal/io/CheckpointFileTest.java | 2 +-
.../org/apache/iotdb/db/wal/io/WALFileTest.java | 2 +-
.../apache/iotdb/db/wal/node/WALFakeNodeTest.java | 3 +-
.../db/wal/recover/WALRecoverManagerTest.java | 6 +-
.../file/SealedTsFileRecoverPerformerTest.java | 5 +-
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 4 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 5 +-
.../datanode1conf/iotdb-engine.properties} | 41 +-
.../test/resources/datanode1conf}/iotdb-metric.yml | 0
.../resources/datanode1conf}/logback.xml | 0
.../datanode2conf/iotdb-engine.properties} | 41 +-
.../test/resources/datanode2conf}/iotdb-metric.yml | 0
.../resources/datanode2conf}/logback.xml | 0
.../datanode3conf/iotdb-engine.properties} | 41 +-
.../test/resources/datanode3conf}/iotdb-metric.yml | 0
.../resources/datanode3conf}/logback.xml | 0
.../iotdb/rpc/ConfigNodeConnectionException.java | 11 +-
spark-iotdb-connector/pom.xml | 2 +-
.../java/org/apache/iotdb/db/sql/SingleNodeIT.java | 8 +-
thrift-cluster/pom.xml | 5 +
{thrift-cluster => thrift-commons}/pom.xml | 11 +-
.../src/main/thrift/common.thrift | 29 +-
thrift-confignode/pom.xml | 2 +-
.../src/main/thrift/confignode.thrift | 69 +-
{thrift-cluster => thrift-procedure}/pom.xml | 5 +-
.../src/main/thrift/procedure.thrift | 30 +-
thrift-sync/src/main/thrift/transport.thrift | 6 +-
thrift/pom.xml | 5 +
thrift/src/main/thrift/mpp.thrift | 7 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 18 +-
.../apache/iotdb/tsfile/read/common/TimeRange.java | 24 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 36 +-
.../common/block/column/BinaryColumnBuilder.java | 21 +-
.../common/block/column/BooleanColumnBuilder.java | 21 +-
.../read/common/block/column/ColumnBuilder.java | 17 +-
.../common/block/column/DoubleColumnBuilder.java | 21 +-
.../common/block/column/FloatColumnBuilder.java | 17 +-
.../read/common/block/column/IntColumnBuilder.java | 21 +-
.../common/block/column/LongColumnBuilder.java | 21 +-
.../read/common/block/column/NullColumn.java | 50 ++
.../block/column/RunLengthEncodedColumn.java | 16 +-
.../common/block/column/TimeColumnBuilder.java | 16 +-
.../read/controller/MetadataQuerierByFileImpl.java | 17 +-
.../query/dataset/DataSetWithoutTimeGenerator.java | 6 +-
.../tsfile/v2/read/TsFileSequenceReaderForV2.java | 17 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 4 -
.../tsfile/common/block/NullColumnUnitTest.java | 120 +++
.../iotdb/tsfile/common/block/TsBlockTest.java | 12 +-
.../tsfile/read/TsFileSequenceReaderTest.java | 47 +
.../iotdb/tsfile/read/common/BatchDataTest.java | 4 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 5 +-
zeppelin-interpreter/pom.xml | 1 -
754 files changed, 31352 insertions(+), 14492 deletions(-)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/ConfigNodeClientPoolFactory.java
rename confignode/src/main/java/org/apache/iotdb/confignode/{physical/PhysicalPlan.java => consensus/request/ConfigRequest.java} (50%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{physical/PhysicalPlanType.java => consensus/request/ConfigRequestType.java} (84%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{physical/sys/AuthorPlan.java => consensus/request/auth/AuthorReq.java} (67%)
copy confignode/src/main/java/org/apache/iotdb/confignode/{physical/sys/QueryDataNodeInfoPlan.java => consensus/request/read/GetDataNodeInfoReq.java} (76%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetOrCountStorageGroupReq.java
rename confignode/src/main/java/org/apache/iotdb/confignode/{physical/crud/GetOrCreateDataPartitionPlan.java => consensus/request/read/GetOrCreateDataPartitionReq.java} (67%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{physical/crud/GetOrCreateSchemaPartitionPlan.java => consensus/request/read/GetOrCreateSchemaPartitionReq.java} (66%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{physical/crud/CreateDataPartitionPlan.java => consensus/request/write/CreateDataPartitionReq.java} (59%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{physical/crud/CreateRegionsPlan.java => consensus/request/write/CreateRegionsReq.java} (63%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{physical/crud/CreateSchemaPartitionPlan.java => consensus/request/write/CreateSchemaPartitionReq.java} (59%)
copy confignode/src/main/java/org/apache/iotdb/confignode/{physical/sys/DeleteStorageGroupPlan.java => consensus/request/write/DeleteStorageGroupReq.java} (74%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{physical/sys/QueryDataNodeInfoPlan.java => consensus/request/write/RegisterDataNodeReq.java} (55%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/SetDataReplicationFactorReq.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/SetSchemaReplicationFactorReq.java
copy confignode/src/main/java/org/apache/iotdb/confignode/{physical/sys/SetStorageGroupPlan.java => consensus/request/write/SetStorageGroupReq.java} (59%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{physical/sys/SetStorageGroupPlan.java => consensus/request/write/SetTTLReq.java} (55%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/SetTimePartitionIntervalReq.java
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{PermissionInfoDataSet.java => CountStorageGroupResp.java} (67%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{DataNodeConfigurationDataSet.java => DataNodeConfigurationResp.java} (90%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{DataNodesInfoDataSet.java => DataNodeLocationsResp.java} (55%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataPartitionDataSet.java
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{DataNodeConfigurationDataSet.java => DataPartitionResp.java} (59%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{PermissionInfoDataSet.java => PermissionInfoResp.java} (89%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/SchemaPartitionDataSet.java
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{PermissionInfoDataSet.java => SchemaPartitionResp.java} (62%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{StorageGroupSchemaDataSet.java => StorageGroupSchemaResp.java} (67%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/RegionManager.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/partition/StorageGroupSchema.java
rename confignode/src/main/java/org/apache/iotdb/confignode/persistence/{AuthorInfoPersistence.java => AuthorInfo.java} (76%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/ClusterSchemaInfo.java
rename confignode/src/main/java/org/apache/iotdb/confignode/persistence/{DataNodeInfoPersistence.java => DataNodeInfo.java} (64%)
rename confignode/src/main/java/org/apache/iotdb/confignode/persistence/{PartitionInfoPersistence.java => PartitionInfo.java} (56%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/RegionInfoPersistence.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/RegisterDataNodePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/executor/ConfigRequestExecutor.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/executor/PlanExecutor.java
rename confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/{server/ConfigNodeRPCServer.java => ConfigNodeRPCService.java} (74%)
rename confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/{server => }/ConfigNodeRPCServiceHandler.java (89%)
copy confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/{server/ConfigNodeRPCServerMBean.java => ConfigNodeRPCServiceMBean.java} (88%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServerProcessor.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/consensus/RatisConsensusDemo.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigRequestSerDeTest.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/ConfigManagerManualTest.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/physical/SerializeDeserializeUT.java
rename confignode/src/test/java/org/apache/iotdb/confignode/service/thrift/{server/ConfigNodeRPCServerProcessorTest.java => ConfigNodeRPCServiceProcessorTest.java} (74%)
copy server/src/assembly/resources/tools/schema/mLogParser.sh => confignode/src/test/resources/confignode1conf/iotdb-confignode.properties (56%)
copy confignode/src/{assembly/resources/conf => test/resources/confignode1conf}/logback.xml (100%)
copy server/src/assembly/resources/tools/schema/mLogParser.sh => confignode/src/test/resources/confignode2conf/iotdb-confignode.properties (56%)
copy confignode/src/{assembly/resources/conf => test/resources/confignode2conf}/logback.xml (100%)
copy server/src/assembly/resources/tools/schema/mLogParser.sh => confignode/src/test/resources/confignode3conf/iotdb-confignode.properties (56%)
copy confignode/src/{assembly/resources/conf => test/resources/confignode3conf}/logback.xml (100%)
copy node-commons/src/main/java/org/apache/iotdb/commons/partition/SeriesPartitionSlot.java => consensus/src/main/java/org/apache/iotdb/consensus/common/SnapshotMeta.java (52%)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisClient.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/SnapshotStorage.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/ratis/SnapshotTest.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/ratis/TestUtils.java
create mode 100644 docs/UserGuide/Data-Modeling/SchemaRegion-rocksdb.md
create mode 100644 docs/zh/UserGuide/Data-Modeling/SchemaRegion-rocksdb.md
copy integration/src/test/java/org/apache/iotdb/db/integration/{IoTDBInIT.java => IoTDBInsertNullIT.java} (51%)
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/TransportHandlerMock.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/AsyncBaseClientFactory.java
copy confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/DeleteStorageGroupPlan.java => node-commons/src/main/java/org/apache/iotdb/commons/client/BaseClientFactory.java (54%)
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/ClientFactoryProperty.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/ClientManager.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/ClientPoolProperty.java
copy confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/DeleteStorageGroupPlan.java => node-commons/src/main/java/org/apache/iotdb/commons/client/IClientManager.java (60%)
copy server/src/main/java/org/apache/iotdb/db/metadata/mnode/IStorageGroupMNode.java => node-commons/src/main/java/org/apache/iotdb/commons/client/IClientPoolFactory.java (70%)
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/async/AsyncConfigNodeIServiceClient.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/async/AsyncDataNodeDataBlockServiceClient.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/async/AsyncDataNodeInternalServiceClient.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncConfigNodeIServiceClient.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeDataBlockServiceClient.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeInternalServiceClient.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/cluster/DataNodeLocation.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/cluster/Endpoint.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/config/IConfigTask.java => node-commons/src/main/java/org/apache/iotdb/commons/exception/runtime/ThriftSerDeException.java (79%)
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/RegionReplicaSet.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/TimePartitionSlot.java
rename confignode/src/main/java/org/apache/iotdb/confignode/util/SerializeDeserializeUtil.java => node-commons/src/main/java/org/apache/iotdb/commons/utils/BasicStructureSerDeUtil.java (98%)
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/utils/ThriftCommonsSerDeUtils.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/utils/ThriftConfigNodeSerDeUtils.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/ClientManagerTest.java
rename confignode/src/test/java/org/apache/iotdb/confignode/utils/SerializeDeserializeUtilTest.java => node-commons/src/test/java/org/apache/iotdb/commons/utils/BasicStructureSerDeUtilTest.java (82%)
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/utils/ThriftCommonsSerDeUtilsTest.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/utils/ThriftConfigNodeSerDeUtilsTest.java
copy {consensus => procedure}/pom.xml (51%)
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/CompletedProcedureCleaner.java
copy confignode/src/main/java/org/apache/iotdb/confignode/exception/physical/UnknownPhysicalPlanTypeException.java => procedure/src/main/java/org/apache/iotdb/procedure/CompletedProcedureRetainer.java (66%)
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/InternalProcedure.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/Procedure.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/ProcedureExecutor.java
rename node-commons/src/main/java/org/apache/iotdb/commons/consensus/GroupType.java => procedure/src/main/java/org/apache/iotdb/procedure/ProcedureLockState.java (80%)
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/RootProcedureStack.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/StateMachineProcedure.java
copy node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/hash/JSHashExecutor.java => procedure/src/main/java/org/apache/iotdb/procedure/StoppableThread.java (53%)
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/TimeoutExecutorThread.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/conf/ProcedureNodeConfig.java
copy confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeDescriptor.java => procedure/src/main/java/org/apache/iotdb/procedure/conf/ProcedureNodeConfigDescriptor.java (51%)
rename confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/DeleteStorageGroupPlan.java => procedure/src/main/java/org/apache/iotdb/procedure/conf/ProcedureNodeConstant.java (55%)
copy confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServerMBean.java => procedure/src/main/java/org/apache/iotdb/procedure/env/ClusterProcedureEnvironment.java (81%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/config/IConfigTask.java => procedure/src/main/java/org/apache/iotdb/procedure/exception/ProcedureAbortedException.java (77%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/WritePlanNode.java => procedure/src/main/java/org/apache/iotdb/procedure/exception/ProcedureException.java (65%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/IOutputPlanNode.java => procedure/src/main/java/org/apache/iotdb/procedure/exception/ProcedureSuspendedException.java (67%)
copy server/src/main/java/org/apache/iotdb/db/auth/authorizer/ClusterAuthorizer.java => procedure/src/main/java/org/apache/iotdb/procedure/exception/ProcedureTimeoutException.java (81%)
copy server/src/main/java/org/apache/iotdb/db/metadata/mnode/IStorageGroupMNode.java => procedure/src/main/java/org/apache/iotdb/procedure/exception/ProcedureYieldException.java (72%)
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/scheduler/AbstractProcedureScheduler.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/scheduler/ProcedureScheduler.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/scheduler/SimpleProcedureScheduler.java
copy confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNode.java => procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureNode.java (51%)
copy confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServerMBean.java => procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureNodeMBean.java (88%)
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureServer.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureServerCommandLine.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureServerProcessor.java
rename node-commons/src/main/java/org/apache/iotdb/commons/partition/SeriesPartitionSlot.java => procedure/src/main/java/org/apache/iotdb/procedure/service/ProcedureServiceHanlder.java (52%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/InputLocation.java => procedure/src/main/java/org/apache/iotdb/procedure/store/IProcedureStore.java (61%)
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/store/ProcedureStore.java
create mode 100644 procedure/src/main/java/org/apache/iotdb/procedure/store/ProcedureWAL.java
copy consensus/src/main/java/org/apache/iotdb/consensus/statemachine/EmptyStateMachine.java => procedure/src/test/java/org/apache/iotdb/procedure/NoopProcedureStore.java (50%)
copy server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceIdTest.java => procedure/src/test/java/org/apache/iotdb/procedure/TestLockRegime.java (51%)
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/TestProcEnv.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/TestProcedureBase.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/TestProcedureExecutor.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/TestSTMProcedure.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/entity/IncProcedure.java
copy consensus/src/main/java/org/apache/iotdb/consensus/statemachine/EmptyStateMachine.java => procedure/src/test/java/org/apache/iotdb/procedure/entity/NoopProcedure.java (54%)
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/entity/SimpleLockProcedure.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/entity/SimpleSTMProcedure.java
copy consensus/src/main/java/org/apache/iotdb/consensus/statemachine/EmptyStateMachine.java => procedure/src/test/java/org/apache/iotdb/procedure/entity/SleepProcedure.java (50%)
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/entity/StuckProcedure.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/entity/StuckSTMProcedure.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/service/TestProcedureService.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/store/TestProcedureStore.java
create mode 100644 procedure/src/test/java/org/apache/iotdb/procedure/util/ProcedureTestUtil.java
create mode 100644 server/src/assembly/resources/conf/schema-rocksdb.properties
create mode 100644 server/src/main/java/org/apache/iotdb/db/client/DataNodeClientPoolFactory.java
rename server/src/main/java/org/apache/iotdb/db/{metadata => localconfignode}/LocalConfigNode.java (87%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/localconfignode/LocalDataPartitionTable.java
rename server/src/main/java/org/apache/iotdb/db/{metadata => localconfignode}/LocalSchemaPartitionTable.java (69%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/DataNodeSchemaCache.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/SchemaCacheEntity.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/IMTreeBelowSG.java
copy server/src/main/java/org/apache/iotdb/db/metadata/mtree/{MTreeBelowSG.java => MTreeBelowSGCachedImpl.java} (92%)
rename server/src/main/java/org/apache/iotdb/db/metadata/mtree/{MTreeBelowSG.java => MTreeBelowSGMemoryImpl.java} (65%)
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/{SchemaRegion.java => SchemaRegionMemoryImpl.java} (77%)
rename server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/{SchemaRegion.java => SchemaRegionSchemaFileImpl.java} (92%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaConfLoader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/tree/AbstractTreeVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/tree/AbstractTreeVisitorWithLimitOffset.java
rename confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServerMBean.java => server/src/main/java/org/apache/iotdb/db/metadata/tree/ITreeNode.java (88%)
copy server/src/main/java/org/apache/iotdb/db/metadata/{path/AlignedPath.java => utils/ResourceByPathUtils.java} (51%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{Executor/SchemaVisitor.java => visitor/SchemaExecutionVisitor.java} (59%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockServiceClientFactory.java
copy server/src/main/java/org/apache/iotdb/db/{auth/authorizer/ClusterAuthorizer.java => mpp/buffer/IDataBlockManagerCallback.java} (87%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/SchemaTreeVisitor.java
rename server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/{ => node}/SchemaEntityNode.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/{ => node}/SchemaInternalNode.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/{ => node}/SchemaMeasurementNode.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/{ => node}/SchemaNode.java (92%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/visitor/SchemaTreeDeviceVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/visitor/SchemaTreeMeasurementVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/visitor/SchemaTreeVisitor.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/{config/IConfigTask.java => FragmentInstanceFailureListener.java} (78%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceStateMachine.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/{Driver.java => IDriver.java} (61%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/config/ConfigTaskResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/config/SampleConfigTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/config/ShowStorageGroupTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/InternalServiceClientFactory.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/DeviceMergeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/DeviceViewOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/FilterOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/merge/ColumnMerger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/merge/MultiColumnMerger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/merge/SingleColumnMerger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/CountMergeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/DevicesCountOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/LevelTimeSeriesCountOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/TimeSeriesCountOperator.java
rename server/src/main/java/org/apache/iotdb/db/mpp/schedule/{AbstractExecutor.java => AbstractDriverThread.java} (77%)
rename server/src/main/java/org/apache/iotdb/db/mpp/schedule/{FragmentInstanceScheduler.java => DriverScheduler.java} (63%)
rename server/src/main/java/org/apache/iotdb/db/mpp/schedule/{FragmentInstanceTaskExecutor.java => DriverTaskThread.java} (84%)
rename server/src/main/java/org/apache/iotdb/db/mpp/schedule/{FragmentInstanceTimeoutSentinel.java => DriverTaskTimeoutSentinelThread.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{execution/DriverContext.java => schedule/FragmentInstanceAbortedException.java} (55%)
rename server/src/main/java/org/apache/iotdb/db/mpp/schedule/{IFragmentInstanceScheduler.java => IDriverScheduler.java} (86%)
rename server/src/main/java/org/apache/iotdb/db/mpp/schedule/task/{FragmentInstanceTask.java => DriverTask.java} (76%)
rename server/src/main/java/org/apache/iotdb/db/mpp/schedule/task/{FragmentInstanceTaskID.java => DriverTaskID.java} (77%)
rename server/src/main/java/org/apache/iotdb/db/mpp/schedule/task/{FragmentInstanceTaskStatus.java => DriverTaskStatus.java} (92%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/SchemaValidator.java
rename server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/{plan => }/IFragmentParallelPlaner.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/{plan => }/SimpleFragmentParallelPlanner.java (88%)
rename server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/{plan => }/WriteFragmentParallelPlanner.java (91%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/{SchemaMergeNode.java => AbstractSchemaMergeNode.java} (60%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/{SchemaMergeNode.java => CountSchemaMergeNode.java} (57%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/{DevicesSchemaScanNode.java => DevicesCountNode.java} (50%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/{DevicesSchemaScanNode.java => LevelTimeSeriesCountNode.java} (56%)
rename server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/{SchemaMergeNode.java => SeriesSchemaMergeNode.java} (68%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/{DevicesSchemaScanNode.java => TimeSeriesCountNode.java} (50%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/AuthorNode.java
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/{IOutputPlanNode.java => parameter/Aggregation.java} (60%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/AggregationStep.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/FilterNullParameter.java
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/{statement/component/GroupByTimeComponent.java => planner/plan/parameter/GroupByTimeParameter.java} (75%)
rename server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/{ => parameter}/InputLocation.java (55%)
rename server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/{ => parameter}/OutputColumn.java (58%)
rename server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/{ConfigStatement.java => IConfigStatement.java} (81%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/{planner/plan/IOutputPlanNode.java => statement/crud/BatchInsert.java} (72%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/{ShowStorageGroupStatement.java => CountDevicesStatement.java} (69%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/{ShowStorageGroupStatement.java => CountLevelTimeSeriesStatement.java} (70%)
copy server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java => mpp/sql/statement/metadata/CountNodesStatement.java} (72%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/{ShowStorageGroupStatement.java => CountStatement.java} (64%)
copy server/src/main/java/org/apache/iotdb/db/{metadata/mnode/IStorageGroupMNode.java => mpp/sql/statement/metadata/CountStorageGroupStatement.java} (72%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/{ShowStorageGroupStatement.java => CountTimeSeriesStatement.java} (69%)
rename server/src/main/java/org/apache/iotdb/db/query/expression/{unary => leaf}/ConstantOperand.java (78%)
rename confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/QueryStorageGroupSchemaPlan.java => server/src/main/java/org/apache/iotdb/db/query/expression/leaf/LeafOperand.java (60%)
rename server/src/main/java/org/apache/iotdb/db/query/expression/{unary => leaf}/TimeSeriesOperand.java (83%)
rename server/src/main/java/org/apache/iotdb/db/query/expression/{unary => multi}/FunctionExpression.java (93%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/expression/unary/InExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/expression/unary/LikeExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/expression/unary/RegularExpression.java
copy server/src/main/java/org/apache/iotdb/db/query/expression/unary/{LogicNotExpression.java => UnaryExpression.java} (71%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFEqualSizeBucketAggSample.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFEqualSizeBucketM4Sample.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFEqualSizeBucketRandomSample.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFEqualSizeBucketSample.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/service/MsgManager.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/cache/DataNodeSchemaCacheTest.java
rename server/src/{main => test}/java/org/apache/iotdb/db/mpp/buffer/StubSinkHandle.java (88%)
copy server/src/test/java/org/apache/iotdb/db/mpp/operator/{LimitOperatorTest.java => DeviceViewOperatorTest.java} (53%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/MultiColumnMergerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/SingleColumnMergerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/schema/CountMergeOperatorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/schema/SchemaCountOperatorTest.java
rename server/src/test/java/org/apache/iotdb/db/mpp/schedule/{FragmentInstanceSchedulerTest.java => DriverSchedulerTest.java} (62%)
rename server/src/test/java/org/apache/iotdb/db/mpp/schedule/{FragmentInstanceTimeoutSentinelTest.java => DriverTaskTimeoutSentinelThreadTest.java} (53%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/SchemaCountNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertMultiTabletsNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertRowsNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertRowsOfOneDeviceNodeSerdeTest.java
copy server/src/{assembly/resources/tools/schema/mLogParser.sh => test/resources/datanode1conf/iotdb-engine.properties} (56%)
copy {cluster/src/test/resources/node1conf => server/src/test/resources/datanode1conf}/iotdb-metric.yml (100%)
copy server/src/{assembly/resources/conf => test/resources/datanode1conf}/logback.xml (100%)
copy server/src/{assembly/resources/tools/schema/mLogParser.sh => test/resources/datanode2conf/iotdb-engine.properties} (56%)
copy {cluster/src/test/resources/node1conf => server/src/test/resources/datanode2conf}/iotdb-metric.yml (100%)
copy server/src/{assembly/resources/conf => test/resources/datanode2conf}/logback.xml (100%)
copy server/src/{assembly/resources/tools/schema/mLogParser.sh => test/resources/datanode3conf/iotdb-engine.properties} (56%)
copy {cluster/src/test/resources/node1conf => server/src/test/resources/datanode3conf}/iotdb-metric.yml (100%)
copy server/src/{assembly/resources/conf => test/resources/datanode3conf}/logback.xml (100%)
copy server/src/main/java/org/apache/iotdb/db/auth/authorizer/ClusterAuthorizer.java => service-rpc/src/main/java/org/apache/iotdb/rpc/ConfigNodeConnectionException.java (76%)
copy {thrift-cluster => thrift-commons}/pom.xml (87%)
rename {thrift => thrift-commons}/src/main/thrift/common.thrift (65%)
copy {thrift-cluster => thrift-procedure}/pom.xml (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/IOutputPlanNode.java => thrift-procedure/src/main/thrift/procedure.thrift (65%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/NullColumn.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/NullColumnUnitTest.java