This is an automated email from the ASF dual-hosted git repository.
Wei-hao-Li pushed a change to branch deviceEntrySpill-devPr
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 42368c0b4b0 remove useless
add bee3ffc9a33 fix partitionCache
add 46f367457a2 fix some
add d10984dbdb0 fix batch & shared QuerySource mixed
add 5017cddd48b fix applySortProperty of
constructSpilledDeviceTableScanByTags
add 5568de6ee9a fix Materializer
add 667f6663027 fix DeviceEntryCount
add 68eb2febe54 fix setDeviceEntryDataSet
add ff95f377f6e make some code about batch & shared QuerySource mixed clear
add da04c139f66 fix err code & message
add 0b154690d97 fix isFinished/hasNext
add 2e7a8224f37 fix ensureFieldColumnForTreeNonAlignedDeviceViewScan
add 16b52179e36 fix null check of prepareNextDeviceBatch
add 96ca9d6a4f9 fix close exception override
add ab4e919d97f fix FIContext statistics
add 408b65579dd rename metric to DEVICE_ENTRY_DISK_READ_WRITE
add a2c0d645022 reserve frame size
add 510762c12be add timeout logic when segment rpc retry
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 2 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 34 +++++-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 2 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 34 +++++-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 19 ++--
.../query/DeviceEntrySpillNotFoundException.java | 6 +-
.../queryengine/execution/driver/DataDriver.java | 49 ++++-----
.../execution/driver/DataDriverContext.java | 2 +
.../execution/exchange/MPPDataExchangeManager.java | 9 +-
.../fragment/FragmentInstanceContext.java | 53 +++++----
.../operator/source/DataSourceOperator.java | 10 ++
.../relational/AbstractAggTableScanOperator.java | 18 +++-
.../AbstractDefaultAggTableScanOperator.java | 16 ++-
.../relational/AbstractTableScanOperator.java | 15 ++-
.../relational/DeviceIteratorScanOperator.java | 26 ++++-
...onAlignedDeviceViewAggregationScanOperator.java | 9 +-
.../metric/SeriesScanCostMetricSet.java | 16 +--
.../analyze/cache/partition/PartitionCache.java | 119 ++++++++++++++++++---
.../planner/DataNodeTableOperatorGenerator.java | 9 +-
.../plan/planner/LocalExecutionPlanner.java | 5 +-
.../planner/plan/node/PlanGraphJsonPrinter.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 5 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 4 +-
.../spill/AbstractDeviceEntryMaterializer.java | 10 +-
.../spill/DeviceEntryFileSpillerReader.java | 13 ++-
...DeviceEntryMaterializationMemoryController.java | 11 +-
.../metadata/spill/DeviceEntryMaterializer.java | 7 +-
.../spill/DeviceEntryRpcSegmentFetcher.java | 13 ++-
.../spill/DeviceEntrySortedMaterializer.java | 41 ++++---
.../metadata/spill/DeviceEntrySpillManager.java | 38 +++++--
.../spill/LocalSegmentDeviceEntrySource.java | 2 +-
.../metadata/spill/SegmentDeviceEntrySource.java | 12 ++-
.../metadata/spill/SpilledDeviceEntryDataSet.java | 14 +--
.../distribute/TableDistributedPlanGenerator.java | 33 +++++-
.../planner/node/DeviceTableScanNode.java | 2 +
.../optimizations/PushPredicateIntoTableScan.java | 11 +-
.../org/apache/iotdb/db/conf/PropertiesTest.java | 16 +--
.../db/queryengine/execution/DataDriverTest.java | 46 ++++++++
.../conf/iotdb-system.properties.template | 2 +-
41 files changed, 562 insertions(+), 176 deletions(-)
