This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch register_table_schema_for_sql_insertion
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 44381f02ae3 catch not CompatibleTsFileException
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 e10934948e1 fix compaction file metrics (#13691)
add 2c74c3e81d5 Fix tablet contains null binary or date value serialize
NPE (#13669)
add f1e603b4ee0 Merge branch 'master' into
register_table_schema_for_sql_insertion
No new revisions were added by this update.
Summary of changes:
...FormatIT.java => IoTDBTreePatternFormatIT.java} | 2 +-
.../apache/iotdb/session/util/SessionUtils.java | 108 +++++++++++++++++----
.../iotdb/session/util/SessionUtilsTest.java | 93 +++++++++++++++---
.../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 +-
.../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 ++---
.../task/InsertionCrossSpaceCompactionTask.java | 35 ++++---
.../compaction/execute/utils/CompactionUtils.java | 18 ++--
.../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 ++---
.../cross/InsertionCrossSpaceCompactionTest.java | 52 ++++++++++
.../wal/recover/WALRecoverManagerTest.java | 2 +
.../conf/iotdb-system.properties.template | 2 +-
.../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 ++++++--
pom.xml | 2 +-
64 files changed, 916 insertions(+), 425 deletions(-)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/{IoTDBPipePatternFormatIT.java
=> IoTDBTreePatternFormatIT.java} (99%)
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%)
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%)
