You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2022/05/02 05:45:20 UTC
[iotdb] branch clean_package updated (c0f3b6edf6 -> 5b9d36bdd3)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch clean_package
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c0f3b6edf6 spotless
add c410efa8d2 fix restart lossing data when sender shutdonws with data remain in memtable (#5740)
add 1529577219 [IOTDB-3048] Refactor binary transformer (#5744)
add cce491190e [IOTDB-3056] triggers support multi-level documents (#5759)
add 8a6031a3c1 [IOTDB-2972] implement local sink/source handle (#5732)
add 5b9d36bdd3 Merge remote-tracking branch 'origin/master' into clean_package
No new revisions were added by this update.
Summary of changes:
docs/UserGuide/Process-Data/Triggers.md | 9 +-
docs/zh/UserGuide/Process-Data/Triggers.md | 7 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 56 +++++++-
.../iotdb/db/engine/storagegroup/DataRegion.java | 3 +
.../db/engine/storagegroup/TsFileManager.java | 2 +-
.../iotdb/db/mpp/buffer/LocalSinkHandle.java | 146 +++++++++++++++++++
.../iotdb/db/mpp/buffer/LocalSourceHandle.java | 125 ++++++++++++++++
.../iotdb/db/mpp/buffer/SharedTsBlockQueue.java | 152 ++++++++++++++++++++
.../execution/datatransfer/DataBlockManager.java | 106 ++++++++++++--
.../execution/datatransfer/IDataBlockManager.java | 24 +++-
.../binary/ArithmeticAdditionTransformer.java | 2 +-
.../binary/ArithmeticBinaryTransformer.java | 12 +-
.../binary/ArithmeticDivisionTransformer.java | 2 +-
.../binary/ArithmeticModuloTransformer.java | 2 +-
.../ArithmeticMultiplicationTransformer.java | 2 +-
.../binary/ArithmeticSubtractionTransformer.java | 2 +-
.../core/transformer/binary/BinaryTransformer.java | 76 ++--------
.../binary/CompareBinaryTransformer.java | 12 +-
.../binary/CompareEqualToTransformer.java | 22 ++-
.../binary/CompareGreaterEqualTransformer.java | 2 +-
.../binary/CompareGreaterThanTransformer.java | 2 +-
.../binary/CompareLessEqualTransformer.java | 2 +-
.../binary/CompareLessThanTransformer.java | 2 +-
.../binary/CompareNonEqualTransformer.java | 22 ++-
.../transformer/binary/LogicAndTransformer.java | 3 +-
.../transformer/binary/LogicBinaryTransformer.java | 18 ++-
.../transformer/binary/LogicOrTransformer.java | 2 +-
.../db/sync/sender/manager/TsFileSyncManager.java | 12 --
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 13 +-
.../db/sync/sender/recovery/TsFilePipeLogger.java | 5 +
.../iotdb/db/mpp/buffer/DataBlockManagerTest.java | 121 ++++++++++++++++
.../iotdb/db/mpp/buffer/LocalSinkHandleTest.java | 151 +++++++++++++++++++
.../iotdb/db/mpp/buffer/LocalSourceHandleTest.java | 119 +++++++++++++++
.../db/mpp/buffer/SharedTsBlockQueueTest.java | 160 +++++++++++++++++++++
.../execution/datatransfer/SourceHandleTest.java | 2 +-
.../iotdb/db/mpp/execution/datatransfer/Utils.java | 6 +
36 files changed, 1274 insertions(+), 130 deletions(-)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/LocalSinkHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/LocalSourceHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/SharedTsBlockQueue.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/buffer/DataBlockManagerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/buffer/LocalSinkHandleTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/buffer/LocalSourceHandleTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/buffer/SharedTsBlockQueueTest.java