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 8ec7bc216abe0d860e6db14cce666d331ba352b8 Merge: e736cb0 2d9a3f1 Author: Steve Yurong Su <[email protected]> AuthorDate: Wed Mar 12 11:47:00 2025 +0800 Merge branch 'master' of https://github.com/apache/iotdb-extras into pr/52 connectors/flink-iotdb-connector/pom.xml | 12 +-- .../iotdb/flink/DefaultIoTSerializationSchema.java | 2 +- .../main/java/org/apache/iotdb/flink/Event.java | 2 +- .../java/org/apache/iotdb/flink/IoTDBSink.java | 4 +- .../java/org/apache/iotdb/flink/IoTDBSource.java | 2 +- .../iotdb/flink/options/IoTDBSinkOptions.java | 6 +- connectors/flink-sql-iotdb-connector/pom.xml | 12 +-- .../flink/sql/client/IoTDBWebSocketClient.java | 2 +- .../org/apache/iotdb/flink/sql/common/Utils.java | 12 +-- .../sql/function/IoTDBBoundedScanFunction.java | 4 +- .../flink/sql/function/IoTDBCDCSourceFunction.java | 26 +++--- .../flink/sql/function/IoTDBLookupFunction.java | 6 +- .../flink/sql/function/IoTDBSinkFunction.java | 2 +- .../iotdb/flink/sql/wrapper/TabletWrapper.java | 3 +- connectors/flink-tsfile-connector/pom.xml | 14 ++-- .../apache/iotdb/flink/tsfile/RowRecordParser.java | 3 +- .../iotdb/flink/tsfile/RowRowRecordParser.java | 9 +- .../iotdb/flink/tsfile/RowTSRecordConverter.java | 31 ++++--- .../iotdb/flink/tsfile/TSRecordConverter.java | 5 +- .../iotdb/flink/tsfile/TSRecordOutputFormat.java | 18 ++-- .../iotdb/flink/tsfile/TsFileInputFormat.java | 16 ++-- .../iotdb/flink/tsfile/TsFileOutputFormat.java | 10 +-- .../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 4 +- .../flink/tsfile/RowTsFileConnectorTestBase.java | 6 +- .../flink/tsfile/RowTsFileInputFormatTest.java | 3 +- .../flink/tsfile/RowTsFileInputFormatTestBase.java | 2 +- .../tsfile/RowTsFileOutputFormatTestBase.java | 21 +++-- .../util/TSFileConfigUtilCompletenessTest.java | 15 +++- .../apache/iotdb/flink/util/TsFileWriteUtil.java | 96 +++++++++++----------- connectors/grafana-connector/pom.xml | 6 +- .../controller/DatabaseConnectController.java | 2 +- .../org/apache/iotdb/web/grafana/dao/BasicDao.java | 3 +- .../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 2 +- .../grafana/service/DatabaseConnectService.java | 3 +- .../service/impl/DatabaseConnectServiceImpl.java | 2 +- connectors/grafana-plugin/pom.xml | 2 +- connectors/hadoop/pom.xml | 12 +-- .../iotdb/hadoop/fileSystem/HDFSConfUtil.java | 9 +- .../apache/iotdb/hadoop/fileSystem/HDFSInput.java | 3 +- .../apache/iotdb/hadoop/fileSystem/HDFSOutput.java | 3 +- .../org/apache/iotdb/hadoop/tsfile/IReaderSet.java | 2 +- .../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 2 +- .../iotdb/hadoop/tsfile/TSFOutputFormat.java | 2 +- .../iotdb/hadoop/tsfile/TSFRecordReader.java | 16 ++-- .../iotdb/hadoop/tsfile/TSFRecordWriter.java | 8 +- .../iotdb/hadoop/tsfile/record/HDFSTSRecord.java | 27 +++--- .../apache/iotdb/hadoop/tsfile/TSFHadoopTest.java | 6 +- .../iotdb/hadoop/tsfile/TsFileTestHelper.java | 38 ++++----- connectors/hive-connector/pom.xml | 15 ++-- .../org/apache/iotdb/hive/TSFHiveRecordReader.java | 8 +- .../org/apache/iotdb/hive/TSFHiveRecordWriter.java | 8 +- .../apache/iotdb/hive/TSFHiveInputFormatTest.java | 4 +- .../apache/iotdb/hive/TSFHiveRecordReaderTest.java | 4 +- .../org/apache/iotdb/hive/TsFileTestHelper.java | 40 ++++----- connectors/pom.xml | 2 +- connectors/spark-iotdb-connector/pom.xml | 8 +- .../spark-iotdb-connector/scala_2.11/pom.xml | 2 +- .../spark-iotdb-connector/scala_2.12/pom.xml | 2 +- .../org/apache/iotdb/spark/db/DataFrameTools.scala | 4 +- connectors/spark-tsfile/pom.xml | 14 ++-- .../iotdb/spark/tsfile/io/TsFileOutputFormat.java | 5 +- .../iotdb/spark/tsfile/io/TsFileRecordWriter.java | 10 +-- .../org/apache/iotdb/spark/tsfile/qp/Executor.java | 7 +- .../iotdb/spark/tsfile/qp/QueryProcessor.java | 3 +- .../spark/tsfile/qp/common/FilterOperator.java | 2 +- .../tsfile/qp/optimizer/PhysicalOptimizer.java | 9 +- .../org/apache/iotdb/spark/tsfile/Converter.scala | 4 +- .../apache/iotdb/spark/tsfile/DefaultSource.scala | 18 ++-- .../iotdb/spark/tsfile/NarrowConverter.scala | 71 ++++++++-------- .../spark/tsfile/NarrowTsFileOutputWriter.scala | 2 +- .../apache/iotdb/spark/tsfile/Transformer.scala | 2 +- .../apache/iotdb/spark/tsfile/WideConverter.scala | 85 +++++++++---------- .../spark/tsfile/WideTsFileOutputWriter.scala | 2 +- .../org/apache/iotdb/spark/tool/TsFileExample.java | 24 +++--- .../apache/iotdb/spark/tool/TsFileWriteTool.java | 28 +++---- .../apache/iotdb/spark/tsfile/ConverterTest.scala | 12 +-- .../org/apache/iotdb/spark/tsfile/TSFileSuit.scala | 4 +- connectors/zeppelin-interpreter/pom.xml | 2 +- .../apache/zeppelin/iotdb/IoTDBInterpreter.java | 2 +- distributions/pom.xml | 14 ++-- examples/flink-sql/pom.xml | 4 +- examples/flink/pom.xml | 10 +-- .../org/apache/iotdb/flink/FlinkIoTDBSink.java | 6 +- .../org/apache/iotdb/flink/FlinkIoTDBSource.java | 8 +- .../apache/iotdb/flink/FlinkTsFileBatchSink.java | 12 +-- .../apache/iotdb/flink/FlinkTsFileBatchSource.java | 6 +- .../apache/iotdb/flink/FlinkTsFileStreamSink.java | 12 +-- .../iotdb/flink/FlinkTsFileStreamSource.java | 6 +- .../java/org/apache/iotdb/flink/TsFileUtils.java | 35 ++++---- examples/hadoop/pom.xml | 4 +- .../iotdb/hadoop/tsfile/TSMRWriteExample.java | 18 ++-- .../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 41 ++++----- .../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 29 ++++--- examples/kafka/pom.xml | 2 +- .../main/java/org/apache/iotdb/kafka/Consumer.java | 6 +- .../org/apache/iotdb/kafka/ConsumerThread.java | 2 +- examples/pom.xml | 2 +- examples/pulsar/pom.xml | 2 +- .../org/apache/iotdb/pulsar/PulsarConsumer.java | 6 +- .../apache/iotdb/pulsar/PulsarConsumerThread.java | 2 +- examples/rabbitmq/pom.xml | 2 +- .../apache/iotdb/rabbitmq/RabbitMQConsumer.java | 6 +- examples/rocketmq/pom.xml | 2 +- .../apache/iotdb/rocketmq/RocketMQConsumer.java | 6 +- iotdb-collector/collector-core/pom.xml | 4 +- iotdb-collector/collector-openapi/pom.xml | 2 +- iotdb-collector/pom.xml | 2 +- pom.xml | 5 +- 108 files changed, 577 insertions(+), 578 deletions(-)
