This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch preallocate_array_list
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 3318788728c add pre-allocation and metrics
add b4abdd2bf34 Pipe: Fixed the meta inclusion between SQL dialects
(#15278)
add 961f3581728 Fix the output ordinal of AggTableScanOperator are not
consistent with OutputSymbols of AggTableScanNode when do single input distinct
optimize
add ab6cbaf6f8b rest add support show models (#15287)
add b466bd1c699 fix: remove mqtt with table auth check (#15288)
add 7a4c1273151 IoTV2: Fix closing receiver corner case regarding to
concurrently closing and receiving file. (#15271)
add eccbcc2a012 fix mods file metrics (#15284)
add ef8dc52e89f perf: add encodeBatch interface to accelerate flushing for
sequential insert (#15243)
add 1d139bdbf45 Get correct TTL in tree model (#15256)
add b8bba8ff2c8 Bump version to 2.0.4-SNAPSHOT
add b89318f59db Remove dn_rpc_min_concurrent_client_num to fix minWorker
> maxWorker bugs #15296
add 6145474ac45 Fix the usage of method initOrInvalidateLastCache in table
last query process. (#15300)
add b1a0dee36e7 Add retry for inactivePeer of region migration (#15294)
add 18e55fee245 DAL: Fix deletion channel close exception (#15302)
add 93671e5a0e3 Check database by show databases (#15299)
add a3a0c6193f8 Pipe: Converted source database / table name pattern to
lower case (#15285)
add 4978d3f4dc9 Subscription: poll heartbeat event when there are no
consumers (#15307)
add 40a0e8a0525 Pipe: Fix the inconsistency between the schema registered
by TsFileWriter and the tablet written (#15304)
add 11b38c0eae3 [Fix](query) Fix project order in table distributed plan
generator
add d1d5f7fc6ac Do not add new compaction mod file in deletion (#15281)
add 6c9f956515d add some informations to find overlap bug (#15305)
add 3d5f6606134 Fixed the issue of REST service listing user or role lists
(#15319)
add c78546d27ef IoTV2: Receiver aware of pipe restart & Improve condition
schedule (#15314)
add 7cb9f171d89 IoTV2: Improve file piece transfer log & resource clean
#15315
add 27b3dcbb4d6 IoTV2: Use global singleton ClientManager to avoid too
many thrift threads which leads to Direct Memory OOM. (#15316)
add 7477ab9456b IoTV2: Add zombie tsFile writer checker as watch dog to
prevent sync stuck. (#15317)
add 74a0d306f81 perf: avoid reading tsfile on distinct aggregation on
tag/attribute column
add 5b2aa974ade Fix Greatest's looping logic bug in Boolean types.
add 3b2657300bf Optimized the NPE error log cause by closing of the
dataNode & the 301 error in select into cause by permission
add 75aec475070 Update README.md (#15329)
add c5ce0a3cb55 Fixed the reuse of time column's comment
add 5354dee8f8e Fixed the concurrent modification bug of pathPatternTree
add 5b8e59fd2d7 Get device path from cache (#15290)
add d01fe7db5c5 pref: Set the maximum number of history records in the
history file / memory to 1,000 lines. (#15332)
add db103faa21a Fixed the NPE caused by concurrent alter of SchemaRegion
#15331
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
new a357ee7c2cb Merge branch 'master' into preallocate_array_list
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:
.asf.yaml | 3 +
.github/workflows/multi-language-client.yml | 6 +-
README.md | 2 +-
README_ZH.md | 2 +-
RELEASE_NOTES.md | 100 ++++
code-coverage/pom.xml | 2 +-
distribution/pom.xml | 12 +-
example/client-cpp-example/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pipe-count-point-processor/pom.xml | 2 +-
example/pipe-opc-ua-sink/pom.xml | 2 +-
example/pom.xml | 2 +-
example/rest-java-example/pom.xml | 2 +-
example/schema/pom.xml | 2 +-
example/session/pom.xml | 2 +-
.../TableModelSubscriptionSessionExample.java | 1 +
example/trigger/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
.../iotdb/udf/table/ExcludeColumnExample.java | 2 +-
.../org/apache/iotdb/udf/table/RepeatExample.java | 2 +-
.../org/apache/iotdb/udf/table/SplitExample.java | 2 +-
integration-test/pom.xml | 32 +-
.../partition/IoTDBPartitionTableAutoCleanIT.java | 102 +++-
.../iotdb/db/it/aggregation/IoTDBCountIfIT.java | 13 +
.../tablemodel/manual/basic/IoTDBPipeAlterIT.java | 6 +-
.../manual/enhanced/IoTDBPipeMetaIT.java | 52 ++
.../relational/it/db/it/IoTDBWindowTVFIT.java | 123 +++-
.../db/it/udf/IoTDBUserDefinedTableFunctionIT.java | 80 ++-
.../query/old/query/IoTDBGreatestLeastTableIT.java | 6 +-
.../it/query/recent/IoTDBComplexQueryIT.java | 84 +++
.../it/query/recent/IoTDBDistinctTagIT.java | 257 ++++++++
.../it/query/recent/IoTDBTableAggregationIT.java | 16 +
.../relational/it/rest/it/IoTDBRestServiceIT.java | 14 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 34 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 73 +++
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 23 +-
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 2 -
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 8 +-
.../IoTDBTSPatternTsfilePushConsumerIT.java | 2 +-
iotdb-api/external-api/pom.xml | 2 +-
iotdb-api/pipe-api/pom.xml | 2 +-
.../api/customizer/parameter/PipeParameters.java | 18 +-
iotdb-api/pom.xml | 2 +-
iotdb-api/trigger-api/pom.xml | 2 +-
iotdb-api/udf-api/pom.xml | 2 +-
iotdb-client/cli/pom.xml | 22 +-
.../cli/src/assembly/resources/sbin/start-cli.bat | 3 +
.../cli/src/assembly/resources/tools/backup.bat | 7 +-
.../org/apache/iotdb/cli/utils/JlineUtils.java | 4 +
.../org/apache/iotdb/tool/common/Constants.java | 3 +
.../org/apache/iotdb/tool/schema/ExportSchema.java | 16 +-
.../iotdb/tool/schema/ExportSchemaTable.java | 117 ++--
iotdb-client/client-cpp/pom.xml | 28 +-
.../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 | 19 +-
iotdb-client/isession/pom.xml | 8 +-
.../org/apache/iotdb/isession/SessionDataSet.java | 18 +
iotdb-client/jdbc/pom.xml | 8 +-
iotdb-client/pom.xml | 2 +-
iotdb-client/service-rpc/pom.xml | 6 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 17 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +
.../rpc/subscription/annotation/TableModel.java | 12 +-
.../subscription/payload/poll/ErrorPayload.java | 4 +
.../subscription/payload/poll/FileSealPayload.java | 27 +-
.../subscription/payload/poll/TabletsPayload.java | 41 +-
iotdb-client/session/pom.xml | 10 +-
.../base/AbstractSubscriptionConsumer.java | 45 +-
.../payload/SubscriptionFileHandler.java | 7 -
.../subscription/payload/SubscriptionMessage.java | 29 +-
.../payload/SubscriptionMessageHandler.java | 7 +-
.../payload/SubscriptionSessionDataSet.java | 12 +-
.../SubscriptionSessionDataSetsHandler.java | 56 +-
.../payload/SubscriptionTsFileHandler.java | 14 +-
iotdb-core/ainode/pom.xml | 10 +-
iotdb-core/antlr/pom.xml | 2 +-
iotdb-core/confignode/pom.xml | 26 +-
.../src/assembly/resources/conf/confignode-env.bat | 14 +-
.../assembly/resources/sbin/start-confignode.bat | 2 +-
.../confignode/persistence/schema/ConfigMTree.java | 23 +-
iotdb-core/consensus/pom.xml | 14 +-
.../consensus/config/PipeConsensusConfig.java | 28 -
.../apache/iotdb/consensus/iot/IoTConsensus.java | 4 +-
.../consensus/iot/IoTConsensusServerImpl.java | 44 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 6 +-
iotdb-core/datanode/pom.xml | 40 +-
.../src/assembly/resources/conf/datanode-env.bat | 14 +-
.../src/assembly/resources/sbin/start-datanode.bat | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 29 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 49 +-
.../db/consensus/DataRegionConsensusImpl.java | 4 -
.../db/exception/runtime/IntoProcessException.java | 17 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 16 +-
.../agent/task/builder/PipeDataNodeBuilder.java | 4 +-
.../PipeRealtimePriorityBlockingQueue.java | 9 +
.../batch/PipeTabletEventTsFileBatch.java | 18 +-
.../request/PipeTransferSchemaSnapshotSealReq.java | 5 +-
.../connector/protocol/opcda/OpcDaConnector.java | 8 +-
.../pipeconsensus/PipeConsensusAsyncConnector.java | 5 +-
.../pipeconsensus/PipeConsensusSyncConnector.java | 5 +-
.../PipeConsensusTsFileInsertionEventHandler.java | 27 +-
.../PipeConsensusTransferBatchReqBuilder.java | 1 +
.../thrift/sync/IoTDBSchemaRegionConnector.java | 8 +-
...ilder.java => PipeTableModelTsFileBuilder.java} | 154 ++++-
.../builder/PipeTableModelTsFileBuilderV2.java | 259 ++++++++
.../util/builder/PipeTreeModelTsFileBuilder.java | 68 ++-
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 198 +++++++
.../connector/util/builder/PipeTsFileBuilder.java | 24 +-
.../pipe/consensus/deletion/DeletionResource.java | 6 +
.../deletion/persist/PageCacheDeletionBuffer.java | 22 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 4 +-
.../schemaregion/SchemaRegionListeningFilter.java | 15 +
.../pipeconsensus/PipeConsensusReceiver.java | 230 ++++++--
.../pipeconsensus/PipeConsensusReceiverAgent.java | 36 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 4 +
.../db/protocol/client/DataNodeInternalClient.java | 8 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 45 +-
.../table/v1/handler/ExecuteStatementHandler.java | 25 +-
.../table/v1/handler/RequestValidationHandler.java | 8 -
.../rest/table/v1/impl/RestApiServiceImpl.java | 11 +-
.../rest/v1/handler/ExecuteStatementHandler.java | 2 +
.../rest/v1/handler/QueryDataSetHandler.java | 2 +
.../rest/v2/handler/ExecuteStatementHandler.java | 2 +
.../rest/v2/handler/QueryDataSetHandler.java | 2 +
.../execution/executor/RegionReadExecutor.java | 17 +-
.../execution/executor/RegionWriteExecutor.java | 94 ++-
.../operator/process/AbstractIntoOperator.java | 6 +-
.../operator/process/FilterAndProjectOperator.java | 15 +
.../execution/operator/process/LimitOperator.java | 6 +
.../execution/operator/process/OffsetOperator.java | 6 +
.../process/join/LeftOuterTimeJoinOperator.java | 15 +-
.../TableLeftOuterTimeJoinOperator.java} | 38 +-
.../relational/AbstractAggTableScanOperator.java | 11 +-
.../AbstractDefaultAggTableScanOperator.java | 2 +-
.../relational/AbstractTableScanOperator.java | 56 +-
.../relational/DeviceIteratorScanOperator.java | 233 ++++++++
.../relational/LastQueryAggTableScanOperator.java | 12 +-
.../MeasurementToTableViewAdaptorUtils.java | 103 ++++
.../TreeToTableViewAdaptorOperator.java} | 112 ++--
.../relational/ColumnTransformerBuilder.java | 2 +-
.../iotdb/db/queryengine/plan/ClusterTopology.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 ++-
.../execution/config/TableConfigTaskVisitor.java | 50 +-
.../plan/planner/LocalExecutionPlanner.java | 13 +
.../plan/planner/TableOperatorGenerator.java | 595 ++++++++++++++++---
.../planner/plan/node/write/InsertTabletNode.java | 6 +-
.../node/write/RelationalInsertTabletNode.java | 14 +-
.../plan/parameter/AggregationDescriptor.java | 2 +-
.../plan/relational/planner/SymbolAllocator.java | 4 +
.../distribute/TableDistributedPlanGenerator.java | 86 ++-
.../rule/SingleDistinctAggregationToGroupBy.java | 3 +-
.../planner/node/AggregationTableScanNode.java | 11 +-
.../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 ++-
.../multi/BooleanGreatestColumnTransformer.java | 2 +-
.../multi/BooleanLeastColumnTransformer.java | 2 +-
.../iotdb/db/service/metrics/FileMetrics.java | 10 +
.../iotdb/db/service/metrics/WritingMetrics.java | 4 +
.../db/service/metrics/file/ModsFileMetrics.java | 4 +-
.../db/storageengine/dataregion/DataRegion.java | 25 +-
.../execute/task/AbstractCompactionTask.java | 3 +
.../execute/utils/CompactionPathUtils.java | 20 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 10 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 8 +-
.../FastNonAlignedSeriesCompactionExecutor.java | 5 +-
.../executor/fast/SeriesCompactionExecutor.java | 7 +-
.../compaction/repair/RepairDataFileScanUtil.java | 6 +-
.../compaction/schedule/CompactionScheduler.java | 16 +-
.../selector/impl/SettleSelectorImpl.java | 106 ++--
.../dataregion/flush/MemTableFlushTask.java | 25 +-
.../memtable/AbstractWritableMemChunk.java | 4 +-
.../memtable/AlignedReadOnlyMemChunk.java | 6 +-
.../memtable/AlignedWritableMemChunk.java | 160 ++---
.../dataregion/memtable/IWritableMemChunk.java | 3 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 19 +-
.../dataregion/memtable/TsFileProcessor.java | 97 +--
.../dataregion/memtable/WritableMemChunk.java | 108 +---
.../dataregion/modification/TreeDeletionEntry.java | 6 +-
.../dataregion/tsfile/TsFileResource.java | 1 -
.../wal/utils/MemoryControlledWALEntryQueue.java | 14 +
.../load/metrics/LoadTsFileCostMetricsSet.java | 14 +-
.../agent/SubscriptionBrokerAgent.java | 9 +
.../broker/SubscriptionBlockingPendingQueue.java | 4 +
.../db/subscription/broker/SubscriptionBroker.java | 10 +
.../broker/SubscriptionPrefetchingQueue.java | 49 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 10 +
.../broker/SubscriptionPrefetchingTsFileQueue.java | 13 +
.../TsFileDeduplicationBlockingPendingQueue.java | 10 +
.../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 | 29 +-
.../db/utils/datastructure/AlignedTVList.java | 162 ++++-
.../db/utils/datastructure/BatchEncodeInfo.java | 60 ++
.../db/utils/datastructure/MemPointIterator.java | 3 +
.../datastructure/MemPointIteratorFactory.java | 194 ++++--
.../MergeSortMultiAlignedTVListIterator.java | 94 ++-
.../MergeSortMultiTVListIterator.java | 76 ++-
.../datastructure/MultiAlignedTVListIterator.java | 14 +-
.../utils/datastructure/MultiTVListIterator.java | 24 +-
.../OrderedMultiAlignedTVListIterator.java | 21 +-
.../datastructure/OrderedMultiTVListIterator.java | 36 +-
.../iotdb/db/utils/datastructure/TVList.java | 144 ++++-
.../cache/dualkeycache/DualKeyCacheTest.java | 171 ------
.../db/pipe/consensus/DeletionResourceTest.java | 38 +-
.../operator/DeviceIteratorScanOperatorTest.java | 228 ++++++++
...nAlignedTreeDeviceViewScanOperatorTreeTest.java | 650 +++++++++++++++++++++
.../TreeToTableViewAdaptorOperatorTest.java | 237 ++++++++
.../compaction/AbstractCompactionTest.java | 4 +-
.../compaction/ReadChunkInnerCompactionTest.java | 70 +++
...eCrossSpaceCompactionWithFastPerformerTest.java | 14 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 12 -
.../InnerSeqCompactionWithFastPerformerTest.java | 7 +-
...nerSeqCompactionWithReadChunkPerformerTest.java | 7 +-
.../settle/SettleCompactionSelectorTest.java | 20 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 5 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 19 +-
iotdb-core/metrics/core/pom.xml | 4 +-
iotdb-core/metrics/interface/pom.xml | 8 +-
iotdb-core/metrics/pom.xml | 2 +-
iotdb-core/node-commons/pom.xml | 24 +-
.../conf/iotdb-system.properties.template | 19 +-
.../src/assembly/resources/sbin/health_check.bat | 33 +-
.../container/PipeConsensusClientMgrContainer.java | 20 +-
.../iotdb/commons/concurrent/ThreadName.java | 8 +-
.../apache/iotdb/commons/path/MeasurementPath.java | 4 +
.../apache/iotdb/commons/path/PathPatternTree.java | 20 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 2 +-
.../task/connection/BlockingPendingQueue.java | 4 +
.../options/PipeInclusionOptions.java | 117 ++--
.../pipe/datastructure/pattern/TablePattern.java | 2 +
.../commons/pipe/extractor/IoTDBExtractor.java | 15 +-
.../apache/iotdb/commons/schema/ttl/TTLCache.java | 23 +-
.../service/AbstractThriftServiceThread.java | 20 +-
.../iotdb/commons/service/ThriftServiceThread.java | 2 -
.../relational/TableBuiltinTableFunction.java | 8 +
...bleFunction.java => CumulateTableFunction.java} | 42 +-
...TableFunction.java => TumbleTableFunction.java} | 32 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 114 +++-
iotdb-core/pom.xml | 2 +-
iotdb-core/relational-grammar/pom.xml | 2 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 9 +-
iotdb-doap.rdf | 16 +
iotdb-protocol/openapi/pom.xml | 2 +-
iotdb-protocol/pom.xml | 2 +-
iotdb-protocol/thrift-ainode/pom.xml | 4 +-
iotdb-protocol/thrift-commons/pom.xml | 2 +-
iotdb-protocol/thrift-confignode/pom.xml | 4 +-
iotdb-protocol/thrift-consensus/pom.xml | 4 +-
.../src/main/thrift/pipeconsensus.thrift | 3 +-
iotdb-protocol/thrift-datanode/pom.xml | 4 +-
library-udf/pom.xml | 4 +-
pom.xml | 4 +-
273 files changed, 8196 insertions(+), 2379 deletions(-)
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/relational/it/query/recent/IoTDBDistinctTagIT.java
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} (58%)
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%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/BatchEncodeInfo.java
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/udf/builtin/relational/tvf/{HOPTableFunction.java
=> CumulateTableFunction.java} (78%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/{HOPTableFunction.java
=> TumbleTableFunction.java} (81%)
