This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch expr
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 8d02321 add async interface in LogDispatcher fix tests
add 010af34 Fix error in the test-only constructor of AlignedSeriesReader
(#4675)
add fa4fb46 Fix aligned bug of metadata module (#4701)
add 9dca629 Fix Query Deadlock (#4704)
add 99600d2 [IOTDB-2249] Fix query NPE when an aligned column with
duplicated time is deleted (#4702)
add de2e626 [IOTDB-2101] Reduce the memory footprint of QueryDataSource
(#4654)
add 3cbf9af [Docs] Add doc about insert data into aligned timeseries
(#4705)
add 4171098 fix ClientManager not closed
add 0f62c08 fix AsyncMetaClientTest
add 0dfe0b1 Fix QueryFrequencyRecorder thread leaking Fix WalTrim thread
leaking Add thread names
add df88404 fix unstopped members
new bf127a3 Merge branch 'client_manager_add_close' into expr
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 11 +-
.../apache/iotdb/cluster/client/BaseFactory.java | 13 +
.../apache/iotdb/cluster/client/ClientManager.java | 37 ++-
.../iotdb/cluster/client/IClientManager.java | 2 +
.../cluster/client/async/AsyncDataClient.java | 4 +
.../log/sequencing/AsynchronousSequencer.java | 12 +-
.../iotdb/cluster/log/sequencing/LogSequencer.java | 2 +
.../log/sequencing/SynchronousSequencer.java | 5 +
.../cluster/query/ClusterUDTFQueryExecutor.java | 4 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 20 +-
.../iotdb/cluster/server/StoppedMemberManager.java | 6 +
.../cluster/server/member/DataGroupMember.java | 4 +-
.../cluster/server/member/MetaGroupMember.java | 4 +-
.../iotdb/cluster/server/member/RaftMember.java | 28 +-
.../cluster/server/service/DataAsyncService.java | 2 +-
.../cluster/server/service/DataGroupEngine.java | 2 +
.../cluster/server/service/DataSyncService.java | 2 +-
.../iotdb/cluster/client/ClientManagerTest.java | 300 ++++++++++++---------
.../cluster/client/ClientPoolFactoryTest.java | 4 +
.../iotdb/cluster/client/MockClientManager.java | 3 +
.../cluster/client/async/AsyncDataClientTest.java | 2 +
.../cluster/client/async/AsyncMetaClientTest.java | 2 +
.../iotdb/cluster/common/TestDataGroupMember.java | 6 +-
.../iotdb/cluster/common/TestMetaGroupMember.java | 7 +-
.../iotdb/cluster/log/LogDispatcherTest.java | 13 +-
.../cluster/log/applier/DataLogApplierTest.java | 5 +-
.../cluster/log/applier/MetaLogApplierTest.java | 1 -
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 1 -
.../cluster/log/catchup/LogCatchUpTaskTest.java | 1 -
.../log/catchup/SnapshotCatchUpTaskTest.java | 1 -
.../cluster/log/snapshot/DataSnapshotTest.java | 2 -
.../log/snapshot/MetaSimpleSnapshotTest.java | 1 -
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 2 -
.../query/ClusterAggregateExecutorTest.java | 7 +
.../query/ClusterDataQueryExecutorTest.java | 87 ++++++
.../query/fill/ClusterFillExecutorTest.java | 7 +
.../ClusterGroupByNoVFilterDataSetTest.java | 7 +
.../groupby/ClusterGroupByVFilterDataSetTest.java | 7 +
.../query/groupby/MergeGroupByExecutorTest.java | 7 +
.../query/groupby/RemoteGroupByExecutorTest.java | 7 +
.../query/last/ClusterLastQueryExecutorTest.java | 7 +
.../query/reader/ClusterReaderFactoryTest.java | 7 +
.../query/reader/ClusterTimeGeneratorTest.java | 7 +
.../cluster/query/reader/DatasourceInfoTest.java | 4 +
.../reader/RemoteSeriesReaderByTimestampTest.java | 3 +
.../query/reader/RemoteSimpleSeriesReaderTest.java | 4 +
.../mult/AssignPathManagedMergeReaderTest.java | 4 +
.../reader/mult/RemoteMultSeriesReaderTest.java | 7 +
.../server/clusterinfo/ClusterInfoServerTest.java | 6 +-
.../clusterinfo/ClusterInfoServiceImplTest.java | 9 +-
.../caller/AppendNodeEntryHandlerTest.java | 1 -
.../handlers/caller/ElectionHandlerTest.java | 1 -
.../handlers/caller/HeartbeatHandlerTest.java | 1 -
.../handlers/caller/LogCatchUpHandlerTest.java | 1 -
.../server/heartbeat/DataHeartbeatThreadTest.java | 2 +-
.../server/heartbeat/HeartbeatThreadTest.java | 1 -
.../iotdb/cluster/server/member/BaseMember.java | 16 +-
.../cluster/server/member/DataGroupMemberTest.java | 12 +-
.../cluster/server/member/MetaGroupMemberTest.java | 18 +-
.../cluster/server/member/RaftMemberTest.java | 15 ++
.../UserGuide/Data-Concept/Auto-Create-MetaData.md | 14 +-
docs/UserGuide/Data-Concept/Compression.md | 95 ++++++-
.../Data-Concept/Data-Model-and-Terminology.md | 37 ++-
docs/UserGuide/Data-Concept/Data-Type.md | 14 +-
docs/UserGuide/Data-Concept/Encoding.md | 11 +-
docs/UserGuide/Data-Concept/SDT.md | 111 --------
docs/UserGuide/Data-Concept/Schema-Template.md | 8 +-
docs/UserGuide/Data-Concept/Time-Partition.md | 8 +-
.../DML-Data-Manipulation-Language.md | 33 ++-
.../UserGuide/Data-Concept/Auto-Create-MetaData.md | 14 +-
docs/zh/UserGuide/Data-Concept/Compression.md | 90 ++++++-
.../Data-Concept/Data-Model-and-Terminology.md | 34 ++-
docs/zh/UserGuide/Data-Concept/Data-Type.md | 18 +-
docs/zh/UserGuide/Data-Concept/Encoding.md | 6 +-
docs/zh/UserGuide/Data-Concept/SDT.md | 106 --------
docs/zh/UserGuide/Data-Concept/Schema-Template.md | 32 +--
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 8 +-
.../DML-Data-Manipulation-Language.md | 29 +-
.../integration/IOTDBGroupByInnerIntervalIT.java | 2 +-
.../IoTDBQueryWithComplexValueFilterIT.java | 122 +++++++++
.../db/integration/aligned/IoTDBDeletionIT.java | 31 +++
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 4 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 51 ++--
.../db/engine/querycontext/QueryDataSource.java | 45 ++++
.../db/engine/storagegroup/TsFileProcessor.java | 74 ++---
.../db/engine/storagegroup/TsFileResource.java | 209 ++++++++++----
.../storagegroup/VirtualStorageGroupProcessor.java | 61 +++--
.../virtualSg/StorageGroupManager.java | 9 +
.../org/apache/iotdb/db/metadata/MManager.java | 21 +-
.../org/apache/iotdb/db/metadata/mtree/MTree.java | 23 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 6 +-
.../iotdb/db/metadata/path/MeasurementPath.java | 8 +-
.../apache/iotdb/db/metadata/path/PartialPath.java | 7 +
.../apache/iotdb/db/metadata/tag/TagManager.java | 24 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 4 +
.../iotdb/db/query/context/QueryContext.java | 9 +
.../db/query/control/QueryResourceManager.java | 110 +++++++-
.../db/query/control/tracing/TracingInfo.java | 8 +
.../db/query/control/tracing/TracingManager.java | 4 +
.../dataset/RawQueryDataSetWithoutValueFilter.java | 17 +-
.../groupby/GroupByWithValueFilterDataSet.java | 30 ++-
.../groupby/GroupByWithoutValueFilterDataSet.java | 24 +-
.../dataset/groupby/LocalGroupByExecutor.java | 5 +-
.../db/query/executor/AggregationExecutor.java | 49 +++-
.../iotdb/db/query/executor/FillQueryExecutor.java | 113 +++++---
.../iotdb/db/query/executor/LastQueryExecutor.java | 14 +-
.../db/query/executor/RawDataQueryExecutor.java | 38 ++-
.../iotdb/db/query/executor/UDFQueryExecutor.java | 4 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 4 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 4 +-
.../query/reader/series/SeriesAggregateReader.java | 27 ++
.../reader/series/SeriesRawDataBatchReader.java | 1 -
.../iotdb/db/query/reader/series/SeriesReader.java | 212 ++++++++++-----
.../reader/series/SeriesReaderByTimestamp.java | 27 ++
.../query/timegenerator/ServerTimeGenerator.java | 60 ++++-
.../db/service/basic/BasicServiceProvider.java | 3 +-
.../db/service/basic/QueryFrequencyRecorder.java | 19 +-
.../db/service/thrift/impl/TSServiceImpl.java | 1 +
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 5 +-
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 26 ++
.../db/utils/datastructure/AlignedTVList.java | 20 +-
.../engine/modification/DeletionFileNodeTest.java | 44 ++-
.../storagegroup/StorageGroupProcessorTest.java | 70 ++++-
.../iotdb/db/engine/storagegroup/TTLTest.java | 23 +-
.../engine/storagegroup/TsFileProcessorTest.java | 40 +--
.../iotdb/db/metadata/MManagerBasicTest.java | 48 +++-
.../reader/series/SeriesAggregateReaderTest.java | 6 +-
.../reader/series/SeriesReaderByTimestampTest.java | 6 +-
site/src/main/.vuepress/config.js | 10 +-
.../read/query/timegenerator/TimeGenerator.java | 3 +
.../query/timegenerator/TsFileTimeGenerator.java | 6 +
.../tsfile/read/reader/FakedTimeGenerator.java | 6 +
132 files changed, 2294 insertions(+), 935 deletions(-)
delete mode 100644 docs/UserGuide/Data-Concept/SDT.md
delete mode 100644 docs/zh/UserGuide/Data-Concept/SDT.md
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryWithComplexValueFilterIT.java
