This is an automated email from the ASF dual-hosted git repository.
Wei-hao-Li pushed a change to branch deviceEntrySpill-dev2
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 96b953f43f6 module-2
add 16560fd89b9 module-3
No new revisions were added by this update.
Summary of changes:
.../iotdb/db/i18n/DataNodeQueryMessages.java | 3 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 3 +
.../execution/exchange/MPPDataExchangeManager.java | 48 ++++++
...ntryReader.java => BatchDeviceEntrySource.java} | 9 +-
.../metadata/spill/DeviceEntryDataSetHandle.java | 2 +-
.../metadata/spill/DeviceEntryReader.java | 6 +-
.../spill/DeviceEntryRpcSegmentFetcher.java | 111 +++++++++++++
.../DeviceEntrySegmentFetcher.java} | 11 +-
.../metadata/spill/DeviceEntrySpillManager.java | 39 ++---
...DataSet.java => InMemoryDeviceEntrySource.java} | 32 ++--
.../spill/LocalSegmentDeviceEntrySource.java | 64 ++++++++
...et.java => RemoteSegmentDeviceEntrySource.java} | 39 +++--
.../metadata/spill/SegmentDeviceEntrySource.java | 78 +++++++++
.../optimizations/QueryCardinalityUtil.java | 4 +-
.../spill/DeviceEntryRpcSegmentFetcherTest.java | 93 +++++++++++
.../spill/SegmentDeviceEntrySourceTest.java | 176 +++++++++++++++++++++
.../src/main/thrift/datanode.thrift | 15 ++
17 files changed, 673 insertions(+), 60 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/{DeviceEntryReader.java
=> BatchDeviceEntrySource.java} (83%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryRpcSegmentFetcher.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/{TableHandle.java
=> spill/DeviceEntrySegmentFetcher.java} (80%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/{DeviceEntryDataSet.java
=> InMemoryDeviceEntrySource.java} (64%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/LocalSegmentDeviceEntrySource.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/{DeviceEntryDataSet.java
=> RemoteSegmentDeviceEntrySource.java} (52%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/SegmentDeviceEntrySource.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryRpcSegmentFetcherTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/SegmentDeviceEntrySourceTest.java
