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/03/25 02:08:50 UTC
[iotdb] branch xingtanzjr/add-internal-service updated (8437bef -> ccb0a95)
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch xingtanzjr/add-internal-service
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 8437bef use string to represent the state of FragmentInstance in thrift
add 6644f52 [IOTDB-2727] add interface for mock testing (#5326)
add 8710848 Fix the bug that FREQ does not support DOUBLE. (#5335)
add cef081c [IOTDB-2713] Analyze stage: define the schema fetcher interface (#5334)
add 84a55e7 Fragment instance implement IConsensusRequest (#5336)
add a9d7b17 [IOTDB-2798] Fix ConfigNode start process (#5340)
add 5829211 Merge branch 'master' into xingtanzjr/add-internal-service
add ccb0a95 rename ThriftFragmentInstanceId to TFragmentInstanceId
No new revisions were added by this update.
Summary of changes:
.../resources/conf/iotdb-confignode.properties | 7 +-
.../src/assembly/resources/conf/logback-tool.xml | 0
.../src/assembly/resources/conf}/logback.xml | 100 ++++++++++--------
.../assembly/resources/sbin/start-confignode.bat | 2 +
.../assembly/resources/sbin/start-confignode.sh | 2 +
.../iotdb/confignode/conf/ConfigNodeConf.java | 23 +++++
.../iotdb/confignode/conf/ConfigNodeConfCheck.java | 19 +++-
.../confignode/conf/ConfigNodeDescriptor.java | 4 +-
.../consensus/response/DataNodesInfoDataSet.java | 15 ++-
.../statemachine/PartitionRegionStateMachine.java | 2 +-
.../iotdb/confignode/partition/PartitionTable.java | 33 ++++--
.../confignode/service/ConfigNodeCommandLine.java | 10 +-
.../confignode/service/executor/PlanExecutor.java | 32 +-----
.../server/ConfigNodeRPCServerProcessor.java | 13 +--
.../apache/iotdb/commons/ServerCommandLine.java | 6 +-
.../consensus/statemachine/BaseStateMachine.java | 48 +++++----
.../statemachine/DataRegionStateMachine.java | 10 +-
.../statemachine/SchemaRegionStateMachine.java | 10 +-
.../iotdb/db/mpp/buffer/IDataBlockManager.java | 68 +++++++++++++
.../apache/iotdb/db/mpp/common/PlanFragmentId.java | 8 ++
.../org/apache/iotdb/db/mpp/common/QueryId.java | 7 ++
.../db/mpp/common/schematree/PathPatternNode.java | 9 +-
.../common/schematree/PathPatternTree.java} | 26 +++--
.../db/mpp/common/schematree/SchemaEntityNode.java | 7 +-
.../mpp/common/schematree/SchemaInternalNode.java | 8 +-
.../common/schematree/SchemaMeasurementNode.java | 10 +-
.../iotdb/db/mpp/common/schematree/SchemaNode.java | 7 +-
.../common/schematree/SchemaTree.java} | 43 ++++----
.../iotdb/db/mpp/execution/QueryExecution.java | 1 -
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 7 ++
.../iotdb/db/mpp/sql/analyze/ISchemaFetcher.java | 5 +
.../mpp/sql/analyze/StandaloneSchemaFetcher.java | 7 ++
.../db/mpp/sql/planner/plan/FragmentInstance.java | 20 +++-
.../db/mpp/sql/planner/plan/PlanFragment.java | 18 ++++
.../db/mpp/sql/planner/plan/node/PlanNode.java | 5 +
.../db/mpp/sql/planner/plan/node/PlanNodeType.java | 113 +++++++++++++++++++++
.../plan/node/metedata/read/ShowDevicesNode.java | 11 ++
.../planner/plan/node/metedata/read/ShowNode.java | 5 +
.../node/metedata/write/CreateTimeSeriesNode.java | 11 ++
.../planner/plan/node/process/AggregateNode.java | 11 ++
.../planner/plan/node/process/DeviceMergeNode.java | 11 ++
.../planner/plan/node/process/ExchangeNode.java | 11 ++
.../sql/planner/plan/node/process/FillNode.java | 11 ++
.../sql/planner/plan/node/process/FilterNode.java | 11 ++
.../planner/plan/node/process/FilterNullNode.java | 11 ++
.../plan/node/process/GroupByLevelNode.java | 11 ++
.../sql/planner/plan/node/process/LimitNode.java | 11 ++
.../sql/planner/plan/node/process/OffsetNode.java | 11 ++
.../sql/planner/plan/node/process/SortNode.java | 11 ++
.../planner/plan/node/process/TimeJoinNode.java | 11 ++
.../sql/planner/plan/node/sink/CsvSinkNode.java | 11 ++
.../planner/plan/node/sink/FragmentSinkNode.java | 11 ++
.../sql/planner/plan/node/sink/ThriftSinkNode.java | 11 ++
.../planner/plan/node/source/CsvSourceNode.java | 11 ++
.../plan/node/source/SeriesAggregateScanNode.java | 11 ++
.../planner/plan/node/source/SeriesScanNode.java | 11 ++
.../plan/node/write/InsertMultiTabletNode.java | 11 ++
.../sql/planner/plan/node/write/InsertNode.java | 4 +
.../sql/planner/plan/node/write/InsertRowNode.java | 11 ++
.../planner/plan/node/write/InsertRowsNode.java | 11 ++
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 11 ++
.../planner/plan/node/write/InsertTabletNode.java | 11 ++
.../InternalService.java} | 36 +++----
...CServiceMBean.java => InternalServiceImpl.java} | 22 ++--
.../org/apache/iotdb/db/utils/SchemaUtils.java | 1 +
thrift/src/main/thrift/mpp.thrift | 23 +++--
66 files changed, 829 insertions(+), 231 deletions(-)
copy {server => confignode}/src/assembly/resources/conf/logback-tool.xml (100%)
copy {tsfile/src/test/resources => confignode/src/assembly/resources/conf}/logback.xml (53%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/IDataBlockManager.java
copy consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java => server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/PathPatternNode.java (82%)
copy server/src/main/java/org/apache/iotdb/db/{qp/utils/EmptyOutputStream.java => mpp/common/schematree/PathPatternTree.java} (64%)
copy cluster/src/test/java/org/apache/iotdb/cluster/utils/Constants.java => server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/SchemaEntityNode.java (85%)
copy consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java => server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/SchemaInternalNode.java (83%)
copy cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotFactory.java => server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/SchemaMeasurementNode.java (78%)
copy cluster/src/test/java/org/apache/iotdb/cluster/utils/Constants.java => server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/SchemaNode.java (88%)
copy server/src/main/java/org/apache/iotdb/db/{qp/physical/sys/ClearCachePlan.java => mpp/common/schematree/SchemaTree.java} (52%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNodeType.java
copy server/src/main/java/org/apache/iotdb/db/{mpp/sql/planner/plan/node/sink/CsvSinkNode.java => service/InternalService.java} (60%)
copy server/src/main/java/org/apache/iotdb/db/service/{RPCServiceMBean.java => InternalServiceImpl.java} (64%)