This is an automated email from the ASF dual-hosted git repository.
lta pushed a change to branch cluster
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 111e619 add apache header for cluster config test
new 5f75d81 fix a doc bug of Readme.md (#128)
new ef6ca4c Log debug the FileNotFoundException, throws the IOException
(#122)
new 0a85c19 Minor modification of README.md (#127)
new e0d4e33
[IOTDB-47][IOTDB-54][IOTDB-59][IOTDB-60]Aggregate+GroupBy+Fill (#97)
new afea492 Fix [IOTDB-37]A WAL check tool script is desired
new 9749349 Merge pull request #129 from FLOW4215/WalChecker
new acb850d Add create timeseries Operator (#130)
new 811168c merge master
new 3adef51 modify data state machine
The 1657 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:
Readme.md => README.md | 40 +-
.../cluster/entity/raft/DataStateMachine.java | 2 +-
.../cluster/qp/executor/NonQueryExecutor.java | 1 +
.../bin/{start-server.bat => start-WalChecker.bat} | 22 +-
.../bin/{start-server.sh => start-WalChecker.sh} | 29 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +
.../apache/iotdb/db/auth/entity/PrivilegeType.java | 2 +-
.../db/engine/overflow/io/OverflowResource.java | 4 +-
.../db/engine/querycontext/ReadOnlyMemChunk.java | 7 -
.../java/org/apache/iotdb/db/metadata/MTree.java | 2 +-
.../org/apache/iotdb/db/qp/QueryProcessor.java | 1 +
.../iotdb/db/qp/executor/OverflowQPExecutor.java | 45 +-
.../iotdb/db/qp/executor/QueryProcessExecutor.java | 99 ++-
.../org/apache/iotdb/db/qp/logical/Operator.java | 2 +-
.../iotdb/db/qp/logical/sys/MetadataOperator.java | 4 +-
.../iotdb/db/qp/physical/sys/MetadataPlan.java | 6 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 2 +
.../db/query/aggregation/AggreFuncFactory.java | 79 ++
.../db/query/aggregation/AggreResultData.java | 192 +++++
.../db/query/aggregation/AggregateFunction.java | 135 ++++
.../db/query/aggregation/impl/CountAggrFunc.java | 155 ++++
.../db/query/aggregation/impl/FirstAggrFunc.java | 154 ++++
.../db/query/aggregation/impl/LastAggrFunc.java | 151 ++++
.../db/query/aggregation/impl/MaxTimeAggrFunc.java | 135 ++++
.../query/aggregation/impl/MaxValueAggrFunc.java | 170 ++++
.../db/query/aggregation/impl/MeanAggrFunc.java | 163 ++++
.../db/query/aggregation/impl/MinTimeAggrFunc.java | 156 ++++
.../query/aggregation/impl/MinValueAggrFunc.java | 166 ++++
.../db/query/aggregation/impl/SumAggrFunc.java | 28 +-
.../iotdb/db/query/context/QueryContext.java | 17 +
...edFilePathsManager.java => JobFileManager.java} | 78 +-
.../db/query/control/QueryDataSourceManager.java | 53 --
...TokenManager.java => QueryResourceManager.java} | 86 +-
.../query/dataset/AggreResultDataPointReader.java | 52 ++
.../dataset/EngineDataSetWithTimeGenerator.java | 7 +-
.../dataset/EngineDataSetWithoutTimeGenerator.java | 16 +-
.../db/query/executor/AggregateEngineExecutor.java | 330 ++++++++
.../executor/EngineExecutorWithTimeGenerator.java | 55 +-
.../EngineExecutorWithoutTimeGenerator.java | 41 +-
.../iotdb/db/query/executor/EngineQueryRouter.java | 180 ++++-
.../db/query/executor/FillEngineExecutor.java | 91 +++
.../executor/groupby/GroupByEngineDataSet.java | 167 ++++
.../GroupByWithOnlyTimeFilterDataSetDataSet.java | 314 +++++++
.../GroupByWithValueFilterDataSetDataSet.java | 160 ++++
.../db/query/factory/SeriesReaderFactory.java | 129 ++-
.../java/org/apache/iotdb/db/query/fill/IFill.java | 79 +-
.../org/apache/iotdb/db/query/fill/LinearFill.java | 90 ++-
.../apache/iotdb/db/query/fill/PreviousFill.java | 36 +-
.../iotdb/db/query/reader/AllDataReader.java | 129 +++
.../iotdb/db/query/reader/IAggregateReader.java | 21 +-
.../apache/iotdb/db/query/reader/IBatchReader.java | 10 +-
.../apache/iotdb/db/query/reader/IPointReader.java | 12 +-
.../org/apache/iotdb/db/query/reader/IReader.java | 14 +-
...nkReaderWithFilter.java => MemChunkReader.java} | 57 +-
.../reader/mem/MemChunkReaderByTimestamp.java | 37 +-
.../reader/mem/MemChunkReaderWithoutFilter.java | 70 --
.../reader/merge/EngineReaderByTimeStamp.java | 8 +-
.../db/query/reader/merge/PriorityMergeReader.java | 56 +-
.../merge/PriorityMergeReaderByTimestamp.java | 60 +-
.../query/reader/sequence/SealedTsFilesReader.java | 151 ++--
.../sequence/SealedTsFilesReaderByTimestamp.java | 136 ++++
.../query/reader/sequence/SequenceDataReader.java | 106 ++-
.../sequence/SequenceDataReaderByTimestamp.java | 108 +++
.../reader/sequence/UnSealedTsFileReader.java | 65 +-
.../sequence/UnSealedTsFilesReaderByTimestamp.java | 64 ++
.../query/reader/unsequence/EngineChunkReader.java | 39 +-
.../unsequence/EngineChunkReaderByTimestamp.java | 77 ++
.../db/query/timegenerator/EngineLeafNode.java | 11 +-
.../query/timegenerator/EngineNodeConstructor.java | 22 +-
.../query/timegenerator/EngineTimeGenerator.java | 10 +-
.../modification => rescon}/package-info.java | 5 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 1 -
.../org/apache/iotdb/db/service/TSServiceImpl.java | 58 +-
.../java/org/apache/iotdb/db/utils/AuthUtils.java | 2 +
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 3 +
.../apache/iotdb/db/utils/TimeValuePairUtils.java | 26 +
.../org/apache/iotdb/db/utils/TsPrimitiveType.java | 2 +-
.../writelog/transfer/PhysicalPlanLogTransfer.java | 1 +
.../engine/modification/DeletionFileNodeTest.java | 25 +-
.../db/engine/modification/DeletionQueryTest.java | 16 +-
.../apache/iotdb/db/integration/IOTDBFillIT.java | 351 ++++++++
.../iotdb/db/integration/IOTDBGroupByIT.java | 532 ++++++++++++
.../iotdb/db/integration/IoTDBAggregationIT.java | 550 +++++++++++++
.../integration/IoTDBAggregationLargeDataIT.java | 900 +++++++++++++++++++++
.../integration/IoTDBAggregationSmallDataIT.java | 757 +++++++++++++++++
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 33 +-
.../iotdb/db/integration/IoTDBCompleteIT.java | 38 +
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 20 +-
.../iotdb/db/integration/IoTDBLargeDataIT.java | 4 -
.../db/integration/IoTDBSequenceDataQueryIT.java | 23 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 29 +-
.../org/apache/iotdb/db/qp/QueryProcessorTest.java | 59 ++
.../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 5 +-
.../org/apache/iotdb/db/qp/plan/QPUpdateTest.java | 31 +-
.../apache/iotdb/db/qp/utils/MemIntQpExecutor.java | 27 +-
.../db/query/control/FileReaderManagerTest.java | 11 +-
...agerTest.java => QueryResourceManagerTest.java} | 2 +-
.../query/executor/GroupByEngineDataSetTest.java | 153 ++++
.../iotdb/db/query/reader/AllDataReaderTest.java | 76 ++
.../iotdb/db/query/reader/FakedIBatchPoint.java | 108 +++
.../iotdb/db/query/reader/FakedIPointReader.java | 74 ++
.../query/reader/FakedSeriesReaderByTimestamp.java | 76 ++
.../merge/PriorityMergeReaderByTimestampTest.java | 72 +-
.../reader/merge/PriorityMergeReaderTest.java | 28 +-
.../reader/merge/SeriesMergeSortReaderTest.java | 27 +-
.../SequenceDataReaderByTimestampTest.java | 91 +++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 10 +-
.../transfer/PhysicalPlanLogTransferTest.java | 29 +-
.../org/apache/iotdb/jdbc/IoTDBQueryResultSet.java | 8 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 9 +-
mvnw.sh | 0
service-rpc/src/main/thrift/rpc.thrift | 2 +
.../apache/iotdb/tsfile/read/common/BatchData.java | 97 ++-
.../iotdb/tsfile/read/filter/basic/Filter.java | 8 +
.../tsfile/read/filter/operator/AndFilter.java | 6 +
.../iotdb/tsfile/read/filter/operator/Eq.java | 14 +
.../iotdb/tsfile/read/filter/operator/Gt.java | 17 +-
.../iotdb/tsfile/read/filter/operator/GtEq.java | 17 +-
.../iotdb/tsfile/read/filter/operator/Lt.java | 14 +
.../iotdb/tsfile/read/filter/operator/LtEq.java | 14 +
.../iotdb/tsfile/read/filter/operator/NotEq.java | 14 +
.../tsfile/read/filter/operator/NotFilter.java | 5 +
.../tsfile/read/filter/operator/OrFilter.java | 6 +
.../tsfile/read/query/dataset/QueryDataSet.java | 7 +
.../tsfile/read/reader/chunk/ChunkReader.java | 54 +-
.../read/reader/series/FileSeriesReader.java | 45 +-
.../reader/series/SeriesReaderByTimestamp.java | 33 +-
.../read/filter/MinTimeMaxTimeFilterTest.java | 52 +-
.../iotdb/tsfile/read/filter/OperatorTest.java | 1 +
129 files changed, 8773 insertions(+), 1103 deletions(-)
rename Readme.md => README.md (86%)
copy iotdb/iotdb/bin/{start-server.bat => start-WalChecker.bat} (87%)
mode change 100755 => 100644
copy iotdb/iotdb/bin/{start-server.sh => start-WalChecker.sh} (79%)
mode change 100755 => 100644
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/aggregation/AggreFuncFactory.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/aggregation/AggreResultData.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/aggregation/AggregateFunction.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/aggregation/impl/CountAggrFunc.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/aggregation/impl/FirstAggrFunc.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/aggregation/impl/LastAggrFunc.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MaxTimeAggrFunc.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MaxValueAggrFunc.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MeanAggrFunc.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MinTimeAggrFunc.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MinValueAggrFunc.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/entity/data/DataPartitionHolder.java
=>
iotdb/src/main/java/org/apache/iotdb/db/query/aggregation/impl/SumAggrFunc.java
(66%)
rename
iotdb/src/main/java/org/apache/iotdb/db/query/control/{OpenedFilePathsManager.java
=> JobFileManager.java} (55%)
delete mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/control/QueryDataSourceManager.java
rename
iotdb/src/main/java/org/apache/iotdb/db/query/control/{QueryTokenManager.java
=> QueryResourceManager.java} (64%)
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/dataset/AggreResultDataPointReader.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/executor/AggregateEngineExecutor.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/executor/FillEngineExecutor.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/executor/groupby/GroupByEngineDataSet.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/executor/groupby/GroupByWithOnlyTimeFilterDataSetDataSet.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/executor/groupby/GroupByWithValueFilterDataSetDataSet.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/reader/AllDataReader.java
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/chunk/ChunkReaderWithoutFilter.java
=> iotdb/src/main/java/org/apache/iotdb/db/query/reader/IAggregateReader.java
(69%)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/query/timegenerator/node/Node.java
=> iotdb/src/main/java/org/apache/iotdb/db/query/reader/IBatchReader.java (80%)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/query/timegenerator/node/Node.java
=> iotdb/src/main/java/org/apache/iotdb/db/query/reader/IPointReader.java (82%)
rename
iotdb/src/main/java/org/apache/iotdb/db/query/reader/mem/{MemChunkReaderWithFilter.java
=> MemChunkReader.java} (56%)
delete mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/reader/mem/MemChunkReaderWithoutFilter.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/reader/sequence/SealedTsFilesReaderByTimestamp.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/reader/sequence/SequenceDataReaderByTimestamp.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/reader/sequence/UnSealedTsFilesReaderByTimestamp.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/query/reader/unsequence/EngineChunkReaderByTimestamp.java
copy iotdb/src/main/java/org/apache/iotdb/db/{engine/modification =>
rescon}/package-info.java (83%)
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/integration/IOTDBFillIT.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/integration/IOTDBGroupByIT.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/integration/IoTDBAggregationIT.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/integration/IoTDBAggregationLargeDataIT.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/integration/IoTDBAggregationSmallDataIT.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/qp/QueryProcessorTest.java
rename
iotdb/src/test/java/org/apache/iotdb/db/query/control/{QueryTokenManagerTest.java
=> QueryResourceManagerTest.java} (93%)
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/query/executor/GroupByEngineDataSetTest.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/query/reader/AllDataReaderTest.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/query/reader/FakedIBatchPoint.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/query/reader/FakedIPointReader.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/query/reader/FakedSeriesReaderByTimestamp.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/query/reader/sequence/SequenceDataReaderByTimestampTest.java
mode change 100644 => 100755 mvnw.sh
