This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e1cc2294e7d Add or modify encryption related codes (#13364)
add 34221fb035f Subscription: avoid the file reading when the memory is
not enough for tsfile slicing & implement all-out effort global timeout control
& support client resume from breakpoint for tsfile consumption (#13992)
No new revisions were added by this update.
Summary of changes:
.../SubscriptionPipeTimeoutException.java | 2 +-
....java => SubscriptionPollTimeoutException.java} | 12 +-
...tion.java => SubscriptionTimeoutException.java} | 14 +-
.../payload/poll/SubscriptionPollRequest.java | 2 +-
.../consumer/SubscriptionConsumer.java | 173 ++++++++-----
.../SubscriptionExecutorServiceManager.java | 11 +-
.../consumer/SubscriptionProvider.java | 13 +-
.../subtask/processor/PipeProcessorSubtask.java | 4 +-
.../evolvable/batch/PipeTabletEventBatch.java | 5 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 55 +++--
.../db/pipe/resource/memory/PipeMemoryManager.java | 6 +
.../agent/SubscriptionReceiverAgent.java | 13 +
.../broker/SubscriptionPrefetchingQueue.java | 22 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 22 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 35 +--
.../db/subscription/event/SubscriptionEvent.java | 6 +-
.../event/batch/SubscriptionPipeEventBatch.java | 6 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 6 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 8 +-
.../SubscriptionEventExtendableResponse.java | 10 -
.../event/response/SubscriptionEventResponse.java | 4 +-
.../response/SubscriptionEventSingleResponse.java | 2 +-
.../response/SubscriptionEventTabletResponse.java | 10 +
.../response/SubscriptionEventTsFileResponse.java | 73 +++++-
.../receiver/SubscriptionReceiver.java | 2 +
.../receiver/SubscriptionReceiverV1.java | 271 +++++++++++----------
.../execution/SubscriptionSubtaskExecutor.java | 50 ++++
.../execution/SubscriptionSubtaskScheduler.java} | 25 +-
.../task/subtask/SubscriptionConnectorSubtask.java | 44 +++-
.../task/subtask/SubscriptionReceiverSubtask.java | 7 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 22 +-
.../iotdb/commons/conf/CommonDescriptor.java | 11 +-
.../agent/task/execution/PipeSubtaskExecutor.java | 32 ++-
.../task/subtask/PipeAbstractConnectorSubtask.java | 12 +-
.../pipe/agent/task/subtask/PipeSubtask.java | 4 +-
.../resource/ref/PipePhantomReferenceManager.java | 4 +-
.../subscription/config/SubscriptionConfig.java | 14 +-
37 files changed, 665 insertions(+), 347 deletions(-)
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/exception/{SubscriptionPipeTimeoutException.java
=> SubscriptionPollTimeoutException.java} (74%)
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/exception/{SubscriptionRuntimeException.java
=> SubscriptionTimeoutException.java} (71%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/agent/task/execution/PipeProcessorSubtaskExecutor.java
=> subscription/task/execution/SubscriptionSubtaskScheduler.java} (61%)
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/configuration/PipeRuntimeConfiguration.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionReceiverSubtask.java
(83%)
