This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from a140a0015b [Improve][CLI] Install source setup in a project virtual
environment (#12464)
add fae69186f1 [Feature][Connector-V2] support websocket connector source
(#12465)
No new revisions were added by this update.
Summary of changes:
.github/workflows/labeler/label-scope-conf.yml | 9 +
config/plugin_config | 1 +
...tor-cdc-oceanbase.md => connector-websocket.md} | 1 +
docs/en/connectors/source/WebSocket.md | 207 ++++++++
.../connectors/changelog/connector-websocket.md} | 1 +
docs/zh/connectors/source/WebSocket.md | 193 +++++++
plugin-mapping.properties | 1 +
.../pom.xml | 39 +-
.../websocket/config/WebSocketCommonOptions.java} | 33 +-
.../websocket/config/WebSocketMessageFormat.java} | 5 +-
.../websocket/config/WebSocketSourceConfig.java | 211 ++++++++
.../websocket/config/WebSocketSourceOptions.java | 145 ++++++
.../exception/WebSocketConnectorErrorCode.java} | 12 +-
.../exception/WebSocketConnectorException.java} | 11 +-
.../source/WebSocketDeserializationCollector.java | 76 +++
.../websocket/source/WebSocketSource.java | 137 +++++
.../websocket/source/WebSocketSourceClient.java | 302 +++++++++++
.../websocket/source/WebSocketSourceFactory.java} | 41 +-
.../websocket/source/WebSocketSourceReader.java | 159 ++++++
.../WebSocketTextDeserializationSchema.java} | 11 +-
.../seatunnel/websocket/WebSocketFactoryTest.java | 43 +-
.../config/WebSocketSourceConfigTest.java | 198 ++++++++
.../source/WebSocketSourceClientTest.java | 142 ++++++
.../source/WebSocketSourceReaderTest.java | 553 +++++++++++++++++++++
.../websocket/source/WebSocketSourceTest.java | 110 ++++
seatunnel-connectors-v2/pom.xml | 1 +
seatunnel-dist/pom.xml | 7 +
.../pom.xml | 27 +-
.../e2e/connector/websocket/WebSocketSourceIT.java | 116 +++++
.../src/test/resources/websocket_to_assert.conf} | 31 +-
seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml | 1 +
31 files changed, 2709 insertions(+), 115 deletions(-)
copy docs/en/connectors/changelog/{connector-cdc-oceanbase.md =>
connector-websocket.md} (59%)
create mode 100644 docs/en/connectors/source/WebSocket.md
copy docs/{en/connectors/changelog/connector-cdc-oceanbase.md =>
zh/connectors/changelog/connector-websocket.md} (59%)
create mode 100644 docs/zh/connectors/source/WebSocket.md
copy seatunnel-connectors-v2/{connector-typesense =>
connector-websocket}/pom.xml (80%)
copy
seatunnel-connectors-v2/{connector-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/config/DingTalkSinkOptions.java
=>
connector-websocket/src/main/java/org/apache/seatunnel/connectors/seatunnel/websocket/config/WebSocketCommonOptions.java}
(51%)
copy
seatunnel-connectors-v2/{connector-google-pubsub/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/pubsub/config/MessageFormat.java
=>
connector-websocket/src/main/java/org/apache/seatunnel/connectors/seatunnel/websocket/config/WebSocketMessageFormat.java}
(82%)
create mode 100644
seatunnel-connectors-v2/connector-websocket/src/main/java/org/apache/seatunnel/connectors/seatunnel/websocket/config/WebSocketSourceConfig.java
create mode 100644
seatunnel-connectors-v2/connector-websocket/src/main/java/org/apache/seatunnel/connectors/seatunnel/websocket/config/WebSocketSourceOptions.java
copy
seatunnel-connectors-v2/{connector-tablestore/src/main/java/org/apache/seatunnel/connectors/seatunnel/tablestore/exception/TablestoreConnectorErrorCode.java
=>
connector-websocket/src/main/java/org/apache/seatunnel/connectors/seatunnel/websocket/exception/WebSocketConnectorErrorCode.java}
(67%)
copy
seatunnel-connectors-v2/{connector-amazonsqs/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/exception/AmazonSqsConnectorException.java
=>
connector-websocket/src/main/java/org/apache/seatunnel/connectors/seatunnel/websocket/exception/WebSocketConnectorException.java}
(81%)
create mode 100644
seatunnel-connectors-v2/connector-websocket/src/main/java/org/apache/seatunnel/connectors/seatunnel/websocket/source/WebSocketDeserializationCollector.java
create mode 100644
seatunnel-connectors-v2/connector-websocket/src/main/java/org/apache/seatunnel/connectors/seatunnel/websocket/source/WebSocketSource.java
create mode 100644
seatunnel-connectors-v2/connector-websocket/src/main/java/org/apache/seatunnel/connectors/seatunnel/websocket/source/WebSocketSourceClient.java
copy
seatunnel-connectors-v2/{connector-http/connector-http-posthog/src/main/java/org/apache/seatunnel/connectors/seatunnel/posthog/source/PostHogSourceFactory.java
=>
connector-websocket/src/main/java/org/apache/seatunnel/connectors/seatunnel/websocket/source/WebSocketSourceFactory.java}
(59%)
create mode 100644
seatunnel-connectors-v2/connector-websocket/src/main/java/org/apache/seatunnel/connectors/seatunnel/websocket/source/WebSocketSourceReader.java
copy
seatunnel-connectors-v2/{connector-edge-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/edgesocket/source/EdgeSocketTextDeserializationSchema.java
=>
connector-websocket/src/main/java/org/apache/seatunnel/connectors/seatunnel/websocket/source/WebSocketTextDeserializationSchema.java}
(79%)
copy
seatunnel-transforms-v2/src/test/java/org/apache/seatunnel/transform/metadata/MetadataTransformFactoryTest.java
=>
seatunnel-connectors-v2/connector-websocket/src/test/java/org/apache/seatunnel/connectors/seatunnel/websocket/WebSocketFactoryTest.java
(52%)
create mode 100644
seatunnel-connectors-v2/connector-websocket/src/test/java/org/apache/seatunnel/connectors/seatunnel/websocket/config/WebSocketSourceConfigTest.java
create mode 100644
seatunnel-connectors-v2/connector-websocket/src/test/java/org/apache/seatunnel/connectors/seatunnel/websocket/source/WebSocketSourceClientTest.java
create mode 100644
seatunnel-connectors-v2/connector-websocket/src/test/java/org/apache/seatunnel/connectors/seatunnel/websocket/source/WebSocketSourceReaderTest.java
create mode 100644
seatunnel-connectors-v2/connector-websocket/src/test/java/org/apache/seatunnel/connectors/seatunnel/websocket/source/WebSocketSourceTest.java
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-azure-event-hubs-e2e
=> connector-websocket-e2e}/pom.xml (80%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-websocket-e2e/src/test/java/org/apache/seatunnel/e2e/connector/websocket/WebSocketSourceIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-firebase-e2e/src/test/resources/firebase_source_to_assert.conf
=> connector-websocket-e2e/src/test/resources/websocket_to_assert.conf} (77%)
