This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch move_flush
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 2367583 update doc
add 15c5567 add scrollbar (#1140)
add 5f1cb2b [IOTDB-628] change readme.md description (#1137)
add 20be40b [IOTDB-633]Update Session.java : Fix sort bug (#1141)
add d36070c -- Resolving Spelling mistake
add 7931d71 Added workaround when doing Aggregation over boolean Series
for v0.10, and fix time precision not effect bug
add 58f7227 remove unused codes
add 1ec34bd fix user guide
add 73dd5eb fix sonar code smell
add 18f726c fix merge stuck bug (#1133)
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 737f97f Merge remote-tracking branch 'origin/master' into move_flush
No new revisions were added by this update.
Summary of changes:
README.md | 18 +--
README_ZH.md | 14 +-
.../UserGuide/7-Ecosystem Integration/1-Grafana.md | 7 +-
.../UserGuide/7-Ecosystem Integration/1-Grafana.md | 7 +-
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 +-
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 109 +++++++++-----
grafana/src/main/resources/application.properties | 6 +-
.../apache/iotdb/hadoop/fileSystem/HDFSFile.java | 24 ++-
.../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 10 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 31 ++--
.../engine/storagegroup/StorageGroupProcessor.java | 14 +-
.../db/engine/storagegroup/TsFileResource.java | 44 +++---
.../java/org/apache/iotdb/session/Session.java | 14 +-
.../java/org/apache/iotdb/session/SessionUT.java | 92 ++++++++++++
site/src/main/.vuepress/styles/index.styl | 2 +-
.../apache/iotdb/tsfile/write/schema/Schema.java | 4 +-
30 files changed, 1402 insertions(+), 193 deletions(-)
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
create mode 100644
session/src/test/java/org/apache/iotdb/session/SessionUT.java
