This is an automated email from the ASF dual-hosted git repository.
zhihao pushed a change to branch feat/szh/support_dense_in_window_optim
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ed79765e78b Add license header to all newly-added files.
add 20b380a11a9 Delete .github/workflows/greetings.yml (#17216)
add 8cfb49d1eb6 Improve Quick Start documentation for system resource
limits (#17213)
add 6ea3052d1a3 Fix: Adding the time column is prohibited. (#17215)
add 9041e6013f8 [IOTDB-17191] CLI: add space after error prefix in three
messages (#17192)
add 1fdd4b3a557 Pipe: Refactored the dataRegionId data type to integer
(#17214)
add 8782662e737 Add UT for new operators introduced by window function
optimization (#17209)
add 85ecbd60826 Pipe: Implemented the login check in customize method &
Added mosaic to subtask string in logger & Optimized the error code of illegal
pipe / pipe plugin name string (#17197)
add 4e7f3e58961 Pipe: Fixed the audit db filter on config receiver &&
Added the judgments for table model audit DB && Optimized the logger for
receiver status (#17219)
add c817cb0a841 Merge master and resolve conflict.
add 5680b371201 Modified comments and symbol name for copilot.
No new revisions were added by this update.
Summary of changes:
.github/workflows/greetings.yml | 14 -
README.md | 23 ++
.../treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 4 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 128 +++++++-
.../it/schema/IoTDBTableWithDefinedTimeIT.java | 22 ++
.../api/customizer/parameter/PipeParameters.java | 4 +-
...eption.java => PipePasswordCheckException.java} | 5 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 8 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../iotdb/confignode/manager/ConfigManager.java | 5 +-
.../apache/iotdb/confignode/manager/IManager.java | 3 +-
.../confignode/manager/PermissionManager.java | 5 +-
.../runtime/PipeLeaderChangeHandler.java | 5 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 2 +-
.../pipe/source/ConfigRegionListeningFilter.java | 84 +++--
.../pipe/source/IoTDBConfigRegionSource.java | 20 +-
.../manager/schema/ClusterSchemaManager.java | 14 +-
.../confignode/persistence/auth/AuthorInfo.java | 5 +-
.../persistence/auth/AuthorPlanExecutor.java | 5 +-
.../persistence/auth/IAuthorPlanExecutor.java | 3 +-
.../schema/CNPhysicalPlanGenerator.java | 10 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 11 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 13 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 5 +-
.../confignode/persistence/AuthorInfoTest.java | 2 +-
.../pipe/metric/PipeConsensusSyncLagManager.java | 10 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 10 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 26 +-
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 3 +-
.../pipe/agent/plugin/PipeDataNodePluginAgent.java | 40 ++-
.../dataregion/PipeDataRegionPluginAgent.java | 22 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 3 +-
.../pipe/consensus/deletion/DeletionResource.java | 9 +-
.../deletion/DeletionResourceManager.java | 20 +-
.../deletion/persist/PageCacheDeletionBuffer.java | 4 +-
.../consensus/deletion/recover/DeletionReader.java | 4 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 80 ++---
.../tsfile/PipeCompactedTsFileInsertionEvent.java | 4 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 3 +-
.../event/realtime/PipeRealtimeEventFactory.java | 2 +-
.../overview/PipeDataNodeSinglePipeMetrics.java | 16 +-
.../schema/PipeSchemaRegionSourceMetrics.java | 38 +--
.../db/pipe/metric/source/PipeAssignerMetrics.java | 32 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 2 +-
.../sink/protocol/writeback/WriteBackSink.java | 23 ++
.../source/dataregion/IoTDBDataRegionSource.java | 114 ++++---
...istoricalDataRegionTsFileAndDeletionSource.java | 21 +-
.../realtime/PipeRealtimeDataRegionSource.java | 18 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 75 ++---
.../PipeTsFileEpochProgressIndexKeeper.java | 8 +-
.../listener/PipeInsertionDataNodeListener.java | 12 +-
.../listener/PipeTimePartitionListener.java | 21 +-
.../schemaregion/IoTDBSchemaRegionSource.java | 32 +-
.../schemaregion/SchemaRegionListeningFilter.java | 7 +-
.../db/protocol/session/InternalClientSession.java | 2 +-
.../iotdb/db/protocol/session/SessionManager.java | 26 +-
.../operator/GroupedTopNRankAccumulator.java | 14 +-
.../operator/GroupedTopNRowNumberBuilder.java | 18 +-
.../execution/operator/TopNPeerGroupLookup.java | 2 +-
.../analyze/cache/partition/PartitionCache.java | 3 +
.../execution/config/TableConfigTaskVisitor.java | 3 +
.../execution/config/TreeConfigTaskVisitor.java | 7 +-
.../config/executor/ClusterConfigTaskExecutor.java | 121 ++++---
.../execution/config/sys/pipe/AlterPipeTask.java | 8 +-
.../execution/config/sys/pipe/CreatePipeTask.java | 20 +-
.../config/sys/pipe/PipeFunctionSupport.java | 2 +-
.../plan/planner/distribution/SourceRewriter.java | 8 +-
.../planner/optimizations/SortElimination.java | 3 +-
.../db/storageengine/dataregion/DataRegion.java | 21 +-
.../dataregion/memtable/TsFileProcessor.java | 8 +-
.../rescon/memory/TimePartitionManager.java | 2 +-
.../apache/iotdb/db/utils/DataNodeAuthUtils.java | 6 +-
.../auth/authorizer/LocalFileAuthorizerTest.java | 8 +-
.../db/auth/authorizer/OpenIdAuthorizerTest.java | 8 +-
.../db/pipe/consensus/DeletionRecoverTest.java | 6 +-
.../db/pipe/consensus/DeletionResourceTest.java | 12 +-
.../db/pipe/source/PipeRealtimeExtractTest.java | 32 +-
.../operator/process/ValuesOperatorTest.java | 207 ++++++++++++
.../process/window/RowNumberOperatorTest.java | 359 +++++++++++++++++++++
.../process/window/TopKRankingOperatorTest.java | 1 -
.../commons/auth/authorizer/BasicAuthorizer.java | 7 +-
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 3 +-
.../commons/auth/authorizer/OpenIdAuthorizer.java | 3 +-
.../commons/pipe/agent/plugin/PipePluginAgent.java | 33 +-
.../agent/task/execution/PipeSubtaskExecutor.java | 18 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 10 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 3 +
.../iotdb/commons/pipe/source/IoTDBSource.java | 19 +-
.../src/main/thrift/confignode.thrift | 1 +
89 files changed, 1541 insertions(+), 523 deletions(-)
delete mode 100644 .github/workflows/greetings.yml
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/{PipeStrategyNotValidException.java
=> PipePasswordCheckException.java} (87%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/ValuesOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/RowNumberOperatorTest.java
