This is an automated email from the ASF dual-hosted git repository.
ericpai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 4a70fba [IOTDB-2658] Generate logical plan for query statement (#5356)
add bcd53d7 [IOTDB-2810] Design and implementation of TsBlock and its
builder (#5362)
No new revisions were added by this update.
Summary of changes:
pom.xml | 10 +
.../apache/iotdb/db/mpp/buffer/ISinkHandle.java | 2 +-
.../apache/iotdb/db/mpp/buffer/ISourceHandle.java | 2 +-
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 2 +-
.../org/apache/iotdb/db/mpp/operator/Operator.java | 2 +-
.../db/mpp/operator/process/AggregateOperator.java | 2 +-
.../mpp/operator/process/DeviceMergeOperator.java | 2 +-
.../db/mpp/operator/process/FillOperator.java | 2 +-
.../mpp/operator/process/FilterNullOperator.java | 2 +-
.../mpp/operator/process/GroupByLevelOperator.java | 2 +-
.../db/mpp/operator/process/LimitOperator.java | 6 +-
.../db/mpp/operator/process/OffsetOperator.java | 2 +-
.../db/mpp/operator/process/SortOperator.java | 2 +-
.../db/mpp/operator/process/TimeJoinOperator.java | 41 ++-
.../db/mpp/operator/sink/FragmentSinkOperator.java | 2 +-
.../iotdb/db/mpp/operator/sink/SinkOperator.java | 2 +-
.../operator/source/AlignedSeriesScanUtil.java} | 57 ++--
.../source/SeriesAggregateScanOperator.java | 2 +-
.../db/mpp/operator/source/SeriesScanOperator.java | 4 +-
.../db/mpp/operator/source/SeriesScanUtil.java | 60 ++--
.../query/reader/chunk/MemAlignedPageReader.java | 39 ++-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 119 +++++---
tsfile/pom.xml | 8 +
.../apache/iotdb/tsfile/read/common/Column.java | 21 --
.../iotdb/tsfile/read/common/TimeColumn.java | 21 --
.../apache/iotdb/tsfile/read/common/TsBlock.java | 175 ------------
.../iotdb/tsfile/read/common/block/TsBlock.java | 317 +++++++++++++++++++++
.../tsfile/read/common/block/TsBlockBuilder.java | 295 +++++++++++++++++++
.../read/common/block/TsBlockBuilderStatus.java | 75 +++++
.../read/common/{ => block}/TsBlockMetadata.java | 2 +-
.../read/common/block/column/BinaryColumn.java | 110 +++++++
.../common/block/column/BinaryColumnBuilder.java | 148 ++++++++++
.../read/common/block/column/BooleanColumn.java | 109 +++++++
.../common/block/column/BooleanColumnBuilder.java | 150 ++++++++++
.../tsfile/read/common/block/column/Column.java | 87 ++++++
.../read/common/block/column/ColumnBuilder.java | 81 ++++++
.../common/block/column/ColumnBuilderStatus.java | 88 ++++++
.../read/common/block/column/ColumnUtil.java | 97 +++++++
.../read/common/block/column/DoubleColumn.java | 109 +++++++
.../common/block/column/DoubleColumnBuilder.java | 150 ++++++++++
.../read/common/block/column/FloatColumn.java | 108 +++++++
.../common/block/column/FloatColumnBuilder.java | 150 ++++++++++
.../tsfile/read/common/block/column/IntColumn.java | 108 +++++++
.../read/common/block/column/IntColumnBuilder.java | 150 ++++++++++
.../read/common/block/column/LongColumn.java | 108 +++++++
.../common/block/column/LongColumnBuilder.java | 150 ++++++++++
.../block/column/RunLengthEncodedColumn.java | 133 +++++++++
.../read/common/block/column/TimeColumn.java | 95 ++++++
.../common/block/column/TimeColumnBuilder.java | 126 ++++++++
.../iotdb/tsfile/read/reader/IPageReader.java | 2 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 43 ++-
.../iotdb/tsfile/read/reader/page/PageReader.java | 87 ++++--
.../iotdb/tsfile/common/block/TsBlockTest.java | 317 +++++++++++++++++++++
53 files changed, 3606 insertions(+), 378 deletions(-)
copy
server/src/main/java/org/apache/iotdb/db/{query/reader/series/AlignedSeriesReader.java
=> mpp/operator/source/AlignedSeriesScanUtil.java} (71%)
delete mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/Column.java
delete mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/TimeColumn.java
delete mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/TsBlock.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/TsBlock.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/TsBlockBuilder.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/TsBlockBuilderStatus.java
rename tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/{ =>
block}/TsBlockMetadata.java (97%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/BinaryColumn.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/BinaryColumnBuilder.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/BooleanColumn.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/BooleanColumnBuilder.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/Column.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnBuilder.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnBuilderStatus.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnUtil.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/DoubleColumn.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/DoubleColumnBuilder.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/FloatColumn.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/FloatColumnBuilder.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/IntColumn.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/IntColumnBuilder.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/LongColumn.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/LongColumnBuilder.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/RunLengthEncodedColumn.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/TimeColumn.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/TimeColumnBuilder.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/TsBlockTest.java
