[IOTDB-2942] [IOTDB-2944] Delete duplicate data structure in node-commons and extend...
authorYongzaoDan <33111881+CRZbulabula@users.noreply.github.com>
Wed, 20 Apr 2022 14:47:33 +0000 (22:47 +0800)
committerGitHub <noreply@github.com>
Wed, 20 Apr 2022 14:47:33 +0000 (22:47 +0800)
commit7ce6033609f0df3c7b809dfc048c1bfcb47aefb7
tree333a79c4fd6ba3d6baa2543243535a0d2279976f
parentaadd8cae72ea71cde9fd3c67a7832e4e5409e7ef
[IOTDB-2942] [IOTDB-2944] Delete duplicate data structure in node-commons and extend TDataNodeLocation (#5592)
145 files changed:
client-cpp/pom.xml
client-py/pom.xml
confignode/pom.xml
confignode/src/assembly/resources/conf/iotdb-confignode.properties
confignode/src/main/java/org/apache/iotdb/confignode/cli/TemporaryClient.java
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConf.java
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeDescriptor.java
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeConfigurationDataSet.java
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeLocationsDataSet.java [moved from confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodesInfoDataSet.java with 55% similarity]
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataPartitionDataSet.java
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/SchemaPartitionDataSet.java
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/StorageGroupSchemaDataSet.java
confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
confignode/src/main/java/org/apache/iotdb/confignode/manager/ConsensusManager.java
confignode/src/main/java/org/apache/iotdb/confignode/manager/DataNodeManager.java
confignode/src/main/java/org/apache/iotdb/confignode/manager/PartitionManager.java
confignode/src/main/java/org/apache/iotdb/confignode/manager/RegionManager.java
confignode/src/main/java/org/apache/iotdb/confignode/partition/StorageGroupSchema.java [deleted file]
confignode/src/main/java/org/apache/iotdb/confignode/persistence/DataNodeInfoPersistence.java
confignode/src/main/java/org/apache/iotdb/confignode/persistence/PartitionInfoPersistence.java
confignode/src/main/java/org/apache/iotdb/confignode/persistence/RegionInfoPersistence.java
confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/CreateDataPartitionPlan.java
confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/CreateRegionsPlan.java
confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/CreateSchemaPartitionPlan.java
confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/GetOrCreateDataPartitionPlan.java
confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/GetOrCreateSchemaPartitionPlan.java
confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/AuthorPlan.java
confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/RegisterDataNodePlan.java
confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/SetStorageGroupPlan.java
confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServerProcessor.java
confignode/src/test/java/org/apache/iotdb/confignode/cli/TemporaryClientDemo.java
confignode/src/test/java/org/apache/iotdb/confignode/consensus/RatisConsensusDemo.java [deleted file]
confignode/src/test/java/org/apache/iotdb/confignode/manager/ConfigManagerManualTest.java [deleted file]
confignode/src/test/java/org/apache/iotdb/confignode/physical/PhysicalPlanSerDeTest.java [moved from confignode/src/test/java/org/apache/iotdb/confignode/physical/SerializeDeserializeUT.java with 73% similarity]
confignode/src/test/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServerProcessorTest.java
consensus/pom.xml
consensus/src/main/java/org/apache/iotdb/consensus/ConsensusFactory.java
consensus/src/main/java/org/apache/iotdb/consensus/common/Peer.java
consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java
consensus/src/main/java/org/apache/iotdb/consensus/ratis/RequestMessage.java
consensus/src/main/java/org/apache/iotdb/consensus/ratis/Utils.java
consensus/src/main/java/org/apache/iotdb/consensus/standalone/StandAloneConsensus.java
consensus/src/test/java/org/apache/iotdb/consensus/ratis/RatisConsensusTest.java
consensus/src/test/java/org/apache/iotdb/consensus/standalone/StandAloneConsensusTest.java
node-commons/pom.xml
node-commons/src/main/java/org/apache/iotdb/commons/cluster/DataNodeLocation.java [deleted file]
node-commons/src/main/java/org/apache/iotdb/commons/cluster/Endpoint.java [deleted file]
node-commons/src/main/java/org/apache/iotdb/commons/consensus/ConsensusGroupId.java
node-commons/src/main/java/org/apache/iotdb/commons/consensus/DataRegionId.java
node-commons/src/main/java/org/apache/iotdb/commons/consensus/GroupType.java [deleted file]
node-commons/src/main/java/org/apache/iotdb/commons/consensus/PartitionRegionId.java
node-commons/src/main/java/org/apache/iotdb/commons/consensus/SchemaRegionId.java
node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartitionQueryParam.java
node-commons/src/main/java/org/apache/iotdb/commons/partition/Partition.java
node-commons/src/main/java/org/apache/iotdb/commons/partition/RegionReplicaSet.java [deleted file]
node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaPartition.java
node-commons/src/main/java/org/apache/iotdb/commons/partition/SeriesPartitionSlot.java [deleted file]
node-commons/src/main/java/org/apache/iotdb/commons/partition/TimePartitionSlot.java [deleted file]
node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/SeriesPartitionExecutor.java
node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/hash/APHashExecutor.java
node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/hash/BKDRHashExecutor.java
node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/hash/JSHashExecutor.java
node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/hash/SDBMHashExecutor.java
node-commons/src/main/java/org/apache/iotdb/commons/utils/BasicStructureSerDeUtil.java [moved from confignode/src/main/java/org/apache/iotdb/confignode/util/SerializeDeserializeUtil.java with 98% similarity]
node-commons/src/main/java/org/apache/iotdb/commons/utils/CommonUtils.java
node-commons/src/main/java/org/apache/iotdb/commons/utils/ThriftCommonsSerDeUtils.java [new file with mode: 0644]
node-commons/src/main/java/org/apache/iotdb/commons/utils/ThriftConfigNodeSerDeUtils.java [new file with mode: 0644]
node-commons/src/test/java/org/apache/iotdb/commons/ConsensusGroupIdTest.java
node-commons/src/test/java/org/apache/iotdb/commons/utils/BasicStructureSerDeUtilTest.java [moved from confignode/src/test/java/org/apache/iotdb/confignode/utils/SerializeDeserializeUtilTest.java with 82% similarity]
node-commons/src/test/java/org/apache/iotdb/commons/utils/ThriftCommonsSerDeUtilsTest.java [new file with mode: 0644]
node-commons/src/test/java/org/apache/iotdb/commons/utils/ThriftConfigNodeSerDeUtilsTest.java [new file with mode: 0644]
pom.xml
server/pom.xml
server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java
server/src/main/java/org/apache/iotdb/db/consensus/ConsensusImpl.java
server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockManager.java
server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockServiceClientFactory.java
server/src/main/java/org/apache/iotdb/db/mpp/buffer/IDataBlockManager.java
server/src/main/java/org/apache/iotdb/db/mpp/common/MPPQueryContext.java
server/src/main/java/org/apache/iotdb/db/mpp/common/ResultNodeContext.java
server/src/main/java/org/apache/iotdb/db/mpp/execution/Coordinator.java
server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryExecution.java
server/src/main/java/org/apache/iotdb/db/mpp/execution/config/SetStorageGroupTask.java
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/AbstractFragInsStateTracker.java
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/InternalServiceClientFactory.java
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/SimpleFragInstanceDispatcher.java
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/SimpleQueryTerminator.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/Analysis.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/ClusterPartitionFetcher.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/ClusterSchemaFetcher.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/FakePartitionFetcherImpl.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/DistributionPlanner.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/LocalExecutionPlanner.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/FragmentInstance.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/PlanFragment.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/SimpleFragmentParallelPlanner.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanGraphPrinter.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/WritePlanNode.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/SchemaScanNode.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/CreateTimeSeriesNode.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/ExchangeNode.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/sink/FragmentSinkNode.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/SeriesAggregateScanNode.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/SeriesScanNode.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/SourceNode.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertMultiTabletsNode.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertNode.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertRowNode.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertRowsNode.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertRowsOfOneDeviceNode.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertTabletNode.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertRowStatement.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertRowsOfOneDeviceStatement.java
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertTabletStatement.java
server/src/main/java/org/apache/iotdb/db/service/DataNode.java
server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InternalServiceImpl.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/DistributionPlannerTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/QueryPlannerTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/DeviceSchemaScanNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/TimeSeriesSchemaScanNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/AggregateNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/DeviceMergeNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/ExchangeNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FillNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNullNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/GroupByLevelNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/LimitNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/OffsetNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/SortNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/TimeJoinNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/sink/FragmentSinkNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesAggregateScanNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesScanNodeSerdeTest.java
server/src/test/java/org/apache/iotdb/db/service/InternalServiceImplTest.java
thrift-cluster/pom.xml
thrift-commons/pom.xml [new file with mode: 0644]
thrift-commons/src/main/thrift/common.thrift [moved from thrift/src/main/thrift/common.thrift with 65% similarity]
thrift-confignode/pom.xml
thrift-confignode/src/main/thrift/confignode.thrift
thrift/pom.xml
thrift/src/main/thrift/mpp.thrift