This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch pipe-new-sql
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 49eeace70ee refactor for extractor table pattern
new 8d8842dd2ba Add table pattern in enriched events
add 220c953f0ba AINode: depend torch of cpu version (#13670)
add 2ec48d28a6c Active Load: Fix load tsfile failed when system is read
only (#13646)
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)
new 43d213d1b7e Merge branch 'master' of https://github.com/apache/iotdb
into pipe-new-sql
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../relational/it/db/it/IoTDBInsertTableIT.java | 79 ++++++
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 37 +++
.../apache/iotdb/session/SessionConnection.java | 6 +-
iotdb-core/ainode/resources/conf/ainode-env.bat | 4 +-
iotdb-core/ainode/resources/conf/ainode-env.sh | 4 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 2 +
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 26 +-
.../pipe/event/PipeConfigRegionWritePlanEvent.java | 13 +-
.../agent/task/connection/PipeEventCollector.java | 5 +-
.../db/pipe/event/UserDefinedEnrichedEvent.java | 9 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 8 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 20 +-
.../schema/PipeSchemaRegionWritePlanEvent.java | 19 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 13 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 32 ++-
.../event/common/terminate/PipeTerminateEvent.java | 6 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 13 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 28 ++-
.../event/realtime/PipeRealtimeEventFactory.java | 6 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 2 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 3 +-
.../realtime/epoch/TsFileEpochManager.java | 6 +-
.../execution/exchange/SharedTsBlockQueue.java | 10 +
.../exchange/source/LocalSourceHandle.java | 12 +
.../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/plan/node/PlanNodeType.java | 8 +
.../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 ++-
.../relational/planner/node/AggregationNode.java | 219 +++++++++++++++-
.../planner/node/AggregationTableScanNode.java | 275 +++++++++++++++++++++
.../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 +
.../load/active/ActiveLoadDirScanner.java | 13 +
.../load/active/ActiveLoadTsFileLoader.java | 15 ++
.../pattern/CachedSchemaPatternMatcherTest.java | 2 +-
.../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 +--
.../iotdb/commons/pipe/event/EnrichedEvent.java | 13 +-
.../commons/pipe/event/PipeSnapshotEvent.java | 13 +-
.../commons/pipe/event/PipeWritePlanEvent.java | 13 +-
.../commons/pipe/event/ProgressReportEvent.java | 9 +-
.../extractor/IoTDBNonDataRegionExtractor.java | 17 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 15 ++
pom.xml | 2 +-
77 files changed, 1597 insertions(+), 392 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/utils/TypeUtil.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tablemodel/TableModelCompactionWithTTLTest.java
