This is an automated email from the ASF dual-hosted git repository.
chenyz pushed a change to branch udsf
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ebcd1b91929 rename beforeStart and add getLocalDate
add 8618464d861 Fix table model insert without measurement error (#14222)
add 5b7f1c66260 Fix flaky LastFlushTimeMapTest (#14225)
add 864b94edf76 Add extra info for TableScanOperator and
AggTableScanOperator in Explain Analyze
add add7f323f4b Fix query failure if a table deletion involves deviceId
with null & Fix status code when deleting illegal time range & support is null
in deletion (#14217)
add f367c729a1b Register TableSchema to TsfileWriter when recover from wal
(#14228)
add 93438081109 Add extra info for HashAggregationOperator and
StreamingHashAggregationOperator in Explain Analyze
add 2b548342ea2 Fixed the bug that the exception may print stack when
dropping id or time column
add f15c30b97fa Fix issue that data is incomplete in full join of table
model and add new ExchangeNode for table model
add 0d8a0d101bf IoTConsensusV2: Fix syncLag error when using steam mode
and 2+ replicas (#14219)
add 0bb51c67c71 IoTConsensusV2: Fix reqBuffer reset and receive concurrent
bug (#14215)
add 4fddd584b20 [IoTConsensusV2 X Pipe Deletion]: Release deletion
resource when delete region & Improve for release when buffer is null (#14227)
add b34b714c80e [IoTConsensusV2 X Region Migration] Start consensus pipe
in proper time rather than automatically start it when create it
add 57973292733 Merge branch 'master' into udsf
add 30be7e5e076 modify getdatatype
No new revisions were added by this update.
Summary of changes:
.../relational/it/db/it/IoTDBDeletionTableIT.java | 71 +++++
.../db/it/IoTDBMultiIDsWithAttributesTableIT.java | 99 ++++++-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 3 +-
.../iotdb/session/it/IoTDBSessionRelationalIT.java | 32 +++
.../persistence/schema/ClusterSchemaInfo.java | 3 +
.../confignode/persistence/schema/ConfigMTree.java | 2 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 4 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 13 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 24 +-
.../consensuspipe/ConsensusPipeDispatcher.java | 3 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 18 +-
.../pipe/metric/PipeConsensusSyncLagManager.java | 88 +++----
.../service/PipeConsensusRPCServiceProcessor.java | 3 +-
.../consensus/ConsensusPipeDataNodeDispatcher.java | 4 +-
.../deletion/persist/PageCacheDeletionBuffer.java | 4 +-
.../pipeconsensus/PipeConsensusReceiver.java | 27 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 4 +
.../execution/operator/OperatorContext.java | 4 +-
.../TableAggregationTableScanOperator.java | 45 ++--
.../relational/TableFullOuterJoinOperator.java | 292 ++++-----------------
.../source/relational/TableInnerJoinOperator.java | 175 +++++++-----
.../source/relational/TableScanOperator.java | 44 +++-
.../grouped/HashAggregationOperator.java | 2 +
.../grouped/StreamingAggregationOperator.java | 5 +-
.../grouped/StreamingHashAggregationOperator.java | 18 +-
.../builder/InMemoryHashAggregationBuilder.java | 13 +
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 56 +++-
.../TableModelStatementMemorySourceVisitor.java | 7 +-
.../plan/planner/TableOperatorGenerator.java | 4 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 29 +-
.../plan/planner/plan/node/PlanNodeType.java | 6 +-
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../planner/plan/node/process/ExchangeNode.java | 9 +-
.../planner/distribute/AddExchangeNodes.java | 2 +-
.../planner/distribute/SubPlanGenerator.java | 2 +-
.../distribute/TableDistributedPlanGenerator.java | 6 +-
.../distribute/TableDistributedPlanner.java | 2 +-
.../distribute/TableModelQueryFragmentPlanner.java | 2 +-
.../TableModelTypeProviderExtractor.java | 4 +-
.../planner/node}/ExchangeNode.java | 72 ++---
.../optimizations/PushPredicateIntoTableScan.java | 12 +-
.../udf/UserDefineScalarFunctionTransformer.java | 8 +-
.../dataregion/flush/MemTableFlushTask.java | 2 +-
.../dataregion/memtable/AbstractMemTable.java | 7 +-
.../memtable/AlignedWritableMemChunk.java | 18 +-
.../memtable/AlignedWritableMemChunkGroup.java | 10 +-
.../dataregion/memtable/IWritableMemChunk.java | 5 +-
.../dataregion/memtable/TsFileProcessor.java | 1 +
.../dataregion/memtable/WritableMemChunk.java | 2 +-
.../dataregion/modification/IDPredicate.java | 16 +-
.../file/UnsealedTsFileRecoverPerformer.java | 22 ++
.../iotdb/db/metadata/path/PatternTreeMapTest.java | 27 +-
.../plan/relational/analyzer/AnalyzerTest.java | 2 +-
.../plan/relational/analyzer/JoinTest.java | 2 +-
.../analyzer/LimitOffsetPushDownTest.java | 2 +-
.../plan/relational/analyzer/SortTest.java | 2 +-
.../plan/relational/analyzer/SubQueryTest.java | 2 +-
.../plan/relational/analyzer/TestUtils.java | 2 +-
.../planner/assertions/ExchangeNodeMatcher.java | 2 +-
.../planner/assertions/PlanMatchPattern.java | 2 +-
.../planner/assertions/PlanMatchingVisitor.java | 4 +-
.../storageengine/dataregion/DataRegionTest.java | 29 +-
.../dataregion/LastFlushTimeMapTest.java | 13 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 47 ++++
.../org/apache/iotdb/commons/path/PartialPath.java | 3 +-
.../apache/iotdb/commons/path/PatternTreeMap.java | 2 +-
.../iotdb/commons/udf/access/RecordIterator.java | 14 +-
.../src/main/thrift/confignode.thrift | 1 +
68 files changed, 893 insertions(+), 572 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{planner/plan/node/process
=> relational/planner/node}/ExchangeNode.java (78%)
