[iotdb] branch seriesAggregateOperator updated (f44cc7f975 -> f0982c5606)

[xi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

xiangweiwei pushed a change to branch seriesAggregateOperator
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from f44cc7f975 add part unit tests
     add 8d10d159ea [IOTDB-2906] Commit pipe data serial number error, Can not find tsfile (#5536)
     add 93ee11b9f3 Add DataNodeTSIServiceImpl as RPCServiceImpl in mpp mode (#5540)
     add ad9401282f [IOTDB-2923] fix CI IoTDBSyncReceiverIT.testReceiveDataAndLoad  (#5548)
     add 8c38d6baac [IOTDB-2842] SHOW PIPE PipeName throws NPE if receiverService isn't initialize (#5414)
     add 6f8eadd8f0 fix the spotless issue in last PR (#5559)
     add a356eeabc9 [IOTDB-2922] Fix NPE when compacting with files that contains zero device (#5553)
     add b2dfcf847b Fix mpp CI (#5562)
     add 588fece871 [IOTDB-2852] the import-csv tool can not import the data to nonaligned device (#5420)
     add 1e3044dbd9 [IOTDB-2934] Fix StorageEngineV2 cannot recover (#5558)
     add 8ed3f3ad5d [IOTDB-2902] Handling user privileges for aligned timeseries related features (#5556)
     add 90cd903f9b [IOTDB-2924] UDF Framework: index overflow while iterating sliding windows (#5555)
     add 2691ade495 Make standalone mode mpp basically runnable (#5566)
     add f0982c5606 Merge branch 'master' into seriesAggregateOperator

No new revisions were added by this update.

Summary of changes:
 .../main/java/org/apache/iotdb/tool/ImportCsv.java |   6 +-
 .../iotdb/cluster/log/snapshot/FileSnapshot.java   |   2 +-
 .../cluster/log/snapshot/FileSnapshotTest.java     |   2 +-
 .../iotdb/confignode/conf/ConfigNodeConf.java      |   2 +-
 .../persistence/PartitionInfoPersistence.java      |   5 +-
 .../tests/tools/importCsv/ImportCsvTestIT.java     |  31 +
 .../db/integration/sync/IoTDBSyncReceiverIT.java   |   1 +
 .../iotdb/db/integration/sync/SyncTestUtil.java    |  64 +-
 .../iotdb/commons/concurrent/ThreadName.java       |  10 +-
 .../iotdb/commons/consensus/DataRegionId.java      |   4 +
 .../iotdb/commons/consensus/PartitionRegionId.java |   4 +
 .../iotdb/commons/consensus/SchemaRegionId.java    |   4 +
 .../iotdb/commons/partition/DataPartition.java     |  28 +-
 .../commons/partition/DataPartitionQueryParam.java |   3 +-
 .../iotdb/commons/partition/SchemaPartition.java   |  46 +-
 .../apache/iotdb/commons/service/ServiceType.java  |   3 +-
 .../iotdb/commons/service/ThriftService.java       |   8 +-
 .../resources/conf/iotdb-engine.properties         |  35 +-
 .../org/apache/iotdb/db/auth/AuthorityChecker.java |   4 +
 .../apache/iotdb/db/client/ConfigNodeClient.java   |   2 +-
 .../java/org/apache/iotdb/db/conf/IoTDBConfig.java |  32 +-
 .../org/apache/iotdb/db/conf/IoTDBDescriptor.java  |  10 +-
 .../org/apache/iotdb/db/engine/StorageEngine.java  |   4 +-
 .../apache/iotdb/db/engine/StorageEngineV2.java    | 101 +--
 .../inner/utils/MultiTsFileDeviceIterator.java     |   5 +-
 .../iotdb/db/engine/storagegroup/DataRegion.java   |  33 +-
 .../iotdb/db/mpp/buffer/DataBlockManager.java      |  38 +-
 .../iotdb/db/mpp/buffer/DataBlockService.java      |  33 +-
 .../mpp/buffer/DataBlockServiceClientFactory.java  |  95 ++-
 .../buffer/DataBlockServiceMBean.java}             |   4 +-
 .../iotdb/db/mpp/buffer/IDataBlockManager.java     |  31 +-
 .../org/apache/iotdb/db/mpp/buffer/SinkHandle.java |  19 +-
 .../apache/iotdb/db/mpp/buffer/SourceHandle.java   |   6 +-
 .../apache/iotdb/db/mpp/buffer/StubSinkHandle.java |  17 +-
 .../iotdb/db/mpp/common/MPPQueryContext.java       |  10 +-
 .../iotdb/db/mpp/common/header/DatasetHeader.java  |  13 +-
 .../apache/iotdb/db/mpp/execution/Coordinator.java |  50 +-
 .../apache/iotdb/db/mpp/execution/DataDriver.java  |   5 +-
 .../iotdb/db/mpp/execution/DriverContext.java      |   4 +
 .../db/mpp/execution/FragmentInstanceContext.java  |   7 +
 .../db/mpp/execution/FragmentInstanceManager.java  |   2 +-
 .../iotdb/db/mpp/execution/IQueryExecution.java    |  13 +
 .../iotdb/db/mpp/execution/QueryExecution.java     |  74 +-
 .../iotdb/db/mpp/execution/QueryStateMachine.java  |   6 +-
 .../iotdb/db/mpp/execution/SchemaDriver.java       |  24 +-
 .../db/mpp/execution/config/ConfigExecution.java   |  48 +-
 .../scheduler/AbstractFragInsStateTracker.java     |  10 +-
 .../scheduler/FixedRateFragInsStateTracker.java    |   8 +
 .../scheduler/InternalServiceClientFactory.java    |  87 ++-
 .../scheduler/SimpleFragInstanceDispatcher.java    |  23 +-
 .../execution/scheduler/SimpleQueryTerminator.java |   9 +-
 .../db/mpp/operator/process/TimeJoinOperator.java  |   5 +-
 .../db/mpp/schedule/FragmentInstanceScheduler.java |  19 +-
 .../apache/iotdb/db/mpp/sql/analyze/Analyzer.java  |  78 ++-
 .../mpp/sql/analyze/ClusterPartitionFetcher.java   |   7 +-
 .../db/mpp/sql/analyze/ClusterSchemaFetcher.java   |  13 +-
 .../db/mpp/sql/planner/DistributionPlanner.java    |  31 +-
 .../db/mpp/sql/planner/LocalExecutionPlanner.java  |  47 +-
 .../db/mpp/sql/planner/plan/node/PlanNodeType.java |   6 +-
 .../plan/node/metedata/read/SchemaFetchNode.java   |   4 +-
 .../plan/node/metedata/read/SchemaMergeNode.java   |  11 +-
 .../node/metedata/write/CreateTimeSeriesNode.java  |  29 +-
 .../planner/plan/node/process/ExchangeNode.java    |   6 +
 .../planner/plan/node/process/TimeJoinNode.java    |   9 +-
 .../planner/plan/node/sink/FragmentSinkNode.java   |   6 +
 .../sql/planner/plan/node/write/InsertRowNode.java |  32 +-
 .../apache/iotdb/db/qp/executor/PlanExecutor.java  |   2 +-
 .../layer/MultiInputColumnIntermediateLayer.java   |  14 +
 ...InputColumnMultiReferenceIntermediateLayer.java |  14 +
 ...nputColumnSingleReferenceIntermediateLayer.java |  14 +
 .../iotdb/db/service/DataNodeManagementServer.java |   4 +-
 .../apache/iotdb/db/service/InternalService.java   |  55 +-
 .../iotdb/db/service/InternalServiceImpl.java      |   8 +-
 ...ataNodeMBean.java => InternalServiceMBean.java} |   3 +-
 .../InternalServiceThriftHandler.java}             |   4 +-
 .../java/org/apache/iotdb/db/service/IoTDB.java    |  29 +-
 .../apache/iotdb/db/service/IoTDBShutdownHook.java |   2 +
 .../org/apache/iotdb/db/service/RPCService.java    |  12 +-
 .../thrift/handler/RPCServiceThriftHandler.java    |  10 +-
 .../thrift/impl/DataNodeTSIServiceImpl.java        | 763 +++++++++++++++++++++
 .../db/service/thrift/impl/TSIEventHandler.java    |  10 +-
 .../db/service/thrift/impl/TSServiceImpl.java      | 367 +---------
 .../iotdb/db/sync/receiver/load/TsFileLoader.java  |   2 +-
 .../db/sync/receiver/manager/ReceiverManager.java  |   9 +-
 .../apache/iotdb/db/utils/QueryDataSetUtils.java   |  19 +-
 .../iotdb/db/wal/recover/WALRecoverManager.java    |   3 +-
 .../db/wal/recover/file/TsFilePlanRedoer.java      |  53 ++
 .../file/UnsealedTsFileRecoverPerformer.java       |   5 +
 .../wal/utils/listener/AbstractResultListener.java |   2 +-
 .../iotdb/db/mpp/execution/DataDriverTest.java     |   4 +-
 .../db/mpp/schedule/DefaultTaskSchedulerTest.java  |   8 -
 .../iotdb/db/mpp/sql/analyze/AnalyzerTest.java     |   6 +-
 .../db/mpp/sql/plan/DistributionPlannerTest.java   |  29 +-
 .../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java  |   5 +-
 .../iotdb/db/mpp/sql/plan/QueryPlannerTest.java    |  10 +-
 95 files changed, 2032 insertions(+), 822 deletions(-)
 copy server/src/main/java/org/apache/iotdb/db/{service/RPCServiceMBean.java => mpp/buffer/DataBlockServiceMBean.java} (92%)
 copy server/src/main/java/org/apache/iotdb/db/service/{DataNodeMBean.java => InternalServiceMBean.java} (95%)
 copy server/src/main/java/org/apache/iotdb/db/{mpp/buffer/DataBlockServiceThriftHandler.java => service/InternalServiceThriftHandler.java} (92%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeTSIServiceImpl.java
 copy cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java => server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSIEventHandler.java (80%)