This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch QueryIO
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 022c8cb08b6 chaneg version
add 70006df9bbc When the thread is interrupted while retrying a
connection, the loop will exit early. (#14062)
add 57c668ca516 Pipe: atomically publish segment lock to avoid
uninitialized volatile variable (#14064)
add 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)
add 32e701eadd5 Pipe: Pin unpin log frequency decrease (#14049)
add 3aef6ada2cf Pipe: Fixed the bug that historical aligned timeseries'
attributes/tags/alias is not transferred (#14071)
new 449cd54edb0 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:
.../it/env/cluster/config/MppCommonConfig.java | 18 ++
.../env/cluster/config/MppSharedCommonConfig.java | 21 ++
.../it/env/remote/config/RemoteCommonConfig.java | 15 ++
.../org/apache/iotdb/itbase/env/CommonConfig.java | 6 +
...emoIT.java => IoTDBEncryptionValueQueryIT.java} | 11 +-
.../db/it/query/IoTDBLoadEncryptedTsFileIT.java | 204 ++++++++++++++++
.../IoTDBLoadPlainTsFileIT.java} | 104 ++++----
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 56 +++++
.../SubscriptionPipeTimeoutException.java | 2 +-
....java => SubscriptionPollTimeoutException.java} | 12 +-
...tion.java => SubscriptionTimeoutException.java} | 14 +-
.../payload/poll/SubscriptionPollRequest.java | 2 +-
.../apache/iotdb/session/SessionConnection.java | 8 +-
.../consumer/SubscriptionConsumer.java | 173 ++++++++-----
.../SubscriptionExecutorServiceManager.java | 11 +-
.../consumer/SubscriptionProvider.java | 13 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 18 ++
.../schemaregion/SchemaExecutionVisitor.java | 32 ++-
.../subtask/processor/PipeProcessorSubtask.java | 4 +-
.../evolvable/batch/PipeTabletEventBatch.java | 5 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 55 +++--
.../scan/AlignedSinglePageWholeChunkReader.java | 11 +-
.../parser/scan/SinglePageWholeChunkReader.java | 50 +++-
.../db/pipe/resource/memory/PipeMemoryManager.java | 6 +
.../resource/tsfile/PipeTsFileResourceManager.java | 14 +-
.../tsfile/PipeTsFileResourceSegmentLock.java | 9 +-
.../pipe/resource/wal/PipeWALResourceManager.java | 14 +-
.../load/LoadTsFileToTableModelAnalyzer.java | 10 +
.../load/LoadTsFileToTreeModelAnalyzer.java | 10 +
.../iotdb/db/storageengine/buffer/ChunkCache.java | 7 +-
.../fast/reader/CompactionAlignedChunkReader.java | 18 +-
.../fast/reader/CompactionChunkReader.java | 14 +-
.../readchunk/loader/InstantChunkLoader.java | 3 +-
.../readchunk/loader/InstantPageLoader.java | 17 +-
.../compaction/repair/RepairDataFileScanUtil.java | 17 +-
.../filescan/impl/DiskAlignedChunkHandleImpl.java | 11 +-
.../read/filescan/impl/DiskChunkHandleImpl.java | 7 +-
.../dataregion/utils/SharedTimeDataBuffer.java | 8 +-
.../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 +-
.../conf/iotdb-system.properties.template | 15 ++
.../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 +-
pom.xml | 1 +
66 files changed, 1293 insertions(+), 448 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/query/{IoTDBQueryDemoIT.java
=> IoTDBEncryptionValueQueryIT.java} (99%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBLoadEncryptedTsFileIT.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{IoTDBRepairDataIT.java
=> query/IoTDBLoadPlainTsFileIT.java} (53%)
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%)
