This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 547e7f6f6b8 Initialize WALNode when DataRegion is created for iotv1
and iotv2 (#14918)
add 85326097340 Memtable enhancement for query (#14591)
No new revisions were added by this update.
Summary of changes:
.../it/env/cluster/config/MppCommonConfig.java | 4 +-
.../env/cluster/config/MppSharedCommonConfig.java | 6 +-
.../it/env/remote/config/RemoteCommonConfig.java | 2 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +-
.../apache/iotdb/db/it/IoTDBDuplicateTimeIT.java | 5 +-
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 4 +-
.../iotdb/db/it/groupby/IoTDBGroupByUnseqIT.java | 2 +-
.../relational/it/db/it/IoTDBRestartTableIT.java | 3 -
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 21 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 12 +-
.../fragment/FragmentInstanceContext.java | 38 ++
.../execution/fragment/QueryContext.java | 9 +
.../schemaregion/utils/ResourceByPathUtils.java | 146 +++-
.../iotdb/db/service/metrics/WritingMetrics.java | 29 +-
.../db/storageengine/dataregion/DataRegion.java | 4 +-
.../dataregion/flush/MemTableFlushTask.java | 16 +-
.../dataregion/memtable/AbstractMemTable.java | 138 ++--
.../memtable/AlignedReadOnlyMemChunk.java | 588 +++++++++++++---
.../memtable/AlignedWritableMemChunk.java | 752 ++++++++++++++++-----
.../memtable/AlignedWritableMemChunkGroup.java | 21 +-
.../dataregion/memtable/IMemTable.java | 8 +-
.../dataregion/memtable/IWritableMemChunk.java | 56 +-
.../memtable/IWritableMemChunkGroup.java | 9 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 274 ++++++--
.../dataregion/memtable/TsFileProcessor.java | 65 +-
.../dataregion/memtable/WritableMemChunk.java | 595 ++++++++++++----
.../dataregion/memtable/WritableMemChunkGroup.java | 30 +-
.../filescan/impl/MemAlignedChunkHandleImpl.java | 21 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 259 ++++++-
.../read/reader/chunk/MemAlignedPageReader.java | 137 +++-
.../read/reader/chunk/MemChunkReader.java | 139 +++-
.../read/reader/chunk/MemPageReader.java | 129 +++-
.../reader/chunk/metadata/AlignedPageMetadata.java | 74 ++
.../read/reader/chunk/metadata/PageMetadata.java | 90 +++
.../dataregion/tsfile/TsFileResource.java | 39 +-
.../db/utils/datastructure/AlignedTVList.java | 412 ++++++++---
.../db/utils/datastructure/BackAlignedTVList.java | 66 +-
.../db/utils/datastructure/BackBinaryTVList.java | 72 +-
.../db/utils/datastructure/BackBooleanTVList.java | 71 +-
.../db/utils/datastructure/BackDoubleTVList.java | 71 +-
.../db/utils/datastructure/BackFloatTVList.java | 71 +-
.../db/utils/datastructure/BackIntTVList.java | 72 +-
.../db/utils/datastructure/BackLongTVList.java | 71 +-
.../iotdb/db/utils/datastructure/BackwardSort.java | 66 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 128 ++--
.../db/utils/datastructure/BooleanTVList.java | 75 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 76 ++-
.../iotdb/db/utils/datastructure/FloatTVList.java | 76 ++-
.../iotdb/db/utils/datastructure/IntTVList.java | 75 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 75 +-
.../MergeSortAlignedTVListIterator.java | 242 +++++++
.../datastructure/MergeSortTvListIterator.java | 162 +++++
.../PageColumnAccessInfo.java} | 43 +-
.../db/utils/datastructure/QuickAlignedTVList.java | 34 +-
.../db/utils/datastructure/QuickBinaryTVList.java | 34 +-
.../db/utils/datastructure/QuickBooleanTVList.java | 31 +-
.../db/utils/datastructure/QuickDoubleTVList.java | 31 +-
.../db/utils/datastructure/QuickFloatTVList.java | 31 +-
.../db/utils/datastructure/QuickIntTVList.java | 37 +-
.../db/utils/datastructure/QuickLongTVList.java | 31 +-
.../iotdb/db/utils/datastructure/QuickSort.java | 28 +-
.../iotdb/db/utils/datastructure/TVList.java | 363 +++++++++-
.../db/utils/datastructure/TimAlignedTVList.java | 109 +--
.../db/utils/datastructure/TimBinaryTVList.java | 113 +---
.../db/utils/datastructure/TimBooleanTVList.java | 111 +--
.../db/utils/datastructure/TimDoubleTVList.java | 111 +--
.../db/utils/datastructure/TimFloatTVList.java | 112 +--
.../iotdb/db/utils/datastructure/TimIntTVList.java | 112 +--
.../db/utils/datastructure/TimLongTVList.java | 111 +--
.../iotdb/db/utils/datastructure/TimSort.java | 105 ++-
.../storageengine/dataregion/DataRegionTest.java | 6 +-
.../memtable/MemChunkDeserializeTest.java | 332 +++++++++
.../dataregion/memtable/PrimitiveMemTableTest.java | 41 +-
.../dataregion/memtable/TsFileProcessorTest.java | 448 ++++++++++--
.../read/control/FileReaderManagerTest.java | 5 +-
.../reader/chunk/AlignedMemPageReaderTest.java | 32 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 138 ++--
.../read/reader/chunk/MemChunkLoaderTest.java | 260 ++++---
.../read/reader/chunk/MemPageReaderTest.java | 12 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 18 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 -
.../db/utils/datastructure/AlignedTVListTest.java | 20 +-
.../db/utils/datastructure/BinaryTVListTest.java | 30 -
.../conf/iotdb-system.properties.template | 31 +-
84 files changed, 5827 insertions(+), 2705 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/metadata/AlignedPageMetadata.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/metadata/PageMetadata.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MergeSortAlignedTVListIterator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MergeSortTvListIterator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/{SetThreadName.java
=> datastructure/PageColumnAccessInfo.java} (57%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/MemChunkDeserializeTest.java
