This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch pull_up_file_close
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from c3907d3 Update
server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
add 2200115 [IOTDB-340] Remove unnecessary getting data types from
MManager (#677)
add 217257c Update RocketMQ example with session API (#676)
add cd776ce update develop-chinese (#694)
add 867a0ae Fix bug IOTDB-159
add 20b42cd Merge pull request #693 from LeiRui/IOTDB-159
add 5c524e7 Rename Session to Native API (#695)
add 72a3044 fix a grammar
add 346b4e1 modify sync startup script (#696)
add bc2fef1 [IOTDB-389] Parallel Raw data query (#684)
add 12ea493 Delete the duplicated fields in the BatchData class (#686)
add b17f402 implement disable align (#698)
add 64d5ed1 [IOTDB-305] Add value filter function while executing group
by device (#687)
add 089da8a abstract an interface ManagedSeriesReader from
SeriesReaderWithoutValueFilter (#701)
add 6d8413f add release check doc (#702)
add 0734ec1 Track the merge history in TsFileResource (#683)
add fdfb35f Merge branch 'master' into pull_up_file_close
No new revisions were added by this update.
Summary of changes:
docs/Development-Chinese.md | 27 +-
docs/Development-VoteRelease.md | 198 ++++++++++
... - Session.md => 2-Programming - Native API.md} | 19 +-
...ogramming - JDBC.md => 3-Programming - JDBC.md} | 0
... - Session.md => 2-Programming - Native API.md} | 19 +-
...ogramming - JDBC.md => 3-Programming - JDBC.md} | 9 +-
.../4-Client/5-Programming - TsFile API.md | 3 +-
.../main/java/org/apache/iotdb/JDBCExample.java | 4 +-
example/rocketmq/pom.xml | 2 +-
example/rocketmq/readme.md | 14 +-
.../java/org/apache/iotdb/rocketmq/Constant.java | 62 ++--
.../apache/iotdb/rocketmq/RocketMQConsumer.java | 97 +++--
.../apache/iotdb/rocketmq/RocketMQProducer.java | 1 +
.../main/java/org/apache/iotdb/rocketmq/Utils.java | 2 +-
.../main/java/org/apache/iotdb/SessionExample.java | 24 +-
.../iotdb/hadoop/tsfile/TSFRecordReader.java | 22 +-
.../assembly/resources/tools/start-sync-client.bat | 2 +-
.../assembly/resources/tools/start-sync-client.sh | 2 +-
.../org/apache/iotdb/db/qp/strategy/SqlBase.g4 | 25 +-
.../org/apache/iotdb/db/concurrent/ThreadName.java | 3 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 22 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 18 +
.../engine/storagegroup/StorageGroupProcessor.java | 13 +
.../db/engine/storagegroup/TsFileProcessor.java | 3 +
.../db/engine/storagegroup/TsFileResource.java | 58 ++-
.../java/org/apache/iotdb/db/metadata/MGraph.java | 6 +-
.../org/apache/iotdb/db/metadata/MManager.java | 19 +-
.../java/org/apache/iotdb/db/metadata/MTree.java | 67 +++-
.../qp/executor/AbstractQueryProcessExecutor.java | 97 ++---
.../db/qp/executor/IQueryProcessExecutor.java | 33 +-
.../iotdb/db/qp/executor/QueryProcessExecutor.java | 45 ++-
.../db/qp/logical/crud/BasicFunctionOperator.java | 3 -
.../iotdb/db/qp/logical/crud/FilterOperator.java | 15 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 9 +
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 13 +
.../iotdb/db/qp/physical/crud/QueryPlan.java | 66 +++-
.../iotdb/db/qp/physical/sys/ShowTTLPlan.java | 18 +-
.../iotdb/db/qp/strategy/LogicalGenerator.java | 6 +
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 171 +++++----
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 131 +++++--
.../optimizer/MergeSingleFilterOptimizer.java | 13 +-
.../db/query/dataset/DeviceIterateDataSet.java | 56 ++-
.../NewEngineDataSetWithoutValueFilter.java | 203 ++++++++---
.../dataset/groupby/GroupByEngineDataSet.java | 38 +-
.../groupby/GroupByWithValueFilterDataSet.java | 36 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 24 +-
.../db/query/executor/AggregateEngineExecutor.java | 35 +-
.../iotdb/db/query/executor/EngineExecutor.java | 75 ++--
.../iotdb/db/query/executor/EngineQueryRouter.java | 68 ++--
.../db/query/executor/FillEngineExecutor.java | 16 +-
.../db/query/executor/IEngineQueryRouter.java | 39 +-
.../pool/QueryTaskPoolManager.java} | 28 +-
...{IPointReader.java => ManagedSeriesReader.java} | 19 +-
.../query/reader/chunkRelated/MemChunkReader.java | 15 +-
.../NewUnseqResourceMergeReader.java | 12 +-
.../SeriesReaderWithoutValueFilter.java | 55 ++-
.../java/org/apache/iotdb/db/service/IoTDB.java | 2 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 15 +-
.../db/sync/sender/manage/SyncFileManager.java | 17 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 8 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 31 +-
.../writelog/recover/TsFileRecoverPerformer.java | 22 +-
.../iotdb/db/engine/merge/MergeOverLapTest.java | 3 +
.../apache/iotdb/db/engine/merge/MergeTest.java | 3 +
.../db/engine/modification/DeletionQueryTest.java | 57 ++-
.../iotdb/db/integration/IoTDBGroupbyDeviceIT.java | 18 +-
.../integration/IoTDBLoadExternalTsfileTest.java | 19 +-
.../db/integration/IoTDBSequenceDataQueryIT.java | 90 +++--
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 93 +++--
.../iotdb/db/metadata/MManagerBasicTest.java | 35 +-
.../iotdb/db/qp/plan/LogicalPlanSmallTest.java | 25 ++
.../apache/iotdb/db/qp/utils/MemIntQpExecutor.java | 25 +-
.../query/executor/GroupByEngineDataSetTest.java | 62 +++-
.../reader/seriesRelated/FakedIBatchPoint.java | 16 +-
.../SeriesReaderWithValueFilterTest.java | 3 +-
.../SeriesReaderWithoutValueFilterTest.java | 5 +-
.../db/sync/sender/manage/SyncFileManagerTest.java | 54 +--
.../sender/recover/SyncSenderLogAnalyzerTest.java | 20 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 3 +
.../writelog/recover/UnseqTsFileRecoverTest.java | 3 +
.../apache/iotdb/tsfile/read/common/BatchData.java | 399 ++++++++++-----------
.../iotdb/tsfile/read/common/SignalBatchData.java | 26 +-
.../tsfile/read/expression/QueryExpression.java | 17 +-
.../tsfile/read/query/dataset/QueryDataSet.java | 4 -
.../iotdb/tsfile/read/reader/page/PageReader.java | 26 +-
.../tsfile/read/query/timegenerator/NodeTest.java | 5 +-
86 files changed, 2023 insertions(+), 1163 deletions(-)
create mode 100644 docs/Development-VoteRelease.md
rename docs/Documentation-CHN/UserGuide/4-Client/{3-Programming - Session.md
=> 2-Programming - Native API.md} (81%)
rename docs/Documentation-CHN/UserGuide/4-Client/{2-Programming - JDBC.md =>
3-Programming - JDBC.md} (100%)
rename docs/Documentation/UserGuide/4-Client/{3-Programming - Session.md =>
2-Programming - Native API.md} (91%)
rename docs/Documentation/UserGuide/4-Client/{2-Programming - JDBC.md =>
3-Programming - JDBC.md} (98%)
copy
server/src/main/java/org/apache/iotdb/db/{engine/flush/pool/FlushTaskPoolManager.java
=> query/pool/QueryTaskPoolManager.java} (71%)
copy server/src/main/java/org/apache/iotdb/db/query/reader/{IPointReader.java
=> ManagedSeriesReader.java} (63%)
copy
server/src/main/java/org/apache/iotdb/db/engine/version/SysTimeVersionController.java
=>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/SignalBatchData.java
(61%)
