This is an automated email from the ASF dual-hosted git repository.
critas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb-extras.git
from e1877ab Add compile-check for Java 17
add 2d9a3f1 Bump version to 2.0.2-SNAPSHOT (#53)
No new revisions were added by this update.
Summary of changes:
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(-)
