This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/npm_and_yarn/connectors/grafana-plugin/nanoid-3.3.8
in repository https://gitbox.apache.org/repos/asf/iotdb-extras.git
omit b8e14a7 chore(deps): Bump nanoid in /connectors/grafana-plugin
add 2193e14 Fixed the issue of displaying 0 when the number is null (#32)
add 55c7de7 Fixed the issue of displaying 0 when the number is null (#34)
add a11397e Add sonar & todos check & dependency check. (#37)
add 25ef8c7 Fix sonar could not find project distributions. (#40)
add eeab667 Add conde analysis & remove sonar (#41)
add 55640cc Add compile-check for java8 & java11 (#42)
add a812c4c Complete the migration of the collector node project (#43)
add 25a88f6 Collector: Refactoring the three phases of data collection
tasks using disruptor (#48)
add 541e1f5 Collector: Refactor package structure and polish code style
(#49)
add e1877ab Add compile-check for Java 17
add 2d9a3f1 Bump version to 2.0.2-SNAPSHOT (#53)
add 4785b88 IoTDB Table Spark Connector
add a5bba81 chore(deps): Bump @babel/runtime in
/connectors/grafana-plugin (#56)
add 94d5ace chore(deps): Bump @babel/helpers in
/connectors/grafana-plugin (#55)
add 39dbd24 chore(deps): Bump golang.org/x/net in /iotdb-operator (#54)
add 8cdcabb chore(deps): Bump org.springframework:spring-web from 5.3.33
to 5.3.39 (#1)
add 065ec4d Add mybatis-generator-plugin module (#46)
add 8c1477d chore(deps): Bump serialize-javascript in
/connectors/grafana-plugin (#39)
add 8c972b0 chore(deps): Bump nanoid in /connectors/grafana-plugin
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (b8e14a7)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/connectors/grafana-plugin/nanoid-3.3.8
(8c972b0)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/code-analysis.yml | 43 +++++
.github/workflows/compile-check.yml | 50 +++++
.github/workflows/dependency-check.yml | 61 ++++++
.github/workflows/grafana-plugin.yml | 3 +-
.github/workflows/todos-check.yml | 39 ++++
.gitignore | 8 +-
.../gradle-enterprise-workspace-id | 1 +
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/README.md | 2 +-
connectors/grafana-plugin/package.json | 2 +-
connectors/grafana-plugin/pkg/plugin/plugin.go | 10 +-
connectors/grafana-plugin/pom.xml | 2 +-
connectors/grafana-plugin/yarn.lock | 87 ++++++---
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 | 14 +-
.../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 | 3 +-
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 +-
.../iotdb-table-connector-3.3}/pom.xml | 33 +++-
...rg.apache.spark.sql.sources.DataSourceRegister} | 6 +-
.../iotdb/spark/table/db/IoTDBTableProvider.scala} | 10 +-
.../iotdb-table-connector-3.4}/pom.xml | 33 +++-
...rg.apache.spark.sql.sources.DataSourceRegister} | 6 +-
.../iotdb/spark/table/db/IoTDBTableProvider.scala} | 10 +-
.../iotdb-table-connector-3.5}/pom.xml | 33 +++-
...rg.apache.spark.sql.sources.DataSourceRegister} | 6 +-
.../iotdb/spark/table/db/IoTDBTableProvider.scala} | 10 +-
.../pom.xml | 105 ++++++-----
.../spark-iotdb-table-common}/pom.xml | 66 +++----
.../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} | 12 +-
.../spark/table/db/read/IoTDBPartitionReader.scala | 76 ++++++++
.../db/read/IoTDBPartitionReaderFactory.scala} | 16 +-
.../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} | 21 +--
.../spark/table/db/write/IoTDBWriteBuilder.scala} | 14 +-
.../spark/table/db/write/IoTDBWriteFactory.scala} | 16 +-
.../apache/iotdb/spark/table/db/UtilsTest.scala | 25 ++-
.../db/read/PushDownPredicateSQLBuilderTest.scala | 76 ++++++++
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 | 16 +-
...connector.xml => iotdb-spring-boot-starter.xml} | 8 +-
...-connector.xml => mybatis-generator-plugin.xml} | 8 +-
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 ++-
.../{pulsar => iotdb-spring-boot-start}/pom.xml | 50 ++---
examples/iotdb-spring-boot-start/readme.md | 116 ++++++++++++
.../IoTDBSpringBootStartApplication.java | 18 +-
.../service/IoTDBService.java | 69 +++++++
.../src/main/resources/application.properties | 19 +-
.../SpringBootIoTDBApplicationTests.java | 38 ++--
examples/kafka/pom.xml | 2 +-
.../main/java/org/apache/iotdb/kafka/Consumer.java | 6 +-
.../org/apache/iotdb/kafka/ConsumerThread.java | 2 +-
{connectors => examples/mybatis-generator}/pom.xml | 52 +++---
examples/mybatis-generator/readme.md | 102 ++++++++++
.../src/main/resources/generatorConfig.xml | 58 ++++++
examples/mybatisplus-generator/pom.xml | 86 +++++++++
examples/mybatisplus-generator/readme.md | 128 +++++++++++++
.../src/main/java/org/apache/iotdb/Main.java | 80 ++++++++
examples/pom.xml | 3 +-
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 +-
examples/spark-table/README.md | 103 +++++++++++
.../scala_2.12 => examples/spark-table}/pom.xml | 45 +++--
.../spark/table/SparkConnectorReadExample.scala | 42 ++---
.../spark/table/SparkConnectorSQLExample.scala | 59 ++++++
.../spark/table/SparkConnectorWriteExample.scala | 51 +++++
helm/templates/NOTES.txt | 19 ++
.../collector-core}/pom.xml | 101 +++++-----
.../org/apache/iotdb/collector/Application.java | 95 ++++++++++
.../collector/api/filter/ApiOriginFilter.java | 52 ++++++
.../api/ping/impl/PingApiServiceImpl.java | 39 ++--
.../api/v1/plugin/impl/PluginApiServiceImpl.java | 63 +++++++
.../PluginApiServiceRequestValidationHandler.java | 9 +-
.../api/v1/task/impl/TaskApiServiceImpl.java | 86 +++++++++
.../TaskApiServiceRequestValidationHandler.java | 47 +++++
.../iotdb/collector/config/ApiServiceOptions.java | 17 +-
.../iotdb/collector/config/Configuration.java | 88 +++++++++
.../org/apache/iotdb/collector/config/Options.java | 112 +++++++++++
.../iotdb/collector/config/TaskRuntimeOptions.java | 63 +++++++
.../iotdb/collector/config/TrimProperties.java | 42 +++--
.../iotdb/collector/plugin/api/PullSource.java | 11 +-
.../iotdb/collector/plugin/api/PushSource.java | 33 ++--
.../CollectorProcessorRuntimeConfiguration.java | 30 ++-
.../customizer/CollectorRuntimeEnvironment.java | 59 ++++++
.../CollectorSinkRuntimeConfiguration.java | 30 ++-
.../CollectorSourceRuntimeConfiguration.java | 30 ++-
.../collector/plugin/api/event/CollectorEvent.java | 10 +-
.../collector/plugin/api/event/DemoEvent.java | 27 +--
.../collector/plugin/builtin/BuiltinPlugin.java | 62 +++++++
.../builtin/processor/DoNothingProcessor.java | 67 +++++++
.../collector/plugin/builtin/sink/DemoSink.java | 85 +++++++++
.../plugin/builtin/source/HttpPullSource.java | 67 +++++++
.../plugin/builtin/source/HttpPushSource.java | 91 +++++++++
.../collector/runtime/plugin/PluginRuntime.java | 91 +++++++++
.../plugin/constructor/PluginConstructor.java | 99 ++++++++++
.../plugin/constructor/ProcessorConstructor.java | 48 +++++
.../plugin/constructor/SinkConstructor.java | 51 +++++
.../plugin/constructor/SourceConstructor.java | 59 ++++++
.../collector/runtime/plugin/meta/PluginMeta.java | 119 ++++++++++++
.../runtime/plugin/meta/PluginMetaKeeper.java | 101 ++++++++++
.../apache/iotdb/collector/runtime/task/Task.java | 92 +++++++++
.../iotdb/collector/runtime/task/TaskCombiner.java | 64 +++++++
.../iotdb/collector/runtime/task/TaskRuntime.java | 149 +++++++++++++++
.../runtime/task/event/EventCollector.java | 32 ++--
.../runtime/task/event/EventContainer.java | 17 +-
.../runtime/task/processor/ProcessorConsumer.java | 57 ++++++
.../task/processor/ProcessorExceptionHandler.java | 33 ++--
.../runtime/task/processor/ProcessorTask.java | 156 ++++++++++++++++
.../collector/runtime/task/sink/SinkConsumer.java | 54 ++++++
.../runtime/task/sink/SinkExceptionHandler.java | 34 ++--
.../collector/runtime/task/sink/SinkTask.java | 147 +++++++++++++++
.../collector/runtime/task/source/SourceTask.java | 67 +++++++
.../task/source/pull/PullSourceConsumer.java | 27 +--
.../runtime/task/source/pull/PullSourceTask.java | 144 ++++++++++++++
.../runtime/task/source/push/PushSourceTask.java | 101 ++++++++++
.../apache/iotdb/collector/service/ApiService.java | 101 ++++++++++
.../apache/iotdb/collector/service/IService.java | 18 +-
.../iotdb/collector/service/RuntimeService.java | 82 ++++++++
.../src/main/resources/application.properties | 56 ++++++
.../collector-core/src/main}/resources/logback.xml | 31 ++--
iotdb-collector/collector-openapi/pom.xml | 206 +++++++++++++++++++++
.../src/main/openapi3/ping/ping.yaml | 47 ++++-
.../src/main/openapi3/v1/plugin.yaml | 156 ++++++++++++++++
.../src/main/openapi3/v1/task.yaml | 154 +++++++++++++++
{examples/hadoop => iotdb-collector}/pom.xml | 20 +-
iotdb-operator/.dockerignore | 19 ++
iotdb-operator/.golangci.yml | 19 ++
iotdb-operator/Dockerfile | 19 ++
iotdb-operator/Makefile | 19 ++
iotdb-operator/PROJECT | 19 ++
iotdb-operator/config/certmanager/certificate.yaml | 19 ++
.../config/certmanager/kustomization.yaml | 19 ++
.../config/certmanager/kustomizeconfig.yaml | 19 ++
.../crd/bases/iotdb.apache.org_confignodes.yaml | 19 ++
.../crd/bases/iotdb.apache.org_datanodes.yaml | 19 ++
iotdb-operator/config/crd/kustomization.yaml | 19 ++
iotdb-operator/config/crd/kustomizeconfig.yaml | 19 ++
.../crd/patches/cainjection_in_confignodes.yaml | 19 ++
.../crd/patches/cainjection_in_datanodes.yaml | 19 ++
.../config/crd/patches/webhook_in_confignodes.yaml | 19 ++
.../config/crd/patches/webhook_in_datanodes.yaml | 19 ++
iotdb-operator/config/default/kustomization.yaml | 19 ++
.../config/default/manager_auth_proxy_patch.yaml | 19 ++
.../config/default/manager_config_patch.yaml | 19 ++
.../config/default/manager_webhook_patch.yaml | 19 ++
.../config/default/webhookcainjection_patch.yaml | 19 ++
iotdb-operator/config/manager/kustomization.yaml | 19 ++
iotdb-operator/config/manager/manager.yaml | 19 ++
iotdb-operator/config/manifests/kustomization.yaml | 19 ++
.../config/prometheus/kustomization.yaml | 19 ++
iotdb-operator/config/prometheus/monitor.yaml | 19 ++
.../config/rbac/auth_proxy_client_clusterrole.yaml | 19 ++
iotdb-operator/config/rbac/auth_proxy_role.yaml | 19 ++
.../config/rbac/auth_proxy_role_binding.yaml | 19 ++
iotdb-operator/config/rbac/auth_proxy_service.yaml | 19 ++
.../config/rbac/confignode_editor_role.yaml | 19 ++
.../config/rbac/confignode_viewer_role.yaml | 19 ++
.../config/rbac/datanode_editor_role.yaml | 19 ++
.../config/rbac/datanode_viewer_role.yaml | 19 ++
iotdb-operator/config/rbac/kustomization.yaml | 19 ++
.../config/rbac/leader_election_role.yaml | 19 ++
.../config/rbac/leader_election_role_binding.yaml | 19 ++
iotdb-operator/config/rbac/role.yaml | 19 ++
iotdb-operator/config/rbac/role_binding.yaml | 19 ++
iotdb-operator/config/rbac/service_account.yaml | 19 ++
.../config/samples/iotdb_v1_confignode.yaml | 19 ++
.../config/samples/iotdb_v1_datanode.yaml | 19 ++
iotdb-operator/config/samples/kustomization.yaml | 19 ++
.../config/samples/pv-example/confignode-pv.yaml | 19 ++
.../config/samples/pv-example/datanode-pv.yaml | 19 ++
iotdb-operator/config/scorecard/bases/config.yaml | 19 ++
iotdb-operator/config/scorecard/kustomization.yaml | 19 ++
.../config/scorecard/patches/basic.config.yaml | 19 ++
.../config/scorecard/patches/olm.config.yaml | 19 ++
iotdb-operator/config/webhook/kustomization.yaml | 19 ++
iotdb-operator/config/webhook/kustomizeconfig.yaml | 19 ++
iotdb-operator/config/webhook/manifests.yaml | 19 ++
iotdb-operator/config/webhook/service.yaml | 19 ++
iotdb-operator/go.mod | 11 +-
iotdb-operator/go.sum | 20 +-
iotdb-spring-boot-starter/README.md | 63 +++++++
.../rabbitmq => iotdb-spring-boot-starter}/pom.xml | 39 ++--
.../iotdb/config/IoTDBSessionProperties.java | 174 +++++++++++++++++
.../org/apache/iotdb/session/IoTDBSessionPool.java | 95 ++++++++++
...rk.boot.autoconfigure.AutoConfiguration.imports | 3 +-
mybatis-generator/.gitignore | 7 +
mybatis-generator/README-zh.md | 55 ++++++
mybatis-generator/README.md | 55 ++++++
mybatis-generator/pom.xml | 27 +++
.../iotdb/mybatis/plugin/BatchInsertPlugin.java | 133 +++++++++++++
.../apache/iotdb/mybatis/plugin/LombokPlugin.java | 64 +++++++
.../iotdb/mybatis/plugin/SerializablePlugin.java | 141 ++++++++++++++
.../plugin/generator/CNCommentGenerator.java | 129 +++++++++++++
.../plugin/generator/SwaggerCommentGenerator.java | 150 +++++++++++++++
.../generator/resolver/IoTDBJavaTypeResolver.java | 98 ++++++++++
.../resolver/JavaTypeResolverSelfImpl.java | 57 ++++++
.../apache/iotdb/mybatis/plugin/util/DateUtil.java | 15 +-
.../src/main/resources/generatorConfig.xml | 58 ++++++
pom.xml | 129 ++++++++++++-
294 files changed, 9262 insertions(+), 1251 deletions(-)
create mode 100644 .github/workflows/code-analysis.yml
create mode 100644 .github/workflows/compile-check.yml
create mode 100644 .github/workflows/dependency-check.yml
create mode 100644 .github/workflows/todos-check.yml
create mode 100644 .mvn/.gradle-enterprise/gradle-enterprise-workspace-id
copy connectors/{spark-iotdb-connector/scala_2.12 =>
spark-iotdb-table-connector/iotdb-table-connector-3.3}/pom.xml (63%)
copy
connectors/{flink-sql-iotdb-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
=>
spark-iotdb-table-connector/iotdb-table-connector-3.3/src/main/resources/META-INF/services/org.apache.spark.sql.sources.DataSourceRegister}
(86%)
copy
connectors/{spark-tsfile/src/test/scala/org/apache/iotdb/spark/constant/TestConstant.java
=>
spark-iotdb-table-connector/iotdb-table-connector-3.3/src/main/scala/org/apache/iotdb/spark/table/db/IoTDBTableProvider.scala}
(78%)
copy connectors/{spark-iotdb-connector/scala_2.12 =>
spark-iotdb-table-connector/iotdb-table-connector-3.4}/pom.xml (63%)
copy
connectors/{flink-sql-iotdb-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
=>
spark-iotdb-table-connector/iotdb-table-connector-3.4/src/main/resources/META-INF/services/org.apache.spark.sql.sources.DataSourceRegister}
(86%)
copy
connectors/{spark-tsfile/src/test/scala/org/apache/iotdb/spark/constant/TestConstant.java
=>
spark-iotdb-table-connector/iotdb-table-connector-3.4/src/main/scala/org/apache/iotdb/spark/table/db/IoTDBTableProvider.scala}
(78%)
copy connectors/{spark-iotdb-connector/scala_2.12 =>
spark-iotdb-table-connector/iotdb-table-connector-3.5}/pom.xml (63%)
copy
connectors/{flink-sql-iotdb-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
=>
spark-iotdb-table-connector/iotdb-table-connector-3.5/src/main/resources/META-INF/services/org.apache.spark.sql.sources.DataSourceRegister}
(86%)
copy
connectors/{spark-tsfile/src/test/scala/org/apache/iotdb/spark/constant/TestConstant.java
=>
spark-iotdb-table-connector/iotdb-table-connector-3.5/src/main/scala/org/apache/iotdb/spark/table/db/IoTDBTableProvider.scala}
(78%)
copy connectors/{spark-iotdb-connector => spark-iotdb-table-connector}/pom.xml
(61%)
copy connectors/{spark-tsfile =>
spark-iotdb-table-connector/spark-iotdb-table-common}/pom.xml (71%)
create mode 100644
connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/AbstractIoTDBTableProvider.scala
create mode 100644
connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/IoTDBOptions.scala
create mode 100644
connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/IoTDBTable.scala
create mode 100644
connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/IoTDBUtils.scala
create mode 100644
connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/read/IoTDBExpressionSQLBuilder.scala
copy
connectors/{spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/SQLConstant.scala
=>
spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/read/IoTDBInputPartition.scala}
(80%)
create mode 100644
connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/read/IoTDBPartitionReader.scala
copy
connectors/{grafana-connector/src/main/java/org/apache/iotdb/web/grafana/TsfileWebDemoApplication.java
=>
spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/read/IoTDBPartitionReaderFactory.scala}
(59%)
create mode 100644
connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/read/IoTDBScan.scala
create mode 100644
connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/read/IoTDBScanBuilder.scala
create mode 100644
connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/write/IoTDBDataWriter.scala
copy
connectors/{hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/IReaderSet.java
=>
spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/write/IoTDBWrite.scala}
(56%)
copy
connectors/{grafana-connector/src/main/java/org/apache/iotdb/web/grafana/TsfileWebDemoApplication.java
=>
spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/write/IoTDBWriteBuilder.scala}
(66%)
copy
connectors/{grafana-connector/src/main/java/org/apache/iotdb/web/grafana/TsfileWebDemoApplication.java
=>
spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/write/IoTDBWriteFactory.scala}
(60%)
copy examples/rocketmq/src/main/java/org/apache/iotdb/rocketmq/Utils.java =>
connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/test/scala/org/apache/iotdb/spark/table/db/UtilsTest.scala
(62%)
create mode 100644
connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/test/scala/org/apache/iotdb/spark/table/db/read/PushDownPredicateSQLBuilderTest.scala
copy distributions/src/assembly/{flink-sql-connector.xml =>
iotdb-spring-boot-starter.xml} (80%)
copy distributions/src/assembly/{flink-sql-connector.xml =>
mybatis-generator-plugin.xml} (80%)
copy examples/{pulsar => iotdb-spring-boot-start}/pom.xml (51%)
create mode 100644 examples/iotdb-spring-boot-start/readme.md
copy connectors/grafana-plugin/jest.config.js =>
examples/iotdb-spring-boot-start/src/main/java/org/apache/iotdb/iotdbspringbootstartexample/IoTDBSpringBootStartApplication.java
(68%)
create mode 100644
examples/iotdb-spring-boot-start/src/main/java/org/apache/iotdb/iotdbspringbootstartexample/service/IoTDBService.java
copy helm/templates/load-balancer.yaml =>
examples/iotdb-spring-boot-start/src/main/resources/application.properties (77%)
copy connectors/grafana-plugin/src/componments/WhereValue.tsx =>
examples/iotdb-spring-boot-start/src/test/java/org/apache/iotdb/iotdbspringbootstartexample/SpringBootIoTDBApplicationTests.java
(53%)
copy {connectors => examples/mybatis-generator}/pom.xml (55%)
create mode 100644 examples/mybatis-generator/readme.md
create mode 100644
examples/mybatis-generator/src/main/resources/generatorConfig.xml
create mode 100644 examples/mybatisplus-generator/pom.xml
create mode 100644 examples/mybatisplus-generator/readme.md
create mode 100644
examples/mybatisplus-generator/src/main/java/org/apache/iotdb/Main.java
create mode 100644 examples/spark-table/README.md
copy {connectors/spark-iotdb-connector/scala_2.12 =>
examples/spark-table}/pom.xml (56%)
copy
connectors/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/wrapper/SchemaWrapper.java
=>
examples/spark-table/src/main/scala/org/apache/iotdb/spark/table/SparkConnectorReadExample.scala
(51%)
create mode 100644
examples/spark-table/src/main/scala/org/apache/iotdb/spark/table/SparkConnectorSQLExample.scala
create mode 100644
examples/spark-table/src/main/scala/org/apache/iotdb/spark/table/SparkConnectorWriteExample.scala
copy {connectors/flink-sql-iotdb-connector =>
iotdb-collector/collector-core}/pom.xml (51%)
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/Application.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/filter/ApiOriginFilter.java
copy connectors/grafana-plugin/src/componments/WhereValue.tsx =>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/ping/impl/PingApiServiceImpl.java
(55%)
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/v1/plugin/impl/PluginApiServiceImpl.java
copy
connectors/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/SQLConstant.scala
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/v1/plugin/impl/PluginApiServiceRequestValidationHandler.java
(83%)
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/v1/task/impl/TaskApiServiceImpl.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/v1/task/impl/TaskApiServiceRequestValidationHandler.java
copy
connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/TsfileWebDemoApplication.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/ApiServiceOptions.java
(70%)
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/Configuration.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/Options.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/TaskRuntimeOptions.java
copy
connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/TrimProperties.java
(52%)
copy
connectors/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/SQLConstant.scala
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/PullSource.java
(83%)
copy
connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/PushSource.java
(57%)
copy
connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/Operator.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/customizer/CollectorProcessorRuntimeConfiguration.java
(51%)
mode change 100755 => 100644
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/customizer/CollectorRuntimeEnvironment.java
copy
connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/Operator.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/customizer/CollectorSinkRuntimeConfiguration.java
(52%)
mode change 100755 => 100644
copy
connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/Operator.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/customizer/CollectorSourceRuntimeConfiguration.java
(52%)
mode change 100755 => 100644
copy
connectors/spark-tsfile/src/test/scala/org/apache/iotdb/spark/constant/TestConstant.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/event/CollectorEvent.java
(73%)
copy
connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/event/DemoEvent.java
(69%)
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/BuiltinPlugin.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/processor/DoNothingProcessor.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/DemoSink.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/HttpPullSource.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/HttpPushSource.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/PluginRuntime.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/constructor/PluginConstructor.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/constructor/ProcessorConstructor.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/constructor/SinkConstructor.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/constructor/SourceConstructor.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/meta/PluginMeta.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/meta/PluginMetaKeeper.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/Task.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/TaskCombiner.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/TaskRuntime.java
copy
connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/event/EventCollector.java
(58%)
copy
connectors/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/MergeFilterException.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/event/EventContainer.java
(73%)
mode change 100755 => 100644
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/processor/ProcessorConsumer.java
copy
connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/service/impl/DatabaseConnectServiceImpl.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/processor/ProcessorExceptionHandler.java
(51%)
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/processor/ProcessorTask.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/sink/SinkConsumer.java
copy
connectors/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/service/impl/DatabaseConnectServiceImpl.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/sink/SinkExceptionHandler.java
(51%)
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/sink/SinkTask.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/source/SourceTask.java
copy
connectors/hive-connector/src/main/java/org/apache/iotdb/hive/TsFileSerDeException.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/source/pull/PullSourceConsumer.java
(56%)
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/source/pull/PullSourceTask.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/source/push/PushSourceTask.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/service/ApiService.java
copy
connectors/spark-tsfile/src/test/scala/org/apache/iotdb/spark/constant/TestConstant.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/service/IService.java
(75%)
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/service/RuntimeService.java
create mode 100644
iotdb-collector/collector-core/src/main/resources/application.properties
copy {connectors/hive-connector/src/test =>
iotdb-collector/collector-core/src/main}/resources/logback.xml (54%)
create mode 100644 iotdb-collector/collector-openapi/pom.xml
copy connectors/flink-tsfile-connector/src/test/resources/log4j.properties =>
iotdb-collector/collector-openapi/src/main/openapi3/ping/ping.yaml (50%)
create mode 100644
iotdb-collector/collector-openapi/src/main/openapi3/v1/plugin.yaml
create mode 100644
iotdb-collector/collector-openapi/src/main/openapi3/v1/task.yaml
copy {examples/hadoop => iotdb-collector}/pom.xml (74%)
create mode 100644 iotdb-spring-boot-starter/README.md
copy {examples/rabbitmq => iotdb-spring-boot-starter}/pom.xml (53%)
create mode 100644
iotdb-spring-boot-starter/src/main/java/org/apache/iotdb/config/IoTDBSessionProperties.java
create mode 100644
iotdb-spring-boot-starter/src/main/java/org/apache/iotdb/session/IoTDBSessionPool.java
copy
connectors/flink-sql-iotdb-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
=>
iotdb-spring-boot-starter/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
(92%)
create mode 100644 mybatis-generator/.gitignore
create mode 100644 mybatis-generator/README-zh.md
create mode 100644 mybatis-generator/README.md
create mode 100644 mybatis-generator/pom.xml
create mode 100644
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/BatchInsertPlugin.java
create mode 100644
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/LombokPlugin.java
create mode 100644
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/SerializablePlugin.java
create mode 100644
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/generator/CNCommentGenerator.java
create mode 100644
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/generator/SwaggerCommentGenerator.java
create mode 100644
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/generator/resolver/IoTDBJavaTypeResolver.java
create mode 100644
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/generator/resolver/JavaTypeResolverSelfImpl.java
copy connectors/grafana-plugin/.prettierrc.js =>
mybatis-generator/src/main/java/org/apache/iotdb/mybatis/plugin/util/DateUtil.java
(73%)
create mode 100644 mybatis-generator/src/main/resources/generatorConfig.xml
