This is an automated email from the ASF dual-hosted git repository.
geniuspig pushed a change to branch http
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 68ec011 update name
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 e25c7f8 Merge branch 'master' into http
add fb4a0af [IOTDB-550] Fix TSMRWriteExample executes unsuccessfully
(#895)
add 59e7977 [IOTDB-545] Update checkPathValidity in Session (#895)
add 66eb044 Merge remote-tracking branch 'upstream/master' into master1
add 327e909 Refine exception code (#896)
add 7a24d65 update ReadMe file for introducing how to mount local folders
in docker (#885)
add 16d1570 [IOTDB-552] Restrictions of predicates in ALIGN_BY_DEVICE
statements are not well stated (#898)
add 0c8a4cc Merge branch 'master' into http
No new revisions were added by this update.
Summary of changes:
README.md | 2 +-
docker/ReadMe.md | 10 +
.../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 +++++++++++++++++++-
.../5-Operation Manual/4-SQL Reference.md | 10 +-
.../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 +-
.../5-Operation Manual/4-SQL Reference.md | 11 +-
.../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 | 34 +-
.../main/java/org/apache/iotdb/SessionExample.java | 28 +-
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 | 186 ++++++++++
.../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 ++++
.../iotdb/hadoop/fileSystem/HDFSConfUtil.java | 5 +-
.../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 +-
.../org/apache/iotdb/jdbc/IoTDBSQLException.java | 2 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 54 +--
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 55 ++-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 12 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 2 +-
.../apache/iotdb/jdbc/IoTDBQueryResultSetTest.java | 14 +-
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 7 +-
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 11 +-
pom.xml | 4 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 8 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 3 +
.../db/engine/memtable/IWritableMemChunk.java | 3 +
.../engine/storagegroup/StorageGroupProcessor.java | 33 +-
.../db/engine/storagegroup/TsFileProcessor.java | 30 +-
.../StorageGroupProcessorException.java | 3 +-
...upException.java => WriteProcessException.java} | 12 +-
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 3 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 15 +-
.../org/apache/iotdb/db/service/StaticResps.java | 4 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 393 +++++++++------------
.../iotdb/db/writelog/recover/LogReplayer.java | 2 +-
.../writelog/recover/TsFileRecoverPerformer.java | 2 +-
.../db/engine/modification/DeletionQueryTest.java | 1 -
.../storagegroup/FileNodeManagerBenchmark.java | 1 -
.../storagegroup/StorageGroupProcessorTest.java | 5 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 2 +-
.../iotdb/db/integration/IOTDBGroupByIT.java | 22 +-
.../integration/IoTDBLoadExternalTsfileTest.java | 2 +-
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 4 +-
.../iotdb/db/metadata/MManagerAdvancedTest.java | 6 +-
.../iotdb/db/metadata/MManagerImproveTest.java | 10 +-
.../apache/iotdb/db/writelog/PerformanceTest.java | 4 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 2 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 2 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 2 +-
service-rpc/rpc-changelist.md | 5 +-
.../apache/iotdb/rpc/BatchExecutionException.java | 26 +-
...xception.java => IoTDBConnectionException.java} | 11 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 104 +++++-
.../iotdb/rpc/StatementExecutionException.java | 12 +-
service-rpc/src/main/thrift/rpc.thrift | 24 +-
.../iotdb/session/IoTDBSessionException.java | 36 --
.../java/org/apache/iotdb/session/Session.java | 222 ++++++------
.../org/apache/iotdb/session/SessionDataSet.java | 16 +-
.../org/apache/iotdb/session/IoTDBSessionIT.java | 121 ++++---
.../read/expression/util/ExpressionOptimizer.java | 58 ++-
.../read/filter/IExpressionOptimizerTest.java | 15 +-
89 files changed, 2975 insertions(+), 776 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 server/src/main/java/org/apache/iotdb/db/exception/{storageGroup =>
}/StorageGroupProcessorException.java (92%)
rename
server/src/main/java/org/apache/iotdb/db/exception/{storageGroup/StorageGroupException.java
=> WriteProcessException.java} (77%)
copy jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBSQLException.java =>
service-rpc/src/main/java/org/apache/iotdb/rpc/BatchExecutionException.java
(63%)
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
