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 <[email protected]> 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>
