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 f31df37 [IOTDB-606] Repalce raw logs with metaSnapshot (#1154)
add 5c95b6f [IOTDB-634] Fix merge and flush caused errors for TsFile
storage in HDFS (#1145)
add 99975f7 [IOTDB-560] add TSRecordOutputFormat to write TsFile via
Flink DataSet/DataStream API.
add af8943e address comments
add 023d9a7 address comments
add fd62d4f address comments
add 3c05164 Fix SessionUT bug and update Session.java
add cbd9c99 Add ResultSet Constrction Doc (#1114)
add 5c492b1 [IOTDB-640] Move flush and merge to anltr (Enable flush and
merge in Session) (#1143)
add bef8a97 [IOTDB-631] Using new TsFile MetadataIndex to optimize query
and cache (#1134)
add f9e4a85 fix the compiler error of pr_1143
add d00a356 Merge branch 'master' into cluster_new
No new revisions were added by this update.
Summary of changes:
.../2-QueryEngine/4-ResultSetConstruction.md | 177 +++++++++++++++++++++
.../1-DDL Data Definition Language.md | 31 ++++
.../2-QueryEngine/4-ResultSetConstruction.md | 175 ++++++++++++++++++++
.../1-DDL Data Definition Language.md | 24 +++
example/flink/README.md | 2 +
.../apache/iotdb/flink/FlinkTsFileBatchSink.java | 114 +++++++++++++
.../apache/iotdb/flink/FlinkTsFileStreamSink.java | 115 +++++++++++++
.../java/org/apache/iotdb/flink/TsFlieUtils.java | 26 +++
flink-tsfile-connector/README.md | 86 +++++++++-
.../iotdb/flink/tsfile/RowTSRecordConverter.java | 163 +++++++++++++++++++
.../iotdb/flink/tsfile/TSRecordConverter.java | 61 +++++++
.../iotdb/flink/tsfile/TSRecordOutputFormat.java | 99 ++++++++++++
.../iotdb/flink/tsfile/TsFileOutputFormat.java | 122 ++++++++++++++
.../tsfile/RowTSRecordOutputFormatITCase.java | 56 +++++++
.../flink/tsfile/RowTSRecordOutputFormatTest.java | 77 +++++++++
.../flink/tsfile/RowTsFileConnectorTestBase.java | 87 ++++++++++
.../flink/tsfile/RowTsFileInputFormatTestBase.java | 72 +--------
.../tsfile/RowTsFileOutputFormatTestBase.java | 117 ++++++++++++++
.../apache/iotdb/flink/util/TsFileWriteUtil.java | 2 +-
.../apache/iotdb/hadoop/fileSystem/HDFSFile.java | 24 ++-
.../org/apache/iotdb/db/qp/strategy/SqlBase.g4 | 7 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 56 ++++---
.../iotdb/db/engine/merge/task/MergeFileTask.java | 31 ++--
.../db/engine/storagegroup/TsFileResource.java | 22 +--
.../org/apache/iotdb/db/mqtt/PublishHandler.java | 7 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 2 +
.../apache/iotdb/db/qp/constant/SQLConstant.java | 4 +
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 4 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 47 +++++-
.../org/apache/iotdb/db/qp/logical/Operator.java | 2 +-
.../apache/iotdb/db/qp/logical/RootOperator.java | 1 -
...torageGroupOperator.java => FlushOperator.java} | 34 ++--
.../sys/{ShowOperator.java => MergeOperator.java} | 19 +--
.../iotdb/db/qp/physical/crud/QueryPlan.java | 2 +-
.../db/qp/physical/crud/RawDataQueryPlan.java | 16 +-
.../sys/{ShowTTLPlan.java => FlushPlan.java} | 26 +--
.../sys/{ShowTTLPlan.java => MergePlan.java} | 22 +--
.../iotdb/db/qp/strategy/LogicalGenerator.java | 36 +++++
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 66 ++++----
.../reader/series/SeriesRawDataBatchReader.java | 24 +--
.../query/timegenerator/ServerTimeGenerator.java | 5 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 70 +-------
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 37 +++--
.../java/org/apache/iotdb/session/Session.java | 2 +-
.../org/apache/iotdb/session/IoTDBSessionIT.java | 11 +-
.../java/org/apache/iotdb/session/SessionUT.java | 2 +
site/src/main/.vuepress/config.js | 6 +-
.../tsfile/file/metadata/MetadataIndexNode.java | 2 +-
.../file/metadata/enums/MetadataIndexNodeType.java | 9 ++
.../iotdb/tsfile/read/TsFileSequenceReader.java | 130 +++++++++++++--
.../read/controller/MetadataQuerierByFileImpl.java | 10 +-
.../apache/iotdb/tsfile/write/schema/Schema.java | 4 +-
52 files changed, 2000 insertions(+), 346 deletions(-)
create mode 100644 docs/SystemDesign/2-QueryEngine/4-ResultSetConstruction.md
create mode 100644
docs/zh/SystemDesign/2-QueryEngine/4-ResultSetConstruction.md
create mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSink.java
create mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSink.java
create mode 100644
flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowTSRecordConverter.java
create mode 100644
flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TSRecordConverter.java
create mode 100644
flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TSRecordOutputFormat.java
create mode 100644
flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TsFileOutputFormat.java
create mode 100644
flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTSRecordOutputFormatITCase.java
create mode 100644
flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTSRecordOutputFormatTest.java
create mode 100644
flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileConnectorTestBase.java
create mode 100644
flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileOutputFormatTestBase.java
copy
server/src/main/java/org/apache/iotdb/db/qp/logical/sys/{DeleteStorageGroupOperator.java
=> FlushOperator.java} (67%)
copy
server/src/main/java/org/apache/iotdb/db/qp/logical/sys/{ShowOperator.java =>
MergeOperator.java} (79%)
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{ShowTTLPlan.java =>
FlushPlan.java} (68%)
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{ShowTTLPlan.java =>
MergePlan.java} (73%)
