This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/TableModelGrammar
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 06a82db678e merge master
add 0191563f172 fix(jdbc): when catalog is "Apache IoTDB", ignore it
(#12166)
add de5405fef83 Print native request api in datanode_slow_sql.log
add 0443aa6a0c8 Bump google.golang.org/protobuf in
/iotdb-connector/grafana-plugin (#12168)
add fd831b7d964 Random schedule compaction of bound data regions in one
compaction schedule worker (#12167)
add 7b34fa91e42 Fixed logical view creation with "into" pattern failure
problem
add 613afa5365e Support schema region snapshot parser (#12145)
add aa547fb3889 Pipe: implemented sdt-sampling-processor & refactored
down-sampling-processor (#12114)
add 792cf133c31 UDF: add an udf function for envelope demodulation
analysis (#12146)
add c12b8b765cf Pipe: Fixed create logical view idempotency problem & some
IT check coverage missing (#12170)
add cf67dc259cf fix: Fix the build.
add 5cb15970ef7 Optimize the result of EXPLAIN ANALYZE
add 86b942dc25a Integration test cluster stop faster (#12110)
add 277c1567b8f Fix Concurrent bug between NodeSupplier.close() and its
run()
add 797aa491b8f Fix wal delete sort method (#12176)
new b73cbb2e42c Merge remote-tracking branch 'origin/master' into
ty/TableModelGrammar
The 1 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:
.../iotdb/it/env/cluster/env/AbstractEnv.java | 2 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 15 +-
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 2 +
.../iotdb/libudf/it/dprofile/DProfileIT.java | 18 +
.../iotdb/pipe/it/autocreate/IoTDBPipeAlterIT.java | 30 +-
.../pipe/it/autocreate/IoTDBPipeIdempotentIT.java | 7 +-
.../pipe/it/autocreate/IoTDBPipeProcessorIT.java | 6 +-
.../org/apache/iotdb/tool/WriteCsvFileTest.java | 4 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 4 +
.../org/apache/iotdb/session/NodesSupplier.java | 7 +-
iotdb-connector/grafana-plugin/go.mod | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 12 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 14 +
.../PipeDataRegionProcessorConstructor.java | 9 +-
...naryTransformer.java => PipeRemarkableRow.java} | 36 +-
.../iotdb/db/pipe/event/common/row/PipeRow.java | 18 +-
.../downsampling/DownSamplingProcessor.java | 122 ++--
...eCache.java => PartialPathLastObjectCache.java} | 38 +-
.../sdt/SwingingDoorTrendingFilter.java | 145 +++++
.../sdt/SwingingDoorTrendingSamplingProcessor.java | 201 ++++++
.../tumbling/TumblingTimeSamplingProcessor.java | 135 ++++
.../receiver/PipeStatementTSStatusVisitor.java | 13 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 27 +-
.../fragment/FragmentInstanceExecution.java | 7 +-
.../execution/operator/ExplainAnalyzeOperator.java | 18 +-
.../queryengine/execution/operator/Operator.java | 10 +-
.../execution/operator/OperatorContext.java | 10 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 10 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 9 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 2 +-
.../plan/planner/LogicalPlanVisitor.java | 3 +-
.../plan/planner/OperatorTreeGenerator.java | 2 +-
.../plan/planner/plan/node/ExplainAnalyzeNode.java | 22 +-
.../FragmentInstanceStatisticsDrawer.java | 9 +-
.../statistics/StatisticsMergeUtil.java | 2 +-
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 2 +-
.../schedule/CompactionScheduleTaskWorker.java | 7 +-
.../storageengine/dataregion/wal/WALManager.java | 9 +-
.../db/tools/schema/SRStatementGenerator.java | 355 +++++++++++
.../tools/schema/SchemaRegionSnapshotParser.java | 175 ++++++
.../org/apache/iotdb/db/utils/CommonUtils.java | 78 +++
.../db/utils/SchemaRegionSnapshotParserTest.java | 694 +++++++++++++++++++++
.../resources/conf/iotdb-common.properties | 6 +-
.../config/constant/PipeProcessorConstant.java | 17 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 10 +-
... => SwingingDoorTrendingSamplingProcessor.java} | 10 +-
...sor.java => TumblingTimeSamplingProcessor.java} | 10 +-
.../src/main/thrift/datanode.thrift | 3 +-
library-udf/pom.xml | 5 +
.../library/frequency/UDFEnvelopeAnalysis.java | 248 ++++++++
.../org/apache/iotdb/library/UDFEnvelopeTest.java | 121 ++++
51 files changed, 2504 insertions(+), 217 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/row/{PipeBinaryTransformer.java
=> PipeRemarkableRow.java} (50%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/{PartialPathLastTimeCache.java
=> PartialPathLastObjectCache.java} (77%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/sdt/SwingingDoorTrendingFilter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/sdt/SwingingDoorTrendingSamplingProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/tumbling/TumblingTimeSamplingProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/schema/SRStatementGenerator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/schema/SchemaRegionSnapshotParser.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/SchemaRegionSnapshotParserTest.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/downsampling/{DownSamplingProcessor.java
=> SwingingDoorTrendingSamplingProcessor.java} (75%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/downsampling/{DownSamplingProcessor.java
=> TumblingTimeSamplingProcessor.java} (74%)
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/frequency/UDFEnvelopeAnalysis.java
create mode 100644
library-udf/src/test/java/org/apache/iotdb/library/UDFEnvelopeTest.java
