This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/SupportFill
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b98e9ddd9e3 Support fill fe change
add 61176054f18 support fill_group be for previous fill
add 5cd607bb5e8 Change database in SessionConnection while using db
add fc965db8734 Add serialize and deserialize method for Agg-related Node
add 5bae76344c0 Bump commons-io:commons-io from 2.13.0 to 2.14.0 (#13676)
add e09a98b4a0b Fix the order of stop schema region and clear schema
engine #13678
add 3544970fe6f Fix the failure of update cluster name in metric framework
of ConfigNode (#13681)
add ff1f1781dee Try to fix error msg like: 301: queue has been destroyed
add 1c2451af9b5 Table ttl & Fix ttl bugs (#13668)
add 4a5c90293da ConfigManager confirms leader before create schema
partition #13693
add 9cc8ffddc0e Catch Exception to improve the robustness of loading
procedure #13696
add 360ca21fe3c Pipe: Introduce TablePattern for table model (#13695)
add ffa19f0cd38 resolve conflicts
No new revisions were added by this update.
Summary of changes:
...FormatIT.java => IoTDBTreePatternFormatIT.java} | 2 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 79 ++++++
.../it/query/recent/IoTDBFillTableIT.java | 201 +++++++++++----
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 37 +++
.../apache/iotdb/session/SessionConnection.java | 6 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 2 +
.../iotdb/confignode/manager/ConfigManager.java | 8 +
.../protocol/IoTDBConfigRegionAirGapConnector.java | 2 +-
.../protocol/IoTDBConfigRegionConnector.java | 2 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 28 ++-
.../pipe/event/PipeConfigRegionWritePlanEvent.java | 15 +-
.../PipeConfigPhysicalPlanPatternParseVisitor.java | 52 ++--
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 6 +-
.../confignode/persistence/ProcedureInfo.java | 2 +-
...eConfigPhysicalPlanPatternParseVisitorTest.java | 6 +-
.../src/main/codegen/templates/constantFill.ftl | 5 +
.../src/main/codegen/templates/previousFill.ftl | 5 +
.../templates/previousFillWithTimeDuration.ftl | 5 +
.../agent/task/connection/PipeEventCollector.java | 7 +-
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 2 +-
.../thrift/sync/IoTDBSchemaRegionConnector.java | 2 +-
.../db/pipe/event/UserDefinedEnrichedEvent.java | 11 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 10 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 22 +-
.../schema/PipeSchemaRegionWritePlanEvent.java | 21 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 23 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 42 +++-
.../tablet/TabletInsertionDataContainer.java | 16 +-
.../event/common/terminate/PipeTerminateEvent.java | 8 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 21 +-
.../common/tsfile/TsFileInsertionPointCounter.java | 6 +-
.../container/TsFileInsertionDataContainer.java | 6 +-
.../TsFileInsertionDataContainerProvider.java | 14 +-
.../query/TsFileInsertionQueryDataContainer.java | 8 +-
.../scan/TsFileInsertionScanDataContainer.java | 4 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 30 ++-
.../event/realtime/PipeRealtimeEventFactory.java | 6 +-
.../dataregion/IoTDBDataRegionExtractor.java | 38 +--
.../PipeHistoricalDataRegionTsFileExtractor.java | 20 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 57 +++--
.../realtime/assigner/PipeDataRegionAssigner.java | 6 +-
.../realtime/epoch/TsFileEpochManager.java | 6 +-
.../matcher/CachedSchemaPatternMatcher.java | 9 +-
.../schemaregion/PipePlanPatternParseVisitor.java | 52 ++--
.../protocol/thrift/IoTDBDataNodeReceiver.java | 6 +-
...peStatementDataTypeConvertExecutionVisitor.java | 4 +-
.../visitor/PipeStatementPatternParseVisitor.java | 26 +-
.../execution/exchange/SharedTsBlockQueue.java | 10 +
.../exchange/source/LocalSourceHandle.java | 12 +
.../process/PreviousFillWithGroupOperator.java | 213 ++++++++++++++++
.../execution/operator/process/fill/IFill.java | 2 +
.../process/fill/identity/IdentityFill.java | 5 +
.../operator/schema/source/DeviceSchemaSource.java | 2 +-
.../source/ActiveDeviceRegionScanOperator.java | 2 +-
.../execution/operator/source/SeriesScanUtil.java | 16 +-
.../db/queryengine/plan/analyze/TypeProvider.java | 10 +-
.../analyze/cache/schema/DataNodeTTLCache.java | 62 ++---
.../plan/planner/OperatorTreeGenerator.java | 8 +-
.../plan/planner/TableOperatorGenerator.java | 44 +++-
.../plan/planner/plan/node/PlanNodeType.java | 8 +
.../relational/analyzer/StatementAnalyzer.java | 2 +-
.../plan/relational/function/BoundSignature.java | 36 +++
.../plan/relational/function/FunctionKind.java | 20 +-
.../plan/relational/metadata/ColumnSchema.java | 47 +---
.../relational/metadata/FunctionNullability.java | 31 +++
.../plan/relational/metadata/ResolvedFunction.java | 32 ++-
.../plan/relational/planner/QueryPlanner.java | 3 +
.../relational/planner/node/AggregationNode.java | 219 +++++++++++++++-
.../planner/node/AggregationTableScanNode.java | 275 +++++++++++++++++++++
.../PushLimitOffsetIntoTableScan.java | 12 +-
.../plan/relational/utils/TypeUtil.java | 105 ++++++++
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +-
.../iotdb/db/storageengine/StorageEngine.java | 8 +-
.../db/storageengine/dataregion/DataRegion.java | 47 ++--
.../execute/performer/ICompactionPerformer.java | 2 -
.../performer/impl/FastCompactionPerformer.java | 49 ++--
.../impl/ReadChunkCompactionPerformer.java | 16 +-
.../impl/ReadPointCompactionPerformer.java | 10 +-
.../RepairUnsortedFileCompactionPerformer.java | 3 +-
.../task/RepairUnsortedFileCompactionTask.java | 10 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 42 ++--
.../ReadChunkAlignedSeriesCompactionExecutor.java | 8 +-
.../repair/RepairTimePartitionScanTask.java | 6 +-
.../schedule/CompactionScheduleContext.java | 25 +-
.../selector/impl/SettleSelectorImpl.java | 16 +-
.../impl/SizeTieredCompactionSelector.java | 3 +-
.../dataregion/memtable/TsFileProcessor.java | 13 +-
.../dataregion/read/QueryDataSource.java | 5 +
.../PipeStatementPatternParseVisitorTest.java | 6 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 26 +-
.../event/TsFileInsertionDataContainerTest.java | 48 ++--
.../extractor/PipePlanPatternParseVisitorTest.java | 6 +-
.../pattern/CachedSchemaPatternMatcherTest.java | 16 +-
...ePatternTest.java => IoTDBTreePatternTest.java} | 24 +-
...PatternTest.java => PrefixTreePatternTest.java} | 24 +-
.../db/storageengine/dataregion/TTLQueryTest.java | 14 +-
.../iotdb/db/storageengine/dataregion/TTLTest.java | 46 ++--
.../compaction/AbstractCompactionTest.java | 3 +-
.../repair/RepairUnsortedFileCompactionTest.java | 32 +--
.../settle/SettleCompactionRecoverTest.java | 2 +-
.../settle/SettleCompactionSelectorTest.java | 14 +-
.../settle/SettleCompactionTaskTest.java | 22 +-
.../tablemodel/CompactionWithAllNullRowsTest.java | 9 +-
.../TableModelCompactionWithTTLTest.java | 191 ++++++++++++++
.../compaction/utils/CompactionCheckerUtils.java | 3 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 38 +--
.../config/constant/PipeExtractorConstant.java | 4 +
...IoTDBPipePattern.java => IoTDBTreePattern.java} | 12 +-
...efixPipePattern.java => PrefixTreePattern.java} | 4 +-
.../pipe/datastructure/pattern/TablePattern.java | 94 +++++++
.../pattern/{PipePattern.java => TreePattern.java} | 28 +--
.../iotdb/commons/pipe/event/EnrichedEvent.java | 48 ++--
.../commons/pipe/event/PipeSnapshotEvent.java | 15 +-
.../commons/pipe/event/PipeWritePlanEvent.java | 15 +-
.../commons/pipe/event/ProgressReportEvent.java | 13 +-
.../extractor/IoTDBNonDataRegionExtractor.java | 40 ++-
.../apache/iotdb/commons/schema/table/TsTable.java | 15 ++
pom.xml | 2 +-
118 files changed, 2471 insertions(+), 732 deletions(-)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/{IoTDBPipePatternFormatIT.java
=> IoTDBTreePatternFormatIT.java} (99%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/PreviousFillWithGroupOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/utils/TypeUtil.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/pattern/{IoTDBPipePatternTest.java
=> IoTDBTreePatternTest.java} (83%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/pattern/{PrefixPipePatternTest.java
=> PrefixTreePatternTest.java} (82%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tablemodel/TableModelCompactionWithTTLTest.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/{IoTDBPipePattern.java
=> IoTDBTreePattern.java} (95%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/{PrefixPipePattern.java
=> PrefixTreePattern.java} (97%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/TablePattern.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/{PipePattern.java
=> TreePattern.java} (85%)
