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/04/09 01:55:36 UTC
[incubator-iotdb] branch cluster_new updated (06d5e85 -> 4a4e259)
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 06d5e85 Revert "[IOTDB-578] Cluster module should use the same thrift version with iotdb-parent" (#1009)
add b3f3540 fix concurrent modification error in upgrade (#1004)
add 644d441 fix meet incompatible file error in restart (#1005)
add 1a8fcd3 fix RestorableTsFileIOWriterTest
add 48b0360 not delete incompatible file in file level api (#1007)
add 0f782ad add TsFileInputFormat for reading TsFiles in flink.
add 2feb0ce try to fix windows test
add bee90f7 add docs and rename util classes.
add 4652631 address comments and push to test travis changes.
add 4846b4a fix compile error caused by rebase
add b24cdde fix compile error caused by rebase and add a new test to help maintain the TSFileConfigUtil.
add af683dd enable compression in session pool
add 4bc238f ignore S107
add d6207c0 [IOTDB-565] MQTT Protocol Support (#929)
add 4a4e259 Merge branch 'master' into cluster_new
No new revisions were added by this update.
Summary of changes:
.travis.yml | 2 +-
LICENSE | 8 +
LICENSE-binary | 2 +-
docs/UserGuide/4-Client/6-Programming - MQTT.md | 100 ++++
.../{6-Status Codes.md => 7-Status Codes.md} | 0
example/flink/README.md | 10 +-
example/flink/pom.xml | 7 +-
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 6 -
.../apache/iotdb/flink/FlinkTsFileBatchSource.java | 80 ++++
.../iotdb/flink/FlinkTsFileStreamSource.java | 84 ++++
.../java/org/apache/iotdb/flink/TsFlieUtils.java | 72 +++
example/{flink => mqtt}/README.md | 8 +-
example/{tsfile => mqtt}/pom.xml | 10 +-
.../java/org/apache/iotdb/mqtt/MQTTClient.java | 50 ++
example/pom.xml | 1 +
flink-tsfile-connector/README.md | 93 ++++
{example/flink => flink-tsfile-connector}/pom.xml | 19 +-
.../apache/iotdb/flink/tsfile/RowRecordParser.java | 46 ++
.../iotdb/flink/tsfile/RowRowRecordParser.java | 120 +++++
.../iotdb/flink/tsfile/TsFileInputFormat.java | 168 +++++++
.../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 65 +++
.../flink/tsfile/RowTsFileInputFormatITCase.java | 109 +++++
.../flink/tsfile/RowTsFileInputFormatTest.java | 89 ++++
.../flink/tsfile/RowTsFileInputFormatTestBase.java | 118 +++++
.../util/TSFileConfigUtilCompletenessTest.java | 84 ++++
.../apache/iotdb/flink/util/TsFileWriteUtil.java | 230 ++++++++++
pom.xml | 28 +-
server/pom.xml | 10 +-
.../resources/conf/iotdb-engine.properties | 22 +-
.../java/io/moquette/broker/MQTTConnection.java | 503 +++++++++++++++++++++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 68 +++
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 7 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 17 +
.../engine/storagegroup/StorageGroupProcessor.java | 60 +--
.../apache/iotdb/db/mqtt/BrokerAuthenticator.java | 48 ++
.../apache/iotdb/db/mqtt/JSONPayloadFormatter.java | 90 ++++
.../java/org/apache/iotdb/db/mqtt/Message.java | 39 +-
.../apache/iotdb/db/mqtt/PayloadFormatManager.java | 43 +-
.../org/apache/iotdb/db/mqtt/PayloadFormatter.java | 23 +-
.../org/apache/iotdb/db/mqtt/PublishHandler.java | 110 +++++
.../java/org/apache/iotdb/db/service/IoTDB.java | 3 +
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 2 +-
.../org/apache/iotdb/db/service/MQTTService.java | 102 +++++
.../org/apache/iotdb/db/service/ServiceType.java | 1 +
.../writelog/recover/TsFileRecoverPerformer.java | 23 +-
.../org.apache.iotdb.db.mqtt.PayloadFormatter | 12 +-
.../iotdb/db/mqtt/BrokerAuthenticatorTest.java | 24 +-
.../iotdb/db/mqtt/JSONPayloadFormatTest.java | 69 +++
.../iotdb/db/mqtt/PayloadFormatManagerTest.java | 22 +-
.../apache/iotdb/db/mqtt/PublishHandlerTest.java | 59 +++
.../org/apache/iotdb/session/pool/SessionPool.java | 14 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 4 +-
site/src/main/.vuepress/config.js | 3 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 3 +-
...tion.java => NotCompatibleTsFileException.java} | 4 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 3 +-
.../iotdb/tsfile/read/expression/IExpression.java | 4 +-
.../tsfile/read/expression/QueryExpression.java | 3 +-
.../write/writer/RestorableTsFileIOWriter.java | 9 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 3 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 6 +-
61 files changed, 2863 insertions(+), 159 deletions(-)
create mode 100644 docs/UserGuide/4-Client/6-Programming - MQTT.md
rename docs/UserGuide/4-Client/{6-Status Codes.md => 7-Status Codes.md} (100%)
create mode 100644 example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSource.java
create mode 100644 example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSource.java
create mode 100644 example/flink/src/main/java/org/apache/iotdb/flink/TsFlieUtils.java
copy example/{flink => mqtt}/README.md (69%)
copy example/{tsfile => mqtt}/pom.xml (86%)
create mode 100644 example/mqtt/src/main/java/org/apache/iotdb/mqtt/MQTTClient.java
create mode 100644 flink-tsfile-connector/README.md
copy {example/flink => flink-tsfile-connector}/pom.xml (73%)
create mode 100644 flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowRecordParser.java
create mode 100644 flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowRowRecordParser.java
create mode 100644 flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java
create mode 100644 flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/util/TSFileConfigUtil.java
create mode 100644 flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatITCase.java
create mode 100644 flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java
create mode 100644 flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTestBase.java
create mode 100644 flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/util/TSFileConfigUtilCompletenessTest.java
create mode 100644 flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/util/TsFileWriteUtil.java
create mode 100644 server/src/main/java/io/moquette/broker/MQTTConnection.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mqtt/BrokerAuthenticator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mqtt/JSONPayloadFormatter.java
copy flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/Event.java => server/src/main/java/org/apache/iotdb/db/mqtt/Message.java (68%)
copy flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/Event.java => server/src/main/java/org/apache/iotdb/db/mqtt/PayloadFormatManager.java (51%)
copy flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTSerializationSchema.java => server/src/main/java/org/apache/iotdb/db/mqtt/PayloadFormatter.java (66%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mqtt/PublishHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/MQTTService.java
copy .asf.yaml => server/src/main/resources/META-INF/services/org.apache.iotdb.db.mqtt.PayloadFormatter (81%)
copy flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTSerializationSchema.java => server/src/test/java/org/apache/iotdb/db/mqtt/BrokerAuthenticatorTest.java (57%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mqtt/JSONPayloadFormatTest.java
copy flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTSerializationSchema.java => server/src/test/java/org/apache/iotdb/db/mqtt/PayloadFormatManagerTest.java (66%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mqtt/PublishHandlerTest.java
rename tsfile/src/main/java/org/apache/iotdb/tsfile/exception/{NotCompatibleException.java => NotCompatibleTsFileException.java} (87%)