This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch iotdb-1971
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from be43397 [IOTDB-2063] Fix MinTimeDescAggregationResult implementation
(#4471)
new 700669e refactor dataset package structure
new dd8f44d UDTFJoinDataSet
add 6487443 [IOTDB-2065] TsFileSequenceReader will be cached for 100s
even no longer used (#4478)
add f5a7b99 [IOTDB-1899] Fix stream closed exception during compaction
(#4457)
add 6c0289e Upgrade lz4 from 1.3.0 to 1.8.0 due to CVE-2019-17543 (#4485)
new ed4c2f0 Merge branch 'master' of github.com:apache/iotdb into
iotdb-1971
new 1ac17c5 UDTFFragmentDataSet
new 49e950c main flow
The 5 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:
.../apache/iotdb/cluster/metadata/CMManager.java | 4 +-
.../cluster/query/ClusterUDTFQueryExecutor.java | 4 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 4 +-
.../handlers/caller/ShowTimeSeriesHandler.java | 2 +-
pom.xml | 6 +-
.../apache/iotdb/db/cq/ContinuousQueryService.java | 2 +-
.../db/engine/compaction/CompactionScheduler.java | 3 +-
.../engine/compaction/CompactionTaskManager.java | 36 ++-
.../inner/AbstractInnerSpaceCompactionTask.java | 2 +
.../sizetiered/SizeTieredCompactionSelector.java | 2 +-
.../inner/sizetiered/SizeTieredCompactionTask.java | 105 ++++-----
.../compaction/task/AbstractCompactionTask.java | 2 +
.../compaction/task/CompactionRecoverTask.java | 2 +-
.../org/apache/iotdb/db/metadata/MManager.java | 4 +-
.../org/apache/iotdb/db/metadata/mtree/MTree.java | 2 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 6 +-
.../iotdb/db/query/control/FileReaderManager.java | 110 +++------
.../iotdb/db/query/control/SessionManager.java | 2 +-
.../dataset/RawQueryDataSetWithValueFilter.java | 1 +
.../dataset/RawQueryDataSetWithoutValueFilter.java | 1 +
.../{ => show}/ShowContinuousQueriesResult.java | 2 +-
.../db/query/dataset/{ => show}/ShowDataSet.java | 2 +-
.../dataset/{ => show}/ShowDevicesDataSet.java | 2 +-
.../dataset/{ => show}/ShowDevicesResult.java | 2 +-
.../db/query/dataset/{ => show}/ShowResult.java | 2 +-
.../dataset/{ => show}/ShowTimeSeriesResult.java | 2 +-
.../dataset/{ => show}/ShowTimeseriesDataSet.java | 2 +-
.../query/dataset/{ => udf}/UDFInputDataSet.java | 2 +-
.../dataset/{ => udf}/UDTFAlignByTimeDataSet.java | 28 ++-
.../db/query/dataset/{ => udf}/UDTFDataSet.java | 34 ++-
.../dataset/udf/UDTFFragmentDataSet.java} | 15 +-
.../db/query/dataset/udf/UDTFJoinDataSet.java | 112 +++++++++
.../dataset/{ => udf}/UDTFNonAlignDataSet.java | 7 +-
.../iotdb/db/query/executor/UDTFQueryExecutor.java | 10 +-
.../layer/{DAGBuilder.java => LayerBuilder.java} | 19 +-
.../db/query/udf/core/layer/LayerCacheUtils.java | 2 +-
.../layer/MultiInputColumnIntermediateLayer.java | 2 +-
.../query/udf/core/layer/RawQueryInputLayer.java | 2 +-
.../iotdb/db/engine/cache/ChunkCacheTest.java | 1 -
.../engine/compaction/CompactionSchedulerTest.java | 18 +-
.../compaction/CompactionTaskManagerTest.java | 252 +++++++++++++++++++++
.../db/engine/compaction/cross/MergeTest.java | 1 -
.../compaction/inner/InnerCompactionChunkTest.java | 4 +-
.../compaction/inner/InnerCompactionLogTest.java | 4 +-
.../inner/InnerCompactionMoreDataTest.java | 2 +-
.../inner/InnerCompactionSchedulerTest.java | 4 +-
.../compaction/inner/InnerCompactionTest.java | 3 +-
.../inner/InnerSpaceCompactionUtilsTest.java | 4 +-
.../SizeTieredCompactionRecoverTest.java | 1 -
.../inner/sizetiered/SizeTieredCompactionTest.java | 1 -
.../task/FakedInnerSpaceCompactionTask.java | 44 ++--
.../compaction/utils/CompactionClearUtils.java | 1 -
.../engine/storagegroup/FakedTsFileResource.java | 11 +
.../storagegroup/StorageGroupProcessorTest.java | 2 +-
.../db/integration/IoTDBNewTsFileCompactionIT.java | 2 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 2 +-
.../iotdb/db/metadata/mlog/MLogUpgraderTest.java | 2 +-
.../db/query/control/FileReaderManagerTest.java | 19 +-
.../iotdb/db/query/dataset/ListDataSetTest.java | 1 +
.../db/query/dataset/ShowDevicesResultTest.java | 2 +
.../db/query/dataset/ShowTimeSeriesResultTest.java | 1 +
.../query/dataset/UDTFAlignByTimeDataSetTest.java | 1 +
.../query/reader/series/SeriesReaderTestUtil.java | 1 -
.../iotdb/db/rescon/ResourceManagerTest.java | 1 -
tsfile/pom.xml | 6 +-
.../apache/iotdb/tsfile/read/common/RowRecord.java | 5 +
66 files changed, 669 insertions(+), 274 deletions(-)
rename server/src/main/java/org/apache/iotdb/db/query/dataset/{ =>
show}/ShowContinuousQueriesResult.java (97%)
rename server/src/main/java/org/apache/iotdb/db/query/dataset/{ =>
show}/ShowDataSet.java (97%)
rename server/src/main/java/org/apache/iotdb/db/query/dataset/{ =>
show}/ShowDevicesDataSet.java (98%)
rename server/src/main/java/org/apache/iotdb/db/query/dataset/{ =>
show}/ShowDevicesResult.java (97%)
rename server/src/main/java/org/apache/iotdb/db/query/dataset/{ =>
show}/ShowResult.java (96%)
rename server/src/main/java/org/apache/iotdb/db/query/dataset/{ =>
show}/ShowTimeSeriesResult.java (99%)
rename server/src/main/java/org/apache/iotdb/db/query/dataset/{ =>
show}/ShowTimeseriesDataSet.java (98%)
rename server/src/main/java/org/apache/iotdb/db/query/dataset/{ =>
udf}/UDFInputDataSet.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/dataset/{ =>
udf}/UDTFAlignByTimeDataSet.java (92%)
rename server/src/main/java/org/apache/iotdb/db/query/dataset/{ =>
udf}/UDTFDataSet.java (84%)
copy
server/src/main/java/org/apache/iotdb/db/{exception/UDFRegistrationException.java
=> query/dataset/udf/UDTFFragmentDataSet.java} (71%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/dataset/udf/UDTFJoinDataSet.java
rename server/src/main/java/org/apache/iotdb/db/query/dataset/{ =>
udf}/UDTFNonAlignDataSet.java (97%)
rename
server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/{DAGBuilder.java
=> LayerBuilder.java} (89%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/CompactionTaskManagerTest.java
