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 1a8c637e99 [Fix][Transform-V2] Make SQL case conversion locale
independent (#11951)
add 25d6ba7f64 [Feature][Connector-V2] Add Azure Queue Storage source
(#12006)
No new revisions were added by this update.
Summary of changes:
.../changelog/connector-azure-queue-storage.md | 1 +
docs/en/connectors/source/AzureQueueStorage.md | 164 +++++++++
.../changelog/connector-azure-queue-storage.md | 1 +
docs/zh/connectors/source/AzureQueueStorage.md | 164 +++++++++
plugin-mapping.properties | 1 +
.../queue/client/AzureQueueClientFactory.java | 66 ++++
...sageFormat.java => AzureQueueClientConfig.java} | 23 +-
.../queue/config/AzureQueueConfigValidator.java | 98 ++++++
.../azure/queue/config/AzureQueueSinkConfig.java | 76 +---
.../azure/queue/config/AzureQueueSourceConfig.java | 113 ++++++
.../config/AzureQueueStorageSourceOptions.java | 75 ++++
.../exception/AzureQueueConnectorErrorCode.java | 7 +-
.../azure/queue/sink/AzureQueueStorageSender.java | 43 +--
.../azure/queue/source/AzureQueueMessage.java} | 30 +-
.../azure/queue/source/AzureQueueReceiver.java | 22 +-
.../queue/source/AzureQueueStorageReceiver.java | 114 ++++++
.../queue/source/AzureQueueStorageSource.java} | 35 +-
.../source/AzureQueueStorageSourceFactory.java | 137 ++++++++
.../source/AzureQueueStorageSourceReader.java | 328 +++++++++++++++++
.../queue/config/AzureQueueSourceConfigTest.java | 94 +++++
.../AzureQueueStorageSourceFactoryTest.java} | 7 +-
.../source/AzureQueueStorageSourceReaderTest.java | 387 +++++++++++++++++++++
.../queue/source/AzureQueueStorageSourceTest.java} | 43 ++-
.../connector/azure/queue/AzureQueueStorageIT.java | 91 +++++
...zure_queue.conf => azure_queue_to_console.conf} | 29 +-
25 files changed, 1953 insertions(+), 196 deletions(-)
create mode 100644 docs/en/connectors/source/AzureQueueStorage.md
create mode 100644 docs/zh/connectors/source/AzureQueueStorage.md
create mode 100644
seatunnel-connectors-v2/connector-azure-queue-storage/src/main/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/client/AzureQueueClientFactory.java
copy
seatunnel-connectors-v2/connector-azure-queue-storage/src/main/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/config/{MessageFormat.java
=> AzureQueueClientConfig.java} (66%)
create mode 100644
seatunnel-connectors-v2/connector-azure-queue-storage/src/main/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/config/AzureQueueConfigValidator.java
create mode 100644
seatunnel-connectors-v2/connector-azure-queue-storage/src/main/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/config/AzureQueueSourceConfig.java
create mode 100644
seatunnel-connectors-v2/connector-azure-queue-storage/src/main/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/config/AzureQueueStorageSourceOptions.java
copy
seatunnel-connectors-v2/{connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/StringRangeSplitDecision.java
=>
connector-azure-queue-storage/src/main/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/source/AzureQueueMessage.java}
(52%)
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/flow/Flow.java
=>
seatunnel-connectors-v2/connector-azure-queue-storage/src/main/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/source/AzureQueueReceiver.java
(66%)
create mode 100644
seatunnel-connectors-v2/connector-azure-queue-storage/src/main/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/source/AzureQueueStorageReceiver.java
copy
seatunnel-connectors-v2/{connector-google-pubsub/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/pubsub/source/GooglePubSubSource.java
=>
connector-azure-queue-storage/src/main/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/source/AzureQueueStorageSource.java}
(74%)
create mode 100644
seatunnel-connectors-v2/connector-azure-queue-storage/src/main/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/source/AzureQueueStorageSourceFactory.java
create mode 100644
seatunnel-connectors-v2/connector-azure-queue-storage/src/main/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/source/AzureQueueStorageSourceReader.java
create mode 100644
seatunnel-connectors-v2/connector-azure-queue-storage/src/test/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/config/AzureQueueSourceConfigTest.java
copy
seatunnel-connectors-v2/connector-azure-queue-storage/src/test/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/{sink/AzureQueueStorageSinkFactoryTest.java
=> source/AzureQueueStorageSourceFactoryTest.java} (79%)
create mode 100644
seatunnel-connectors-v2/connector-azure-queue-storage/src/test/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/source/AzureQueueStorageSourceReaderTest.java
copy
seatunnel-connectors-v2/{connector-google-pubsub/src/test/java/org/apache/seatunnel/connectors/seatunnel/google/pubsub/source/GooglePubSubSourceTest.java
=>
connector-azure-queue-storage/src/test/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/source/AzureQueueStorageSourceTest.java}
(59%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-azure-queue-storage-e2e/src/test/resources/azurequeue/{fake_to_azure_queue.conf
=> azure_queue_to_console.conf} (84%)
