This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a7e2f09173f Pipe: Fixed the bug that the
PipeDataNodeRemainingEventAndTimeMetrics may generate NullPointerException
(#14015)
add 859d37f3a3e Pipe: CreatePipe and AlterPipe support now function
(#14014)
No new revisions were added by this update.
Summary of changes:
.../pipe/it/autocreate/PipeNowFunctionIT.java | 286 +++++++++++++++++++++
.../tablet/parser/TabletInsertionEventParser.java | 8 +-
.../execution/config/sys/pipe/AlterPipeTask.java | 43 ++++
.../execution/config/sys/pipe/CreatePipeTask.java | 43 ++++
.../config/sys/pipe/PipeFunctionSupport.java | 85 ++++++
.../config/constant/PipeExtractorConstant.java | 1 +
6 files changed, 464 insertions(+), 2 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/PipeNowFunctionIT.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/PipeFunctionSupport.java
