You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2025/04/09 03:47:37 UTC
(iotdb-extras) 07/07: Merge branch 'master' of https://github.com/YC27/iotdb-extras into pr/52
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch sink
in repository https://gitbox.apache.org/repos/asf/iotdb-extras.git
commit 071d20d4c2afd99dfa67f1bb6ff74b87f9a86426
Merge: feeb55c 8cdcabb
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Mon Apr 7 10:23:51 2025 +0800
Merge branch 'master' of https://github.com/YC27/iotdb-extras into pr/52
connectors/grafana-plugin/yarn.lock | 72 +++++++--
connectors/hive-connector/pom.xml | 1 +
connectors/pom.xml | 1 +
.../iotdb-table-connector-3.3/pom.xml | 76 +++++++++
...org.apache.spark.sql.sources.DataSourceRegister | 18 +++
.../iotdb/spark/table/db/IoTDBTableProvider.scala | 28 ++++
.../iotdb-table-connector-3.4/pom.xml | 76 +++++++++
...org.apache.spark.sql.sources.DataSourceRegister | 18 +++
.../iotdb/spark/table/db/IoTDBTableProvider.scala | 28 ++++
.../iotdb-table-connector-3.5/pom.xml | 76 +++++++++
...org.apache.spark.sql.sources.DataSourceRegister | 18 +++
.../iotdb/spark/table/db/IoTDBTableProvider.scala | 28 ++++
connectors/spark-iotdb-table-connector/pom.xml | 152 ++++++++++++++++++
.../spark-iotdb-table-common/pom.xml | 118 ++++++++++++++
.../table/db/AbstractIoTDBTableProvider.scala | 45 ++++++
.../apache/iotdb/spark/table/db/IoTDBOptions.scala | 50 ++++++
.../apache/iotdb/spark/table/db/IoTDBTable.scala | 64 ++++++++
.../apache/iotdb/spark/table/db/IoTDBUtils.scala | 171 +++++++++++++++++++++
.../table/db/read/IoTDBExpressionSQLBuilder.scala | 161 +++++++++++++++++++
.../spark/table/db/read/IoTDBInputPartition.scala | 27 ++++
.../spark/table/db/read/IoTDBPartitionReader.scala | 76 +++++++++
.../db/read/IoTDBPartitionReaderFactory.scala | 32 ++++
.../iotdb/spark/table/db/read/IoTDBScan.scala | 57 +++++++
.../spark/table/db/read/IoTDBScanBuilder.scala | 99 ++++++++++++
.../spark/table/db/write/IoTDBDataWriter.scala | 131 ++++++++++++++++
.../iotdb/spark/table/db/write/IoTDBWrite.scala | 35 +++++
.../spark/table/db/write/IoTDBWriteBuilder.scala | 28 ++++
.../spark/table/db/write/IoTDBWriteFactory.scala | 32 ++++
.../apache/iotdb/spark/table/db/UtilsTest.scala | 36 +++++
.../db/read/PushDownPredicateSQLBuilderTest.scala | 76 +++++++++
examples/pom.xml | 1 +
examples/spark-table/README.md | 103 +++++++++++++
{connectors => examples/spark-table}/pom.xml | 66 ++++----
.../spark/table/SparkConnectorReadExample.scala | 44 ++++++
.../spark/table/SparkConnectorSQLExample.scala | 59 +++++++
.../spark/table/SparkConnectorWriteExample.scala | 51 ++++++
iotdb-collector/collector-core/pom.xml | 3 +
iotdb-operator/go.mod | 11 +-
iotdb-operator/go.sum | 20 +--
pom.xml | 12 +-
40 files changed, 2139 insertions(+), 61 deletions(-)
diff --cc iotdb-collector/collector-core/pom.xml
index ef58a21,7b68e68..f661994
--- a/iotdb-collector/collector-core/pom.xml
+++ b/iotdb-collector/collector-core/pom.xml
@@@ -99,101 -104,9 +99,104 @@@
<artifactId>disruptor</artifactId>
</dependency>
<dependency>
+ <groupId>org.java-websocket</groupId>
+ <artifactId>Java-WebSocket</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.commons</groupId>
+ <artifactId>commons-lang3</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.commons</groupId>
+ <artifactId>commons-collections4</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.commons</groupId>
+ <artifactId>commons-pool2</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.tsfile</groupId>
+ <artifactId>tsfile</artifactId>
+ </dependency>
+ <!-- <dependency>-->
+ <!-- <groupId>org.apache.iotdb</groupId>-->
+ <!-- <artifactId>iotdb-server</artifactId>-->
+ <!-- <version>2.0.1-beta</version>-->
+ <!-- </dependency>-->
+ <dependency>
+ <groupId>org.apache.iotdb</groupId>
+ <artifactId>iotdb-thrift-commons</artifactId>
+ <version>2.0.1-beta</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.iotdb</groupId>
+ <artifactId>iotdb-thrift</artifactId>
+ <version>2.0.1-beta</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.iotdb</groupId>
+ <artifactId>iotdb-session</artifactId>
+ <version>2.0.1-beta</version>
+ </dependency>
+ <dependency>
+ <groupId>net.java.dev.jna</groupId>
+ <artifactId>jna</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>net.java.dev.jna</groupId>
+ <artifactId>jna-platform</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>com.google.code.findbugs</groupId>
+ <artifactId>jsr305</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.thrift</groupId>
+ <artifactId>libthrift</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>com.google.guava</groupId>
+ <artifactId>guava</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.eclipse.milo</groupId>
+ <artifactId>stack-core</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.eclipse.milo</groupId>
+ <artifactId>sdk-core</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.eclipse.milo</groupId>
+ <artifactId>stack-server</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.eclipse.milo</groupId>
+ <artifactId>sdk-server</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>commons-io</groupId>
+ <artifactId>commons-io</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>com.github.luben</groupId>
+ <artifactId>zstd-jni</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.tsfile</groupId>
+ <artifactId>common</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>com.github.ben-manes.caffeine</groupId>
+ <artifactId>caffeine</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>io.moquette</groupId>
+ <artifactId>moquette-broker</artifactId>
+ </dependency>
+ <groupId>com.google.code.findbugs</groupId>
+ <artifactId>jsr305</artifactId>
+ </dependency>
</dependencies>
<build>
<plugins>