This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch pipe-meta-sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4817afc5ae4 fix equals in CreatePipePlanV2.java
add 71e04746533 remove: @SuppressWarnings("unused") //
assignerSubtaskExecutor is for future use
add 96a6df6e33a Optimize the situation when using align by device with
template and value filter (#11783)
add dd7bada581d Pipe: conceal SSL trust store password & improve exception
messages for sink connection establishment (#11806)
add 0c7fef076d8 [IOTDB-6285] Alter Procedure timeout (#11817)
add 177cc9a0e5b Add log for NotEnoughDataNodeException (#11815)
add 5a19759e11d Pipe: accurate recording of heartbeat event duration to
improve observability (#11820)
add e5f05105ada Clear status in InsertNodes to fix consensus endless retry
(#11819)
add 88feb511cb5 Move path related antlr defined files to tsfile module
(#11813)
add 1b4fbaabfa3 Merge branch 'master' of https://github.com/apache/iotdb
into pipe-meta-sync
No new revisions were added by this update.
Summary of changes:
.gitignore | 2 +
.../IoTDBAlignByDeviceWithTemplateIT.java | 308 ++++++++++++++++++++-
.../api/customizer/parameter/PipeParameters.java | 33 ++-
.../api/exception/PipeConnectionException.java | 2 +
.../exception/PipeParameterNotValidException.java | 3 +
.../exception/NotEnoughDataNodeException.java | 13 +-
.../iotdb/confignode/manager/ProcedureManager.java | 16 +-
.../manager/load/balancer/RegionBalancer.java | 2 +-
.../confignode/manager/load/cache/LoadCache.java | 8 +-
.../dataregion/DataExecutionVisitor.java | 3 +
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 25 +-
.../thrift/async/IoTDBThriftAsyncConnector.java | 10 +-
.../thrift/sync/IoTDBThriftSyncClientManager.java | 39 ++-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 40 ++-
.../executor/PipeSubtaskExecutorManager.java | 1 -
.../iotdb/db/queryengine/common/NodeRef.java | 4 +
.../db/queryengine/plan/analyze/Analysis.java | 2 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 2 +-
.../plan/analyze/ExpressionTypeAnalyzer.java | 118 ++++----
.../queryengine/plan/analyze/TemplatedAnalyze.java | 61 ++--
.../db/queryengine/plan/analyze/TemplatedInfo.java | 104 ++++++-
.../visitor/ColumnTransformerVisitor.java | 14 +-
...dConcatRemoveUnExistentMeasurementVisitor.java} | 31 ++-
...ncatDeviceAndBindSchemaForPredicateVisitor.java | 1 +
.../db/queryengine/plan/parser/ASTVisitor.java | 7 +-
.../plan/planner/OperatorTreeGenerator.java | 169 ++++++++++-
.../plan/planner/SubPlanTypeExtractor.java | 13 +
.../plan/planner/TemplatedLogicalPlan.java | 181 ++++++------
.../plan/planner/TemplatedLogicalPlanBuilder.java | 11 +-
.../plan/planner/plan/node/PlanNodeType.java | 2 +
.../plan/planner/plan/node/process/FilterNode.java | 30 ++
.../planner/plan/node/process/TransformNode.java | 2 +-
.../plan/node/write/InsertMultiTabletsNode.java | 4 +
.../planner/plan/node/write/InsertRowsNode.java | 4 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 4 +
.../db/storageengine/dataregion/DataRegion.java | 14 +
.../builtin/connector/iotdb/IoTDBConnector.java | 82 ++++--
.../connector/iotdb/thrift/IoTDBMetaConnector.java | 34 ++-
.../commons/pipe/task/meta/PipeStaticMeta.java | 6 +-
iotdb-core/tsfile/pom.xml | 56 +++-
.../antlr4/org/apache/tsfile/parser/PathLexer.g4 | 212 ++++++++++++++
.../antlr4/org/apache/tsfile/parser}/PathParser.g4 | 9 +-
.../tsfile/common/constant/TsFileConstant.java | 4 -
.../read/common/parser/PathNodesGenerator.java | 8 +-
.../tsfile/read/common/parser/PathVisitor.java | 6 +-
45 files changed, 1358 insertions(+), 342 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/{RemoveRootPrefixVisitor.java
=> TemplatedConcatRemoveUnExistentMeasurementVisitor.java} (58%)
create mode 100644
iotdb-core/tsfile/src/main/antlr4/org/apache/tsfile/parser/PathLexer.g4
rename iotdb-core/{antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql =>
tsfile/src/main/antlr4/org/apache/tsfile/parser}/PathParser.g4 (92%)
