This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cluster_new
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 62c0009 Merge branch 'cluster_new' of
github.com:apache/incubator-iotdb into cluster_new
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 40c6e94 abstract an interface ManagedSeriesReader from
SeriesReaderWithoutValueFilter
add 640df20 Merge branch 'abstract_SeriesReaderWithoutValueFilter' into
cluster_new
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/iotdb/JDBCExample.java | 4 +-
.../main/java/org/apache/iotdb/SessionExample.java | 9 +-
.../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 +-
.../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 | 70 ++--
.../db/qp/executor/IQueryProcessExecutor.java | 9 +-
.../iotdb/db/qp/executor/QueryProcessExecutor.java | 2 +-
.../db/qp/logical/crud/BasicFunctionOperator.java | 3 -
.../iotdb/db/qp/logical/crud/FilterOperator.java | 14 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 9 +
.../iotdb/db/qp/physical/crud/QueryPlan.java | 24 +-
.../iotdb/db/qp/strategy/LogicalGenerator.java | 6 +
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 113 ++----
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 121 ++++++-
.../optimizer/MergeSingleFilterOptimizer.java | 13 +-
.../db/query/dataset/DeviceIterateDataSet.java | 4 +-
.../NewEngineDataSetWithoutValueFilter.java | 203 ++++++++---
.../iotdb/db/query/executor/EngineExecutor.java | 18 +-
.../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/integration/IoTDBGroupbyDeviceIT.java | 18 +-
.../integration/IoTDBLoadExternalTsfileTest.java | 19 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 32 +-
.../iotdb/db/qp/plan/LogicalPlanSmallTest.java | 25 ++
.../apache/iotdb/db/qp/utils/MemIntQpExecutor.java | 10 +-
.../reader/seriesRelated/FakedIBatchPoint.java | 16 +-
.../SeriesReaderWithValueFilterTest.java | 3 +-
.../SeriesReaderWithoutValueFilterTest.java | 5 +-
.../db/sync/sender/manage/SyncFileManagerTest.java | 54 +--
.../sender/recover/SyncSenderLogAnalyzerTest.java | 20 +-
.../apache/iotdb/tsfile/read/common/BatchData.java | 399 ++++++++++-----------
.../iotdb/tsfile/read/common/SignalBatchData.java | 25 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 26 +-
.../tsfile/read/query/timegenerator/NodeTest.java | 5 +-
45 files changed, 921 insertions(+), 600 deletions(-)
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/qp/logical/crud/UpdateOperator.java =>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/SignalBatchData.java
(61%)
