This is an automated email from the ASF dual-hosted git repository.
hxd pushed a change to branch testcontainer
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 750f775 apply spotless
add 05c5b7b rethrow RTE (#3042)
add 6d338c4 [IOTDB-1301] snappy compatible arm64 (#3006)
add 9766836 [IOTDB-1319] Trigger module: sink utility (#3038)
add 79f4b4b Fix CI failed caused by updating unnecessary vector last
cache (#3044)
add de51269 change version to 0.13.0-SNAPSHOT (#3045)
add 42a04ac Fix CI Bug
add 892473d Merge remote-tracking branch 'origin/master' into
testcontainer
No new revisions were added by this update.
Summary of changes:
antlr/pom.xml | 2 +-
cli/pom.xml | 4 +-
client-cpp/pom.xml | 2 +-
client-py/README.md | 2 +-
client-py/pom.xml | 2 +-
cluster/pom.xml | 14 +-
code-coverage/pom.xml | 2 +-
compile-tools/pom.xml | 2 +-
compile-tools/thrift/pom.xml | 2 +-
cross-tests/pom.xml | 2 +-
distribution/pom.xml | 2 +-
docs/Development/VoteRelease.md | 8 +-
docs/SystemDesign/TsFile/Format.md | 12 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 2 +-
.../UserGuide/API/Programming-Python-Native-API.md | 2 +-
docs/UserGuide/API/Programming-TsFile-API.md | 4 +-
docs/UserGuide/Advanced-Features/Triggers.md | 282 ++++++++++++++++++++-
.../Advanced-Features/UDF-User-Defined-Function.md | 8 +-
docs/UserGuide/Appendix/SQL-Reference.md | 2 +-
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 8 +-
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 8 +-
.../Ecosystem Integration/MapReduce TsFile.md | 2 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 8 +-
.../Ecosystem Integration/Spark TsFile.md | 2 +-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 2 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 2 +-
docs/zh/Development/VoteRelease.md | 8 +-
docs/zh/SystemDesign/TsFile/Format.md | 12 +-
docs/zh/UserGuide/API/Programming-JDBC.md | 2 +-
.../UserGuide/API/Programming-Java-Native-API.md | 2 +-
.../UserGuide/API/Programming-Python-Native-API.md | 2 +-
docs/zh/UserGuide/API/Programming-TsFile-API.md | 4 +-
docs/zh/UserGuide/Advanced-Features/Triggers.md | 282 ++++++++++++++++++++-
.../Advanced-Features/UDF-User-Defined-Function.md | 8 +-
docs/zh/UserGuide/Appendix/SQL-Reference.md | 2 +-
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 8 +-
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 8 +-
.../Ecosystem Integration/MapReduce TsFile.md | 2 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 8 +-
.../Ecosystem Integration/Spark TsFile.md | 2 +-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 2 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 2 +-
example/client-cpp-example/pom.xml | 2 +-
example/flink/pom.xml | 2 +-
example/hadoop/pom.xml | 6 +-
example/jdbc/pom.xml | 2 +-
example/kafka/pom.xml | 4 +-
example/kafka/readme.md | 4 +-
example/mqtt/pom.xml | 2 +-
example/pom.xml | 3 +-
example/pulsar/pom.xml | 2 +-
example/rocketmq/pom.xml | 2 +-
example/rocketmq/readme.md | 4 +-
example/session/pom.xml | 2 +-
example/{udf => trigger}/pom.xml | 6 +-
.../org/apache/iotdb/trigger/TriggerExample.java | 127 ++++++++++
example/tsfile/pom.xml | 2 +-
example/tsfile/readme.md | 2 +-
example/udf/pom.xml | 4 +-
flink-iotdb-connector/pom.xml | 2 +-
flink-tsfile-connector/pom.xml | 2 +-
grafana/pom.xml | 2 +-
hadoop/README.md | 2 +-
hadoop/pom.xml | 4 +-
hive-connector/pom.xml | 6 +-
jdbc/README.md | 4 +-
jdbc/pom.xml | 2 +-
pom.xml | 5 +-
server/pom.xml | 6 +-
.../resources/conf/iotdb-engine.properties | 6 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 4 +-
.../compaction/CompactionMergeTaskPoolManager.java | 38 ++-
.../db/engine/compaction/TsFileManagement.java | 19 +-
.../level/LevelCompactionTsFileManagement.java | 274 +++++++++++---------
.../no/NoCompactionTsFileManagement.java | 132 ++++++----
.../iotdb/db/engine/merge/task/MergeFileTask.java | 14 +-
.../engine/storagegroup/StorageGroupProcessor.java | 123 +++++----
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 2 +
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 11 +-
.../apache/iotdb/db/sink/api/Configuration.java | 5 +-
.../java/org/apache/iotdb/db/sink/api/Event.java | 5 +-
.../java/org/apache/iotdb/db/sink/api/Handler.java | 15 +-
.../exception/SinkException.java} | 8 +-
.../local/LocalIoTDBConfiguration.java} | 39 ++-
.../iotdb/db/sink/local/LocalIoTDBEvent.java | 26 +-
.../iotdb/db/sink/local/LocalIoTDBHandler.java | 104 ++++++++
.../iotdb/db/sink/mqtt/MQTTConfiguration.java | 74 ++++++
.../mqtt/MQTTEvent.java} | 48 ++--
.../org/apache/iotdb/db/sink/mqtt/MQTTHandler.java | 85 +++++++
.../iotdb/db/utils/windowing/api/Evaluator.java | 3 +-
.../windowing/runtime/WindowEvaluationTask.java | 2 +-
.../compaction/LevelCompactionCacheTest.java | 2 +-
.../engine/compaction/LevelCompactionLogTest.java | 2 +-
.../compaction/LevelCompactionMergeTest.java | 6 +-
.../compaction/LevelCompactionMoreDataTest.java | 2 +-
.../LevelCompactionTsFileManagementTest.java | 69 +++++
.../NoCompactionTsFileManagementTest.java | 71 +++++-
.../apache/iotdb/db/sink/LocalIoTDBSinkTest.java | 217 ++++++++++++++++
.../org/apache/iotdb/db/sink/MQTTSinkTest.java | 204 +++++++++++++++
service-rpc/pom.xml | 2 +-
session/pom.xml | 2 +-
site/pom.xml | 2 +-
spark-iotdb-connector/Readme.md | 8 +-
spark-iotdb-connector/pom.xml | 2 +-
spark-tsfile/README.md | 6 +-
spark-tsfile/pom.xml | 4 +-
thrift-cluster/pom.xml | 2 +-
thrift-sync/pom.xml | 2 +-
thrift/pom.xml | 2 +-
tsfile/README.md | 2 +-
tsfile/pom.xml | 2 +-
zeppelin-interpreter/pom.xml | 2 +-
112 files changed, 2118 insertions(+), 483 deletions(-)
copy example/{udf => trigger}/pom.xml (97%)
create mode 100644
example/trigger/src/main/java/org/apache/iotdb/trigger/TriggerExample.java
copy jdbc/src/main/resources/services/META-INF/java.sql.Driver =>
server/src/main/java/org/apache/iotdb/db/sink/api/Configuration.java (91%)
copy jdbc/src/main/resources/services/META-INF/java.sql.Driver =>
server/src/main/java/org/apache/iotdb/db/sink/api/Event.java (92%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/TimeseriesSchemaSnapshot.java
=> server/src/main/java/org/apache/iotdb/db/sink/api/Handler.java (69%)
copy
server/src/main/java/org/apache/iotdb/db/{query/udf/api/exception/UDFException.java
=> sink/exception/SinkException.java} (81%)
copy
server/src/main/java/org/apache/iotdb/db/{query/dataset/SingleDataSet.java =>
sink/local/LocalIoTDBConfiguration.java} (55%)
copy service-rpc/src/main/java/org/apache/iotdb/rpc/NonOpenTransport.java =>
server/src/main/java/org/apache/iotdb/db/sink/local/LocalIoTDBEvent.java (66%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sink/local/LocalIoTDBHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/sink/mqtt/MQTTConfiguration.java
copy
server/src/main/java/org/apache/iotdb/db/{qp/logical/sys/CreateFunctionOperator.java
=> sink/mqtt/MQTTEvent.java} (52%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sink/mqtt/MQTTHandler.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/sink/LocalIoTDBSinkTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/sink/MQTTSinkTest.java
