This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch
optimize_partition_cache_get_region_replica_set_interface_by_batching
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 7ef66e4937b finish
add 9d7649d990c IoTV2: Improve receiver closed and clean dir logic (#15313)
add 24c23ce09a8 Support invoke table function without TABLE keyword
add c60a3b83320 Optimized the dual key cache memory computation
add 5ec193bf2f1 Throw exception when wal entry is too large
add 81d12e47353 Separate fully dirty files by partially dirty files task
(#15341)
add 88095bc2e52 [RTO/RPO] Fix: NullPointer in ClusterTopology #15347
add 371bf5c4662 reopen discussion in .asf.yml config (#15335)
add e545bf0cc50 Pipe: aggregate tablets with different measurements under
the same device before write into tsfile (#15193)
add 95ed457dc08 Subscription: detect outdated subscription event for
better consumer exception control (#15326)
add 077c3bcae1a Bump netty version to 4.1.119.Final
add 21b0fb7cea3 Load: check if the DataRegion is Deleted before loading
the new tsfile (#15346)
add 3c2b0670e53 Pipe: Fixed the validation logic of OpcDaConnector &
Optimized the error message when the system is not Windows (#15339)
add a84bee756a5 Pipe: use mem table to batch write tree data into tsfile
(#15276)
add a0497b80cbd Pipe: Fix NPE caused by InsertNodeMemoryEstimator
estimating Binary array length (#15321)
add 9e31c84ff99 Pipe: Fixed the IndexOutOfBound exception & Trimmed the
un-transferred schema region & Refactor for meta transfer (#15337)
add f5124525914 Load: Supports metrics in the Async Analyzer stage (#15312)
add b553a6f3670 Pipe/Load: Remove MD5 check for identically named TSFile
to speed up Active Load (#15311)
add 858c8b8538b [Bug] When using SubscriptionPullConsumer to consume data,
an error is reported when configuring ConsumerConstant.NODE_URLS_KEY as the
cluster address. (#15322)
add 323b21e3674 Make deserialize of AggregationDescriptor AttributesMap
use LinkedHashMap
add 040f3af358c refactor: load max page&chunk configuration in
ReadOnlyMemchunk and M… (#15309)
add edbf08ebccd perf: Adapt to Win11(wmic to powershell and compatibility
adjustment) (#15350)
add efdbb6d0946 Update release info after 2.0.2 and 1.3.4 released
add 1a64ec2a225 Impl visitTreeNonAlignedDeviceViewScan
add e6e37ccf365 update session source when have no permission in
ExportSchemaTable (#15355)
add d16ec65b70a Fix process of last query if intermediate state of last
cache is read when query concurrently
add be92fcd7a60 Fix sort properties process of AggregationNode when
generate distribution plan
add f9195c1e06e Add getBlob and getDate for SessionDataSet.DataIterator
add 427970f46fc fix an encrypt_key_import bug #15365
add 63517523561 Include thrift genarated python code in python client to
support AINode (#15348)
add 66b1997b172 Feature/node supplier (#15230)
add 3f96ada4c8d Tumble & Cumulate Windows TVFs (#15354)
add fcb2ab352fe Pipe: switch to IdentityHashMap backed set to avoid
infinite loop in table tsfile builder (#15371)
add 8fff9f22677 Pipe: fix potential ClassCastException when casting
LocalDate[] in PipeTreeModelTsFileBuilderV2 (#15375)
add 41c55ad7599 Fix python client pom error (#15381)
add 8f29bcd8578 Load: Do not clear schema cache when last cache is
disabled (#15380)
add aaff44910bd Pipe: aggregate tablets with different measurements under
the same table before write into tsfile (#15372)
add 74827521421 Subscription: obtain database name for message payload
subscribed by table model consumer (#15374)
add 2cfd029f214 Pipe: use mem table to batch write table data into tsfile
(#15373)
add 3215a4f4782 Fix error code when Row appears in query
add 571dcbe19c9 [RTO/RPO] Coordinator/Session Failover Retry (#15269)
add b20ab8accf2 Subscription: implemented runtime permission check (#15376)
add 5fae88dd6a6 feat: disabled history for -e sql (#15389)
add ede9b7430b6 Fixed the issue where the code returned when executing
drop user root SQL is different from the CLI (#15387)
add 699487f7f12 Adapt TIMESTAMP type when import data (#15378)
add 285ee5b5b6b Load: Fixed the bug that an empty table database may not
check privilege for auto-creation (#15366)
add 9e02cbdd371 [RTO/RPO] Add requestor retry for network partition
error #15393
add bac9f664f5f Subscription: unify table and tree consumer builder
interface (#15392)
add b0cfead5f3b Pipe: Fixed the deadlock cause by terminate event
reporting & Added sink.batch.max-delay-ms to enable delicate control over batch
delay & Fixed the bug of premature halt in extractor snapshot mode cause by
real-time-first transfer & Stabilized the trigger of default batch sending &
Added "isNeedToReport" getter in PipeRawTabletInsertionEvent for user-defined
plugins & Reduce logs from PipeEventCommitter (#15377)
add 34795100682 Add ScalarArgumentChecker and auto-built pass through
index for TVF
add 42d43810bc9 finish
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (7ef66e4937b)
\
N -- N -- N
refs/heads/optimize_partition_cache_get_region_replica_set_interface_by_batching
(42d43810bc9)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 3 +
.github/workflows/multi-language-client.yml | 6 +-
RELEASE_NOTES.md | 100 ++++
.../TableModelSubscriptionSessionExample.java | 1 +
.../iotdb/udf/table/ExcludeColumnExample.java | 2 +-
.../org/apache/iotdb/udf/table/RepeatExample.java | 6 +-
.../org/apache/iotdb/udf/table/SplitExample.java | 2 +-
.../{MyExcludeColumn.java => MySelectColumn.java} | 10 +-
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 54 ++
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 2 -
.../iotdb/db/it/aggregation/IoTDBCountIfIT.java | 13 +
.../org/apache/iotdb/db/it/utils/TestUtils.java | 8 -
.../relational/it/db/it/IoTDBWindowTVFIT.java | 142 ++++-
.../db/it/udf/IoTDBUserDefinedTableFunctionIT.java | 96 ++-
.../it/query/recent/IoTDBComplexQueryIT.java | 84 +++
.../it/query/recent/IoTDBTableAggregationIT.java | 8 +
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 73 +++
.../it/local/IoTDBSubscriptionPermissionIT.java | 236 ++++++++
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 23 +-
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 2 -
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 8 +-
.../IoTDBTSPatternTsfilePushConsumerIT.java | 2 +-
.../table/argument/ScalarArgumentChecker.java | 16 +-
.../processor/TableFunctionDataProcessor.java | 12 +-
.../ScalarParameterSpecification.java | 23 +-
.../cli/src/assembly/resources/sbin/start-cli.bat | 3 +
.../cli/src/assembly/resources/tools/backup.bat | 7 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 1 +
.../apache/iotdb/tool/data/AbstractDataTool.java | 12 +
.../org/apache/iotdb/tool/data/ImportDataTree.java | 57 +-
.../iotdb/tool/schema/ExportSchemaTable.java | 19 +-
iotdb-client/client-cpp/pom.xml | 24 +
.../client-cpp/src/main/AbstractSessionBuilder.h | 3 +
iotdb-client/client-cpp/src/main/NodesSupplier.cpp | 221 +++++++
iotdb-client/client-cpp/src/main/NodesSupplier.h | 137 +++++
iotdb-client/client-cpp/src/main/Session.cpp | 169 +++++-
iotdb-client/client-cpp/src/main/Session.h | 71 ++-
.../client-cpp/src/main/SessionConnection.cpp | 256 ++++++++
.../client-cpp/src/main/SessionConnection.h | 81 +++
.../client-cpp/src/main/ThriftConnection.cpp | 158 +++++
.../client-cpp/src/main/ThriftConnection.h | 68 +++
iotdb-client/client-py/pom.xml | 13 +-
.../org/apache/iotdb/isession/SessionDataSet.java | 18 +
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 134 +++--
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 17 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../rpc/subscription/annotation/TableModel.java | 12 +-
.../rpc/subscription/config/ConsumerConfig.java | 8 +
.../subscription/payload/poll/ErrorPayload.java | 4 +
.../subscription/payload/poll/FileSealPayload.java | 27 +-
.../subscription/payload/poll/TabletsPayload.java | 41 +-
.../response/PipeSubscribeHeartbeatResp.java | 48 +-
.../apache/iotdb/session/SessionConnection.java | 148 +++--
.../SubscriptionSessionConnection.java | 32 -
.../base/AbstractSubscriptionConsumer.java | 47 +-
.../base/AbstractSubscriptionConsumerBuilder.java | 4 +-
.../base/AbstractSubscriptionProvider.java | 13 +-
.../base/AbstractSubscriptionProviders.java | 6 +-
.../tree/SubscriptionTreePullConsumerBuilder.java | 2 +-
.../tree/SubscriptionTreePushConsumerBuilder.java | 2 +-
.../payload/SubscriptionFileHandler.java | 7 -
.../subscription/payload/SubscriptionMessage.java | 29 +-
.../payload/SubscriptionMessageHandler.java | 7 +-
.../payload/SubscriptionSessionDataSet.java | 12 +-
.../SubscriptionSessionDataSetsHandler.java | 56 +-
.../payload/SubscriptionTsFileHandler.java | 14 +-
.../src/assembly/resources/conf/confignode-env.bat | 14 +-
.../assembly/resources/sbin/start-confignode.bat | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 2 +-
.../iotdb/confignode/manager/ProcedureManager.java | 6 +-
.../persistence/schema/ClusterSchemaInfo.java | 15 +-
.../subscription/CreateSubscriptionProcedure.java | 21 +-
.../src/assembly/resources/conf/datanode-env.bat | 14 +-
.../src/assembly/resources/sbin/start-datanode.bat | 2 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 18 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 16 +-
.../agent/task/builder/PipeDataNodeBuilder.java | 4 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 51 +-
.../subtask/connector/PipeConnectorSubtask.java | 13 +-
.../batch/PipeTabletEventTsFileBatch.java | 18 +-
.../batch/PipeTransferBatchReqBuilder.java | 40 +-
.../request/PipeTransferSchemaSnapshotSealReq.java | 5 +-
.../connector/protocol/opcda/OpcDaConnector.java | 8 +-
.../PipeConsensusTransferBatchReqBuilder.java | 19 +-
.../thrift/sync/IoTDBSchemaRegionConnector.java | 8 +-
...ilder.java => PipeTableModelTsFileBuilder.java} | 119 +++-
.../builder/PipeTableModelTsFileBuilderV2.java | 259 ++++++++
.../util/builder/PipeTreeModelTsFileBuilder.java | 68 ++-
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 198 +++++++
.../connector/util/builder/PipeTsFileBuilder.java | 24 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 4 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 5 +
.../event/common/terminate/PipeTerminateEvent.java | 6 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 30 +-
.../schemaregion/SchemaRegionListeningFilter.java | 15 +
.../pipeconsensus/PipeConsensusReceiver.java | 86 +--
.../pipeconsensus/PipeConsensusReceiverAgent.java | 36 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 4 +
.../rest/table/v1/handler/ExceptionHandler.java | 4 +
.../protocol/rest/v1/handler/ExceptionHandler.java | 4 +
.../protocol/rest/v2/handler/ExceptionHandler.java | 4 +
.../execution/executor/RegionReadExecutor.java | 17 +-
.../operator/process/FilterAndProjectOperator.java | 15 +
.../execution/operator/process/LimitOperator.java | 6 +
.../execution/operator/process/OffsetOperator.java | 6 +
.../process/function/TableFunctionOperator.java | 18 +-
.../process/join/LeftOuterTimeJoinOperator.java | 15 +-
.../TableLeftOuterTimeJoinOperator.java} | 38 +-
.../relational/AbstractTableScanOperator.java | 56 +-
.../relational/DeviceIteratorScanOperator.java | 233 ++++++++
.../relational/LastQueryAggTableScanOperator.java | 10 +-
.../MeasurementToTableViewAdaptorUtils.java | 103 ++++
.../TreeToTableViewAdaptorOperator.java} | 112 ++--
.../relational/ColumnTransformerBuilder.java | 2 +-
.../iotdb/db/queryengine/plan/ClusterTopology.java | 4 +
.../iotdb/db/queryengine/plan/Coordinator.java | 4 -
.../cache/schema/dualkeycache/IDualKeyCache.java | 28 +-
.../dualkeycache/impl/CacheEntryGroupImpl.java | 57 +-
.../cache/schema/dualkeycache/impl/CacheStats.java | 47 +-
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 526 ++++++-----------
.../schema/dualkeycache/impl/ICacheEntryGroup.java | 13 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 67 ++-
.../analyze/schema/AutoCreateSchemaExecutor.java | 14 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 9 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 1 -
.../config/executor/ClusterConfigTaskExecutor.java | 4 +-
.../plan/planner/TableOperatorGenerator.java | 580 +++++++++++++++---
.../queryengine/plan/planner/TreeModelPlanner.java | 2 -
.../plan/node/metadata/write/MeasurementGroup.java | 25 +-
.../planner/plan/node/write/InsertTabletNode.java | 6 +-
.../node/write/RelationalInsertTabletNode.java | 14 +-
.../plan/parameter/AggregationDescriptor.java | 2 +-
.../relational/analyzer/StatementAnalyzer.java | 8 +
.../plan/relational/planner/TableModelPlanner.java | 9 -
.../distribute/TableDistributedPlanGenerator.java | 42 +-
.../TransformAggregationToStreamable.java | 33 +-
.../plan/relational/sql/ast/Expression.java | 3 +
.../queryengine/plan/relational/sql/ast/Row.java | 33 ++
.../relational/sql/ast/TableExpressionType.java | 3 +-
.../plan/relational/sql/parser/AstBuilder.java | 90 ++-
.../plan/scheduler/AsyncPlanNodeSender.java | 21 +-
.../plan/scheduler/ClusterScheduler.java | 5 -
....java => FailedFragmentInstanceWithStatus.java} | 22 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 248 ++++----
.../db/schemaengine/table/DataNodeTableCache.java | 18 +-
.../iotdb/db/service/metrics/WritingMetrics.java | 4 +
.../db/storageengine/dataregion/DataRegion.java | 19 +-
.../compaction/schedule/CompactionScheduler.java | 16 +-
.../selector/impl/SettleSelectorImpl.java | 103 ++--
.../dataregion/flush/MemTableFlushTask.java | 12 +-
.../memtable/AlignedReadOnlyMemChunk.java | 6 +-
.../memtable/AlignedWritableMemChunk.java | 52 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 19 +-
.../dataregion/memtable/TsFileProcessor.java | 38 +-
.../dataregion/memtable/WritableMemChunk.java | 19 +-
.../wal/utils/MemoryControlledWALEntryQueue.java | 14 +
.../load/metrics/LoadTsFileCostMetricsSet.java | 14 +-
.../agent/SubscriptionBrokerAgent.java | 9 +
.../db/subscription/broker/SubscriptionBroker.java | 10 +
.../broker/SubscriptionPrefetchingQueue.java | 21 +
.../broker/SubscriptionPrefetchingTabletQueue.java | 10 +
.../broker/SubscriptionPrefetchingTsFileQueue.java | 13 +
.../db/subscription/event/SubscriptionEvent.java | 4 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 27 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 5 +-
.../response/SubscriptionEventTabletResponse.java | 20 +-
.../response/SubscriptionEventTsFileResponse.java | 9 +-
.../receiver/SubscriptionReceiverV1.java | 76 ++-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 +-
.../db/utils/datastructure/AlignedTVList.java | 28 +-
.../db/utils/datastructure/BatchEncodeInfo.java | 16 +-
.../datastructure/MemPointIteratorFactory.java | 194 ++++--
.../MergeSortMultiAlignedTVListIterator.java | 27 +-
.../MergeSortMultiTVListIterator.java | 15 +-
.../datastructure/MultiAlignedTVListIterator.java | 14 +-
.../utils/datastructure/MultiTVListIterator.java | 13 +-
.../OrderedMultiAlignedTVListIterator.java | 6 +-
.../datastructure/OrderedMultiTVListIterator.java | 5 +-
.../iotdb/db/utils/datastructure/TVList.java | 39 +-
.../cache/dualkeycache/DualKeyCacheTest.java | 171 ------
.../operator/DeviceIteratorScanOperatorTest.java | 228 ++++++++
...nAlignedTreeDeviceViewScanOperatorTreeTest.java | 650 +++++++++++++++++++++
.../TreeToTableViewAdaptorOperatorTest.java | 237 ++++++++
.../iotdb/db/queryengine/plan/function/Repeat.java | 4 +-
.../compaction/AbstractCompactionTest.java | 4 +-
.../settle/SettleCompactionSelectorTest.java | 20 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 5 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 19 +-
.../src/assembly/resources/sbin/health_check.bat | 33 +-
...n.java => QuerySchemaFetchFailedException.java} | 10 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 2 +-
.../agent/task/progress/PipeEventCommitter.java | 28 +-
.../config/constant/PipeConnectorConstant.java | 3 +
.../pipe/connector/protocol/IoTDBConnector.java | 10 +
.../pipe/datastructure/pattern/TablePattern.java | 2 +
.../meta/consumer/ConsumerGroupMeta.java | 21 +
.../subscription/meta/consumer/ConsumerMeta.java | 12 +
.../commons/subscription/meta/topic/TopicMeta.java | 9 +-
.../relational/TableBuiltinTableFunction.java | 8 +
.../relational/tvf/CapacityTableFunction.java | 5 +-
...bleFunction.java => CumulateTableFunction.java} | 53 +-
.../builtin/relational/tvf/HOPTableFunction.java | 13 +-
.../relational/tvf/SessionTableFunction.java | 5 +-
...TableFunction.java => TumbleTableFunction.java} | 39 +-
.../relational/tvf/VariationTableFunction.java | 5 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 114 +++-
.../apache/iotdb/commons/utils/StatusUtils.java | 2 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 9 +-
iotdb-doap.rdf | 16 +
pom.xml | 2 +-
210 files changed, 7221 insertions(+), 2031 deletions(-)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/{MyExcludeColumn.java
=> MySelectColumn.java} (90%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBComplexQueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionPermissionIT.java
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/SQLModel.java
=>
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/table/argument/ScalarArgumentChecker.java
(69%)
create mode 100644 iotdb-client/client-cpp/src/main/NodesSupplier.cpp
create mode 100644 iotdb-client/client-cpp/src/main/NodesSupplier.h
create mode 100644 iotdb-client/client-cpp/src/main/SessionConnection.cpp
create mode 100644 iotdb-client/client-cpp/src/main/SessionConnection.h
create mode 100644 iotdb-client/client-cpp/src/main/ThriftConnection.cpp
create mode 100644 iotdb-client/client-cpp/src/main/ThriftConnection.h
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/node/utils/MNodeFactory.java
=>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/annotation/TableModel.java
(78%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/util/builder/{PipeTableModeTsFileBuilder.java
=> PipeTableModelTsFileBuilder.java} (65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/util/builder/PipeTableModelTsFileBuilderV2.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/util/builder/PipeTreeModelTsFileBuilderV2.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{TreeMergeSortOperator.java
=> join/TableLeftOuterTimeJoinOperator.java} (55%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/DeviceIteratorScanOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/MeasurementToTableViewAdaptorUtils.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/{process/last/LastQueryTransformOperator.java
=> source/relational/TreeToTableViewAdaptorOperator.java} (56%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/{FragInstanceDispatchResult.java
=> FailedFragmentInstanceWithStatus.java} (69%)
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/metadata/cache/dualkeycache/DualKeyCacheTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/DeviceIteratorScanOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/NonAlignedTreeDeviceViewScanOperatorTreeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/TreeToTableViewAdaptorOperatorTest.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/{RpcThrottlingException.java
=> QuerySchemaFetchFailedException.java} (72%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/{HOPTableFunction.java
=> CumulateTableFunction.java} (73%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/{HOPTableFunction.java
=> TumbleTableFunction.java} (80%)
