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 862e7366e5c fix IoTDBSessionSimpleIT compile issue
add 7ef1eb722e9 Pipe: add parameter realtime.loose-range to support
subscription loose range semantics (#12580)
add e49a07d1129 Pipe: fix PipeEnrichedStatement can't contain redirect
info (#12579)
add f60694b4a46 Add TsFile develop branch for IoTDB in README (#12581)
add fad655319e1 Avoid infinite and unecessary loop when CN RPC processors
are killed/interrupted by OS (#12584)
add 1517e81e878 Fix python ci security warning and update c++ ci commands
(#12583)
add aa2687c1fe7 Pipe: Fix BatchActivateTemplateStatement is not handled
correctly when some of the timeseries already exists (#12587)
add 6a0da36bc56 Merge multi-language client CI workflows to one ymls
(#12586)
add 21a23967d7c Fix error compare method in IT framework
add 28bb9b8cd6c Pipe: Support pipe's endpoint & global connector transfer
rate limit & Fix RPC compression not enabled in stream batch mode (#12543)
add a9c27bb249d Fix potential NPE for empty InsertRowsOfOneDevice #12593
add a8f3ca3fcc0 Fix the bug that iot consensus doesn't adapt
InsertRowsNode (#12594)
add 88cadb2d800 more compaction config items allow hot load (#12596)
add 2ed61401d3c Subscription: support TsFile message format & improve
exception handling logic (#12326)
add 4403bb890b8 Fix agg push down bug (#12598)
add baf37c3711d add --help with remove-xx script (#12585)
add 231910ebf7b Clean up local snapshot after add region peer #12602
add cb1bca615d9 Support new data type: DATE, TIMESTAMP, BLOB and STRING
new e40a36f16eb resolve conflicts
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:
.github/workflows/client-go.yml | 56 --
.github/workflows/client-python.yml | 58 --
.../{client-cpp.yml => multi-language-client.yml} | 92 ++-
.mvn/wrapper/maven-wrapper.properties | 4 +-
README.md | 2 +
README_ZH.md | 2 +
.../main/java/org/apache/iotdb/JDBCExample.java | 25 +-
.../org/apache/iotdb/DataMigrationExample.java | 7 +
.../apache/iotdb/SubscriptionSessionExample.java | 188 +++--
.../iotdb/it/env/cluster/ClusterConstant.java | 1 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 15 +-
.../iotdb/itbase/runtime/RequestDelegate.java | 26 +-
.../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 40 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 64 ++
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 4 +-
.../db/it/aggregation/IoTDBAggregationIT.java | 387 +++++++--
.../aggregation/IoTDBAggregationSmallDataIT.java | 4 +-
.../iotdb/db/it/aggregation/IoTDBVarianceIT.java | 74 +-
.../maxby/IoTDBMaxByAlignedSeriesIT.java | 28 +-
.../db/it/aggregation/maxby/IoTDBMaxByIT.java | 62 +-
.../minby/IoTDBMinByAlignedSeriesIT.java | 16 +-
.../db/it/aggregation/minby/IoTDBMinByIT.java | 50 +-
.../scalar/IoTDBReplaceFunctionIT.java | 47 +-
.../scalar/IoTDBSubStringFunctionIT.java | 67 +-
.../iotdb/db/it/query/IoTDBCaseWhenThenIT.java | 2 +-
.../query/IoTDBQueryWithComplexValueFilterIT.java | 235 +++++-
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 57 ++
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 226 +++++-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 2 +-
.../org/apache/iotdb/session/it/SessionIT.java | 223 ++++++
.../it/IoTDBSubscriptionITConstant.java | 19 +-
.../it/dual/AbstractSubscriptionDualIT.java | 3 +
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 327 +++++++-
.../it/dual/IoTDBSubscriptionTopicIT.java | 228 ++++--
.../it/local/IoTDBSubscriptionBasicIT.java | 227 ++++--
.../it/local/IoTDBSubscriptionRestartIT.java | 103 ++-
.../java/org/apache/iotdb/udf/api/type/Type.java | 19 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 3 +-
.../java/org/apache/iotdb/tool/ExportData.java | 3 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 17 +-
.../java/org/apache/iotdb/tool/ImportData.java | 41 +-
iotdb-client/client-py/requirements_dev.txt | 1 -
.../org/apache/iotdb/isession/SessionDataSet.java | 27 +-
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 13 +-
.../iotdb/jdbc/GroupedLSBWatermarkEncoder.java | 2 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 2 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 84 +-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 35 +-
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 7 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 12 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 2 +-
iotdb-client/service-rpc/pom.xml | 4 +
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 39 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 26 +-
.../rpc/subscription/config/ConsumerConfig.java | 11 +-
.../rpc/subscription/config/ConsumerConstant.java | 22 +-
.../iotdb/rpc/subscription/config/TopicConfig.java | 37 +-
.../rpc/subscription/config/TopicConstant.java | 5 +-
...n.java => SubscriptionConnectionException.java} | 21 +-
.../exception/SubscriptionException.java | 8 +-
... SubscriptionIncompatibleHandlerException.java} | 25 +-
.../SubscriptionParameterNotValidException.java | 13 +-
...a => SubscriptionRuntimeCriticalException.java} | 24 +-
...tion.java => SubscriptionRuntimeException.java} | 23 +-
...> SubscriptionRuntimeNonCriticalException.java} | 25 +-
.../rpc/subscription/payload/EnrichedTablets.java | 104 ---
.../subscription/payload/poll/ErrorPayload.java | 85 ++
.../subscription/payload/poll/FileInitPayload.java | 75 ++
.../payload/poll/FilePiecePayload.java | 123 +++
.../subscription/payload/poll/FileSealPayload.java | 85 ++
.../subscription/payload/poll/PollFilePayload.java | 103 +++
.../rpc/subscription/payload/poll/PollPayload.java | 79 ++
.../payload/poll/SubscriptionCommitContext.java | 152 ++++
.../SubscriptionPollPayload.java} | 18 +-
.../payload/poll/SubscriptionPollRequest.java | 111 +++
.../SubscriptionPollRequestType.java} | 20 +-
.../payload/poll/SubscriptionPollResponse.java | 122 +++
.../SubscriptionPollResponseType.java} | 25 +-
.../subscription/payload/poll/TabletsPayload.java | 92 +++
.../payload/request/PipeSubscribeCloseReq.java | 6 +-
.../payload/request/PipeSubscribeCommitReq.java | 48 +-
.../payload/request/PipeSubscribeHandshakeReq.java | 19 +-
.../payload/request/PipeSubscribeHeartbeatReq.java | 7 +-
.../payload/request/PipeSubscribePollReq.java | 46 +-
.../payload/request/PipeSubscribeRequestType.java | 8 +-
.../request/PipeSubscribeRequestVersion.java | 2 +-
.../payload/request/PipeSubscribeSubscribeReq.java | 9 +-
.../request/PipeSubscribeUnsubscribeReq.java | 8 +-
.../payload/response/PipeSubscribeCloseResp.java | 8 +-
.../payload/response/PipeSubscribeCommitResp.java | 9 +-
.../response/PipeSubscribeHandshakeResp.java | 27 +-
.../response/PipeSubscribeHeartbeatResp.java | 8 +-
.../payload/response/PipeSubscribePollResp.java | 88 +-
.../response/PipeSubscribeResponseType.java | 9 +-
.../response/PipeSubscribeResponseVersion.java | 2 +-
.../response/PipeSubscribeSubscribeResp.java | 8 +-
.../response/PipeSubscribeUnsubscribeResp.java | 8 +-
.../java/org/apache/iotdb/session/Session.java | 4 +
.../apache/iotdb/session/SessionConnection.java | 15 +-
.../org/apache/iotdb/session/ThriftConnection.java | 5 +-
.../session/subscription/AsyncCommitCallback.java | 2 +-
.../session/subscription/ConsumeListener.java | 2 +
.../subscription/ConsumerHeartbeatWorker.java | 63 --
.../subscription/PullConsumerAutoCommitWorker.java | 60 --
.../session/subscription/SubscriptionConsumer.java | 884 ++++++++++++++-------
.../subscription/SubscriptionEndpointsSyncer.java | 132 ---
.../session/subscription/SubscriptionMessage.java | 85 --
.../session/subscription/SubscriptionProvider.java | 295 ++++++-
.../subscription/SubscriptionProviders.java | 339 ++++++++
.../subscription/SubscriptionPullConsumer.java | 147 ++--
.../subscription/SubscriptionPushConsumer.java | 112 ++-
.../session/subscription/SubscriptionSession.java | 48 +-
.../SubscriptionSessionConnection.java | 73 +-
.../payload/SubscriptionFileHandler.java | 105 +++
.../subscription/payload/SubscriptionMessage.java | 106 +++
.../SubscriptionMessageHandler.java} | 9 +-
.../payload/SubscriptionMessageType.java} | 20 +-
.../{ => payload}/SubscriptionSessionDataSet.java | 33 +-
.../SubscriptionSessionDataSetsHandler.java} | 35 +-
.../payload/SubscriptionTsFileHandler.java} | 24 +-
.../subscription/util/RandomStringGenerator.java} | 22 +-
.../subscription/util}/SubscriptionPollTimer.java | 2 +-
.../apache/iotdb/session/util/SessionUtils.java | 29 +
.../apache/iotdb/session/pool/SessionPoolTest.java | 6 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 6 +
.../assembly/resources/sbin/remove-confignode.bat | 12 +
.../assembly/resources/sbin/remove-confignode.sh | 11 +
.../iotdb/confignode/manager/ClusterManager.java | 2 +
.../manager/consensus/ConsensusManager.java | 1 +
.../protocol/IoTDBConfigRegionAirGapConnector.java | 51 +-
.../protocol/IoTDBConfigRegionConnector.java | 52 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 20 +-
.../consensus/iot/IoTConsensusServerImpl.java | 14 +-
.../service/IoTConsensusRPCServiceProcessor.java | 2 +-
.../assembly/resources/sbin/remove-datanode.bat | 12 +
.../src/assembly/resources/sbin/remove-datanode.sh | 11 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 8 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 50 +-
.../dataregion/DataRegionStateMachine.java | 65 +-
.../payload/evolvable/builder/PipeEventBatch.java | 18 +
.../builder/PipeTransferBatchReqBuilder.java | 8 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 20 +-
.../airgap/IoTDBDataRegionAirGapConnector.java | 55 +-
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 32 +-
.../async/IoTDBDataRegionAsyncConnector.java | 11 +-
.../PipeTransferTabletBatchEventHandler.java | 19 +-
.../PipeTransferTabletInsertNodeEventHandler.java | 8 +-
.../PipeTransferTabletInsertionEventHandler.java | 5 +
.../PipeTransferTsFileInsertionEventHandler.java | 35 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 17 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 136 ++--
.../thrift/sync/IoTDBSchemaRegionConnector.java | 36 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 13 +
.../event/realtime/PipeRealtimeEventFactory.java | 1 +
.../realtime/PipeRealtimeDataRegionExtractor.java | 22 +
.../visitor/PipeStatementExceptionVisitor.java | 39 +-
.../visitor/PipeStatementTSStatusVisitor.java | 10 +
.../db/pipe/resource/memory/PipeMemoryManager.java | 2 +-
.../db/protocol/rest/utils/InsertRowDataUtils.java | 4 +
.../v1/handler/StatementConstructionHandler.java | 4 +
.../v2/handler/StatementConstructionHandler.java | 4 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 10 +-
.../aggregation/FirstValueAccumulator.java | 24 +
.../aggregation/LastValueAccumulator.java | 24 +
.../execution/aggregation/MaxByAccumulator.java | 6 +
.../aggregation/MaxMinByBaseAccumulator.java | 65 +-
.../execution/aggregation/MaxValueAccumulator.java | 50 ++
.../execution/aggregation/MinByAccumulator.java | 6 +
.../execution/aggregation/MinValueAccumulator.java | 50 ++
.../execution/load/LoadTsFileRateLimiter.java | 32 +-
.../queryengine/execution/memory/MemoryPool.java | 6 +-
.../execution/operator/AggregationUtil.java | 4 +
.../operator/process/TransformOperator.java | 4 +
.../AbstractSeriesAggregationScanOperator.java | 13 +-
.../AlignedSeriesAggregationScanOperator.java | 12 +-
.../source/SeriesAggregationScanOperator.java | 12 +-
.../execution/operator/source/SeriesScanUtil.java | 4 +
.../plan/analyze/ExpressionTypeAnalyzer.java | 31 +-
.../queryengine/plan/analyze/PredicateUtils.java | 6 +-
.../plan/analyze/schema/SchemaValidator.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 10 +-
.../builtin/helper/ReplaceFunctionHelper.java | 4 +-
.../builtin/helper/SubStringFunctionHelper.java | 4 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 20 +-
.../plan/optimization/AggregationPushDown.java | 2 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 49 +-
.../plan/parser/StatementGenerator.java | 6 +-
.../plan/planner/OperatorTreeGenerator.java | 48 +-
.../queryengine/plan/planner/TreeModelPlanner.java | 11 +-
.../planner/plan/node/write/InsertRowNode.java | 28 +
.../planner/plan/node/write/InsertTabletNode.java | 27 +
.../plan/statement/crud/InsertBaseStatement.java | 3 +-
.../crud/InsertMultiTabletsStatement.java | 3 +-
.../plan/statement/crud/InsertRowStatement.java | 14 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 5 +-
.../plan/statement/crud/InsertRowsStatement.java | 5 +-
.../plan/statement/literal/BinaryLiteral.java | 93 +++
.../plan/statement/literal/Literal.java | 5 +-
.../multi/MappableUDFQueryRowTransformer.java | 4 +
.../multi/UniversalUDFQueryTransformer.java | 4 +
.../dag/transformer/unary/InTransformer.java | 6 +
.../transformation/dag/util/LayerCacheUtils.java | 4 +
.../row/SerializableRowRecordList.java | 4 +
.../datastructure/tv/SerializableTVList.java | 8 +
.../db/service/metrics/DataNodeMetricsHelper.java | 4 +
.../readchunk/SingleSeriesCompactionExecutor.java | 4 +
.../utils/writer/AbstractCompactionWriter.java | 4 +
.../impl/RewriteCrossSpaceCompactionSelector.java | 5 +-
.../impl/SizeTieredCompactionSelector.java | 5 +-
.../memtable/AlignedReadOnlyMemChunk.java | 4 +
.../memtable/AlignedWritableMemChunk.java | 6 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 4 +
.../dataregion/memtable/TsFileProcessor.java | 18 +-
.../dataregion/memtable/WritableMemChunk.java | 16 +-
.../read/reader/chunk/MemPageReader.java | 4 +
.../rescon/memory/PrimitiveArrayManager.java | 27 +-
.../agent/SubscriptionBrokerAgent.java | 94 ++-
.../agent/SubscriptionConsumerAgent.java | 7 +-
.../subscription/agent/SubscriptionTopicAgent.java | 20 +-
.../broker/EnrichedTabletsBinaryCache.java | 62 --
.../db/subscription/broker/SubscriptionBroker.java | 101 ++-
.../broker/SubscriptionPrefetchingQueue.java | 269 ++-----
.../SubscriptionPrefetchingTabletsQueue.java | 244 ++++++
.../broker/SubscriptionPrefetchingTsFileQueue.java | 377 +++++++++
.../SubscriptionEvent.java} | 132 +--
.../event/SubscriptionEventBinaryCache.java | 140 ++++
.../event/SubscriptionTsFileEvent.java | 247 ++++++
.../subscription/metric/SubscriptionMetrics.java | 57 ++
.../SubscriptionPrefetchingQueueMetrics.java | 197 +++++
.../receiver/SubscriptionReceiverV1.java | 323 +++++---
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 4 +
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 4 +
.../org/apache/iotdb/db/utils/CommonUtils.java | 97 ++-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 53 +-
.../iotdb/db/utils/EncodingInferenceUtils.java | 4 +
.../java/org/apache/iotdb/db/utils/MemUtils.java | 4 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 12 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 4 +
.../apache/iotdb/db/utils/TimeValuePairUtils.java | 32 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 37 +-
.../db/utils/datastructure/AlignedTVList.java | 38 +-
.../iotdb/db/utils/datastructure/TVList.java | 8 +
.../db/utils/windowing/window/WindowImpl.java | 4 +
.../dataregion/DataRegionStateMachineTest.java | 46 +-
.../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 12 +-
.../operator/AggregationOperatorTest.java | 6 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 3 +-
.../operator/HorizontallyConcatOperatorTest.java | 6 +-
.../execution/operator/LastQueryOperatorTest.java | 12 +-
.../operator/LastQuerySortOperatorTest.java | 12 +-
.../execution/operator/OperatorMemoryTest.java | 3 +-
.../SeriesAggregationScanOperatorTest.java | 3 +-
.../SlidingWindowAggregationOperatorTest.java | 3 +-
.../operator/UpdateLastCacheOperatorTest.java | 3 +-
.../compaction/TestUtilsForAlignedSeries.java | 12 +
.../compaction/utils/TsFileGeneratorUtils.java | 8 +
.../org/apache/iotdb/db/utils/BlobParserTest.java | 60 ++
.../iotdb/db/utils/TypeInferenceUtilsTest.java | 2 +-
.../datastructure/PrimitiveArrayManagerTest.java | 4 +
.../resources/conf/iotdb-common.properties | 10 +
.../async/AsyncPipeDataTransferServiceClient.java | 4 +
.../apache/iotdb/commons/conf/CommonConfig.java | 55 +-
.../iotdb/commons/conf/CommonDescriptor.java | 28 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 17 +
.../config/constant/PipeConnectorConstant.java | 4 +
.../config/constant/PipeExtractorConstant.java | 2 +
.../pipe/connector/client/IoTDBSyncClient.java | 7 +
.../pipe/connector/limiter/GlobalRateLimiter.java} | 55 +-
.../connector/limiter/PipeEndPointRateLimiter.java | 59 ++
.../connector/protocol/IoTDBAirGapConnector.java | 48 +-
.../pipe/connector/protocol/IoTDBConnector.java | 45 +-
.../connector/protocol/IoTDBSslSyncConnector.java | 24 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 1 +
.../iotdb/commons/service/metric/enums/Metric.java | 4 +
.../subscription/config/SubscriptionConfig.java | 18 +-
.../commons/subscription/meta/topic/TopicMeta.java | 37 +-
.../commons/udf/builtin/String/UDTFConcat.java | 2 +-
.../commons/udf/builtin/String/UDTFEndsWith.java | 2 +-
.../commons/udf/builtin/String/UDTFLower.java | 2 +-
.../commons/udf/builtin/String/UDTFStartsWith.java | 2 +-
.../commons/udf/builtin/String/UDTFStrCompare.java | 4 +-
.../commons/udf/builtin/String/UDTFStrLength.java | 2 +-
.../commons/udf/builtin/String/UDTFStrLocate.java | 2 +-
.../iotdb/commons/udf/builtin/String/UDTFTrim.java | 2 +-
.../commons/udf/builtin/String/UDTFUpper.java | 2 +-
.../iotdb/commons/udf/builtin/UDTFBottomK.java | 8 +-
.../iotdb/commons/udf/builtin/UDTFConst.java | 26 +
.../iotdb/commons/udf/builtin/UDTFSelectK.java | 27 +-
.../apache/iotdb/commons/udf/builtin/UDTFTopK.java | 8 +-
.../commons/udf/utils/UDFDataTypeTransformer.java | 12 +
.../org/apache/iotdb/commons/utils/BlobUtils.java | 60 ++
293 files changed, 9471 insertions(+), 3216 deletions(-)
delete mode 100644 .github/workflows/client-go.yml
delete mode 100644 .github/workflows/client-python.yml
rename .github/workflows/{client-cpp.yml => multi-language-client.yml} (58%)
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeRequestVersion.java
=>
integration-test/src/test/java/org/apache/iotdb/subscription/it/IoTDBSubscriptionITConstant.java
(68%)
rename
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/exception/{SubscriptionPollTimeOutException.java
=> SubscriptionConnectionException.java} (59%)
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/exception/{SubscriptionException.java
=> SubscriptionIncompatibleHandlerException.java} (59%)
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/exception/{SubscriptionException.java
=> SubscriptionRuntimeCriticalException.java} (60%)
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/exception/{SubscriptionException.java
=> SubscriptionRuntimeException.java} (60%)
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/exception/{SubscriptionException.java
=> SubscriptionRuntimeNonCriticalException.java} (59%)
delete mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/EnrichedTablets.java
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/ErrorPayload.java
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/FileInitPayload.java
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/FilePiecePayload.java
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/FileSealPayload.java
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/PollFilePayload.java
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/PollPayload.java
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionCommitContext.java
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/{request/PipeSubscribeRequestVersion.java
=> poll/SubscriptionPollPayload.java} (71%)
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollRequest.java
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/{response/PipeSubscribeResponseType.java
=> poll/SubscriptionPollRequestType.java} (67%)
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollResponse.java
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/{response/PipeSubscribeResponseType.java
=> poll/SubscriptionPollResponseType.java} (64%)
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/TabletsPayload.java
delete mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/ConsumerHeartbeatWorker.java
delete mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/PullConsumerAutoCommitWorker.java
delete mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionEndpointsSyncer.java
delete mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionMessage.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionProviders.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionFileHandler.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionMessage.java
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{SubscriptionMessagePayload.java
=> payload/SubscriptionMessageHandler.java} (78%)
copy
iotdb-client/{service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeResponseType.java
=>
session/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionMessageType.java}
(67%)
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{ =>
payload}/SubscriptionSessionDataSet.java (82%)
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{SubscriptionSessionDataSets.java
=> payload/SubscriptionSessionDataSetsHandler.java} (55%)
copy
iotdb-client/{service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeRequestVersion.java
=>
session/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionTsFileHandler.java}
(59%)
copy
iotdb-client/{service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeRequestVersion.java
=>
session/src/main/java/org/apache/iotdb/session/subscription/util/RandomStringGenerator.java}
(59%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/timer =>
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/util}/SubscriptionPollTimer.java
(97%)
mode change 100644 => 100755
iotdb-core/datanode/src/assembly/resources/sbin/remove-datanode.sh
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/literal/BinaryLiteral.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/EnrichedTabletsBinaryCache.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingTabletsQueue.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingTsFileQueue.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/{broker/SerializedEnrichedEvent.java
=> event/SubscriptionEvent.java} (53%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/SubscriptionEventBinaryCache.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/SubscriptionTsFileEvent.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/metric/SubscriptionMetrics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/metric/SubscriptionPrefetchingQueueMetrics.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/BlobParserTest.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/load/LoadTsFileRateLimiter.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/limiter/GlobalRateLimiter.java}
(51%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/limiter/PipeEndPointRateLimiter.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/BlobUtils.java
