You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2020/03/09 03:07:28 UTC
[incubator-iotdb] branch cluster_new updated (1d600ef -> acbc889)
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 1d600ef add group by test
add 40222c0 [IOTDB-546] Show child paths statement doesn't show quotation marks in path
add 13b2236 Merge pull request #887 from apache/jira_444
add e7acb86 update User Guide link in readme file
add e5f253a Merge pull request #890 from LebronAl/dev_fix_readme
add 98bfef4 [IOTDB-547] Fix typo for tsfile schema
add 5a5f36b Merge pull request #889 from vesense/patch-8
add 27fb440 [IOTDB-545] Update checkPathValidity in Session (#886)
add f7c850f [IOTDB-497] Apache Flink Connector Support (#817)
add 93f8146 [HOTFIX] fix the maven badge pixel
add fdb1f40 Merge pull request #892 from vesense/patch-9
add 28c35aa [IOTDB-399] add Chinese user guide (#884)
add 0391873 optimize tsfile expression
add 9b943d2 Merge pull request #894 from Ring-k/master
add 0bc56c4 [IOTDB-549] Reorganize exception (#893)
add acbc889 Merge branch 'master' into cluster_new
No new revisions were added by this update.
Summary of changes:
README.md | 4 +-
.../SystemDesign/1-TsFile/4-Read.md | 4 +-
.../UserGuide/0-Get Started/1-QuickStart.md | 12 +-
.../UserGuide/0-Get Started/3-Publication.md | 10 +-
.../UserGuide/3-Server/3-Cluster Setup.md | 6 +-
.../4-Client/1-Command Line Interface (CLI).md | 6 +-
.../4-Client/2-Programming - Native API.md | 12 +-
.../4-Client/4-Programming - Other Languages.md | 48 ++-
.../2-DML (Data Manipulation Language).md | 382 ++++++++++++++++++++-
.../UserGuide/6-System Tools/4-Watermark Tool.md | 4 -
.../6-System Tools/7-Monitor and Log Tools.md | 198 ++++++++++-
.../7-Ecosystem Integration/3-Spark TsFile.md | 327 +++++++++++++++++-
.../7-Ecosystem Integration/4-Spark IoTDB.md | 159 ++++++++-
docs/Documentation/SystemDesign/1-TsFile/4-Read.md | 8 +-
.../UserGuide/0-Get Started/3-Publication.md | 10 +-
.../UserGuide/4-Client/3-Programming - JDBC.md | 14 +-
.../flink/README.md | 16 +-
example/{rocketmq => flink}/pom.xml | 11 +-
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 85 +++++
example/pom.xml | 1 +
.../apache/iotdb/rocketmq/RocketMQConsumer.java | 24 +-
.../main/java/org/apache/iotdb/SessionExample.java | 26 +-
flink-iotdb-connector/README.md | 58 ++++
flink-iotdb-connector/pom.xml | 55 +++
.../iotdb/flink/DefaultIoTSerializationSchema.java | 99 ++++++
.../main/java/org/apache/iotdb/flink/Event.java | 54 +++
.../java/org/apache/iotdb/flink/IoTDBOptions.java | 152 ++++++++
.../java/org/apache/iotdb/flink/IoTDBSink.java | 187 ++++++++++
.../apache/iotdb/flink/IoTSerializationSchema.java | 31 ++
.../flink/DefaultIoTSerializationSchemaTest.java | 49 +++
.../iotdb/flink/IoTDBSinkBatchInsertTest.java | 102 ++++++
.../iotdb/flink/IoTDBSinkBatchTimerTest.java | 74 ++++
.../apache/iotdb/flink/IoTDBSinkInsertTest.java | 66 ++++
.../apache/iotdb/jdbc/AbstractIoTDBResultSet.java | 6 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 9 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 4 +-
.../iotdb/jdbc/IoTDBNonAlignQueryResultSet.java | 4 +-
.../org/apache/iotdb/jdbc/IoTDBQueryResultSet.java | 4 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 8 +-
pom.xml | 4 +-
.../java/org/apache/iotdb/db/metadata/MTree.java | 10 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 85 +++--
.../iotdb/db/integration/IOTDBGroupByIT.java | 22 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 41 ++-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 3 +
...xception.java => IoTDBConnectionException.java} | 11 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 6 +-
.../iotdb/rpc/StatementExecutionException.java | 12 +-
.../main/java/org/apache/iotdb/session/Config.java | 11 +-
.../iotdb/session/IoTDBSessionException.java | 36 --
.../java/org/apache/iotdb/session/Session.java | 154 +++++----
.../org/apache/iotdb/session/SessionDataSet.java | 16 +-
.../iotdb/session/CheckPathValidityTest.java | 49 +++
.../org/apache/iotdb/session/IoTDBSessionIT.java | 133 ++++---
.../read/expression/util/ExpressionOptimizer.java | 58 +++-
.../tsfile/write/schema/MeasurementSchema.java | 2 +-
.../read/filter/IExpressionOptimizerTest.java | 15 +-
57 files changed, 2644 insertions(+), 353 deletions(-)
copy docs/Documentation/UserGuide/3-Server/2-Single Node Setup.md => example/flink/README.md (76%)
copy example/{rocketmq => flink}/pom.xml (84%)
create mode 100644 example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java
create mode 100644 flink-iotdb-connector/README.md
create mode 100644 flink-iotdb-connector/pom.xml
create mode 100644 flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/DefaultIoTSerializationSchema.java
create mode 100644 flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/Event.java
create mode 100644 flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBOptions.java
create mode 100644 flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
create mode 100644 flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTSerializationSchema.java
create mode 100644 flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/DefaultIoTSerializationSchemaTest.java
create mode 100644 flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchInsertTest.java
create mode 100644 flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchTimerTest.java
create mode 100644 flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkInsertTest.java
rename service-rpc/src/main/java/org/apache/iotdb/rpc/{IoTDBRPCException.java => IoTDBConnectionException.java} (76%)
copy tsfile/src/main/java/org/apache/iotdb/tsfile/exception/filter/QueryFilterOptimizationException.java => service-rpc/src/main/java/org/apache/iotdb/rpc/StatementExecutionException.java (72%)
delete mode 100644 session/src/main/java/org/apache/iotdb/session/IoTDBSessionException.java
create mode 100644 session/src/test/java/org/apache/iotdb/session/CheckPathValidityTest.java