This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ty/TableModelGrammar in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit b73cbb2e42c54dd828845d5197949b96a42c7e6d Merge: 06a82db678e 797aa491b8f Author: JackieTien97 <[email protected]> AuthorDate: Fri Mar 15 15:46:31 2024 +0800 Merge remote-tracking branch 'origin/master' into ty/TableModelGrammar .../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 +- .../pipe/event/common/row/PipeRemarkableRow.java | 55 ++ .../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, 2532 insertions(+), 208 deletions(-)
