[iotdb] branch master updated (1ae952ce14c -> 3073fe63bc3)

[ro...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from 1ae952ce14c [IOTDB-6127] Pipe: buffered events in processor stage can not be consumed by connector (#10962)
     add 3073fe63bc3  [IOTDB-6029] flink-sql-iotdb-connector (#10958)

No new revisions were added by this update.

Summary of changes:
 .../flink-sql-iotdb-connector}/pom.xml             |  37 ++-
 .../flink/sql/client/IoTDBWebSocketClient.java     |  75 ++++++
 .../org/apache/iotdb/flink/sql/common/Options.java |  55 +++++
 .../org/apache/iotdb/flink/sql/common/Utils.java   | 144 ++++++++++++
 .../sql/exception/IllegalIoTDBPathException.java   |   7 +-
 .../sql/exception/IllegalOptionException.java      |  13 +-
 .../sql/exception/IllegalSchemaException.java      |  13 +-
 .../sql/exception/IllegalUrlPathException.java     |  13 +-
 .../exception/UnsupportedDataTypeException.java    |   7 +-
 .../sql/factory/IoTDBDynamicTableFactory.java      | 189 +++++++++++++++
 .../sql/function/IoTDBBoundedScanFunction.java     | 163 +++++++++++++
 .../flink/sql/function/IoTDBCDCSourceFunction.java | 256 +++++++++++++++++++++
 .../flink/sql/function/IoTDBLookupFunction.java    | 151 ++++++++++++
 .../flink/sql/function/IoTDBSinkFunction.java      | 125 ++++++++++
 .../flink/sql/provider/IoTDBDynamicTableSink.java  |  64 ++++++
 .../sql/provider/IoTDBDynamicTableSource.java      |  76 ++++++
 .../iotdb/flink/sql/wrapper/SchemaWrapper.java     |  29 ++-
 .../iotdb/flink/sql/wrapper/TabletWrapper.java     |  41 ++--
 .../org.apache.flink.table.factories.Factory       |   2 +-
 iotdb-connector/pom.xml                            |   1 +
 iotdb-core/datanode/pom.xml                        |   5 +
 .../config/constant/PipeConnectorConstant.java     |   3 +
 .../websocket/WebSocketConnectorServer.java        | 216 +++++++++++++++++
 .../protocol/websocket/WebsocketConnector.java     | 139 +++++++++++
 .../connector/PipeConnectorSubtaskManager.java     |   3 +
 .../pipe/plugin/builtin/BuiltinPipePlugin.java     |   2 +
 ...hriftConnector.java => WebSocketConnector.java} |   4 +-
 pom.xml                                            |   2 +
 28 files changed, 1753 insertions(+), 82 deletions(-)
 copy {example/session => iotdb-connector/flink-sql-iotdb-connector}/pom.xml (58%)
 create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/client/IoTDBWebSocketClient.java
 create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/common/Options.java
 create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/common/Utils.java
 copy iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/exception/ProcedureTimeoutException.java => iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalIoTDBPathException.java (82%)
 copy iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/InternalReporterType.java => iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalOptionException.java (83%)
 copy iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/InternalReporterType.java => iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalSchemaException.java (83%)
 copy iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/InternalReporterType.java => iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalUrlPathException.java (82%)
 copy iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/exception/ProcedureTimeoutException.java => iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/UnsupportedDataTypeException.java (82%)
 create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/factory/IoTDBDynamicTableFactory.java
 create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBBoundedScanFunction.java
 create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBCDCSourceFunction.java
 create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBLookupFunction.java
 create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBSinkFunction.java
 create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/provider/IoTDBDynamicTableSink.java
 create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/provider/IoTDBDynamicTableSource.java
 copy iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/view/viewExpression/leaf/LeafViewOperand.java => iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/wrapper/SchemaWrapper.java (55%)
 copy iotdb-api/trigger-api/src/main/java/org/apache/iotdb/trigger/api/enums/TriggerEvent.java => iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/wrapper/TabletWrapper.java (55%)
 copy iotdb-core/datanode/src/main/resources/META-INF/services/org.apache.iotdb.db.protocol.mqtt.PayloadFormatter => iotdb-connector/flink-sql-iotdb-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory (93%)
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/websocket/WebSocketConnectorServer.java
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/websocket/WebsocketConnector.java
 copy iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBThriftConnector.java => WebSocketConnector.java} (92%)