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 a01f5f03e7 [Fix][Connector-V2] Support YashanDB VARCHAR2 and NVARCHAR2
type conversion (#11874)
add 9f229ce3e7 [Feature] [Connector-V2] [NebulaGraph] Add vertex sink
connector (#11865)
No new revisions were added by this update.
Summary of changes:
.github/workflows/labeler/label-scope-conf.yml | 7 +
config/plugin_config | 1 +
...connector-fluss.md => connector-nebulagraph.md} | 5 +
docs/en/connectors/sink/NebulaGraph.md | 127 +++++++++++
.../connectors/changelog/connector-nebulagraph.md | 11 +
docs/zh/connectors/sink/NebulaGraph.md | 127 +++++++++++
plugin-mapping.properties | 1 +
.../connector-nebulagraph/pom.xml | 92 ++++++++
.../nebulagraph/client/NebulaGraphClient.java} | 10 +-
.../client/SessionPoolNebulaGraphClient.java | 84 ++++++++
.../nebulagraph/config/NebulaGraphSinkConfig.java | 235 +++++++++++++++++++++
.../nebulagraph/config/NebulaGraphSinkOptions.java | 107 ++++++++++
.../nebulagraph/config/NebulaGraphWriteMode.java} | 8 +-
.../exception/NebulaGraphConnectorErrorCode.java} | 22 +-
.../exception/NebulaGraphConnectorException.java} | 14 +-
.../nebulagraph/sink/NebulaGraphRowConverter.java | 209 ++++++++++++++++++
.../nebulagraph/sink/NebulaGraphSink.java} | 17 +-
.../nebulagraph/sink/NebulaGraphSinkFactory.java} | 46 ++--
.../nebulagraph/sink/NebulaGraphSinkWriter.java | 162 ++++++++++++++
.../sink/NebulaGraphStatementBuilder.java | 173 +++++++++++++++
.../nebulagraph/sink/NebulaGraphVertex.java} | 27 ++-
.../nebulagraph/sink/NebulaGraphWriteRequest.java | 29 ++-
.../client/SessionPoolNebulaGraphClientTest.java | 52 +++++
.../config/NebulaGraphSinkConfigTest.java | 112 ++++++++++
.../sink/NebulaGraphSinkWriterTest.java | 187 ++++++++++++++++
.../sink/NebulaGraphStatementBuilderTest.java | 121 +++++++++++
seatunnel-connectors-v2/pom.xml | 1 +
seatunnel-dist/pom.xml | 6 +
seatunnel-dist/release-docs/LICENSE | 2 +
.../pom.xml | 18 +-
.../e2e/connector/nebulagraph/NebulaGraphIT.java | 201 ++++++++++++++++++
.../nebulagraph/fake_to_nebulagraph_insert.conf} | 51 +++--
.../nebulagraph/fake_to_nebulagraph_update.conf} | 33 +--
seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml | 1 +
34 files changed, 2161 insertions(+), 138 deletions(-)
copy docs/en/connectors/changelog/{connector-fluss.md =>
connector-nebulagraph.md} (54%)
create mode 100644 docs/en/connectors/sink/NebulaGraph.md
create mode 100644 docs/zh/connectors/changelog/connector-nebulagraph.md
create mode 100644 docs/zh/connectors/sink/NebulaGraph.md
create mode 100644 seatunnel-connectors-v2/connector-nebulagraph/pom.xml
copy
seatunnel-connectors-v2/{connector-snmp/src/main/java/org/apache/seatunnel/connectors/seatunnel/snmp/source/SnmpClient.java
=>
connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/client/NebulaGraphClient.java}
(78%)
create mode 100644
seatunnel-connectors-v2/connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/client/SessionPoolNebulaGraphClient.java
create mode 100644
seatunnel-connectors-v2/connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/config/NebulaGraphSinkConfig.java
create mode 100644
seatunnel-connectors-v2/connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/config/NebulaGraphSinkOptions.java
copy
seatunnel-connectors-v2/{connector-azure-queue-storage/src/main/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/config/MessageFormat.java
=>
connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/config/NebulaGraphWriteMode.java}
(86%)
copy
seatunnel-connectors-v2/{connector-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/exception/DingTalkConnectorErrorCode.java
=>
connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/exception/NebulaGraphConnectorErrorCode.java}
(68%)
copy
seatunnel-connectors-v2/{connector-azure-queue-storage/src/main/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/exception/AzureQueueConnectorException.java
=>
connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/exception/NebulaGraphConnectorException.java}
(72%)
create mode 100644
seatunnel-connectors-v2/connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/sink/NebulaGraphRowConverter.java
copy
seatunnel-connectors-v2/{connector-azure-queue-storage/src/main/java/org/apache/seatunnel/connectors/seatunnel/azure/queue/sink/AzureQueueStorageSink.java
=>
connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/sink/NebulaGraphSink.java}
(73%)
copy
seatunnel-connectors-v2/{connector-selectdb-cloud/src/main/java/org/apache/seatunnel/connectors/selectdb/sink/SelectDBSinkFactory.java
=>
connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/sink/NebulaGraphSinkFactory.java}
(54%)
create mode 100644
seatunnel-connectors-v2/connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/sink/NebulaGraphSinkWriter.java
create mode 100644
seatunnel-connectors-v2/connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/sink/NebulaGraphStatementBuilder.java
copy
seatunnel-connectors-v2/{connector-selectdb-cloud/src/main/java/org/apache/seatunnel/connectors/selectdb/rest/CopyIntoResp.java
=>
connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/sink/NebulaGraphVertex.java}
(61%)
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/error/ErrorSinkConfig.java
=>
seatunnel-connectors-v2/connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/sink/NebulaGraphWriteRequest.java
(60%)
create mode 100644
seatunnel-connectors-v2/connector-nebulagraph/src/test/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/client/SessionPoolNebulaGraphClientTest.java
create mode 100644
seatunnel-connectors-v2/connector-nebulagraph/src/test/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/config/NebulaGraphSinkConfigTest.java
create mode 100644
seatunnel-connectors-v2/connector-nebulagraph/src/test/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/sink/NebulaGraphSinkWriterTest.java
create mode 100644
seatunnel-connectors-v2/connector-nebulagraph/src/test/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/sink/NebulaGraphStatementBuilderTest.java
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-sensorsdata-e2e =>
connector-nebulagraph-e2e}/pom.xml (81%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-nebulagraph-e2e/src/test/java/org/apache/seatunnel/e2e/connector/nebulagraph/NebulaGraphIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-databend-e2e/src/test/resources/databend/fake_to_databend.conf
=>
connector-nebulagraph-e2e/src/test/resources/nebulagraph/fake_to_nebulagraph_insert.conf}
(69%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-google-pubsub-e2e/src/test/resources/pubsub/fake_to_google_pubsub.conf
=>
connector-nebulagraph-e2e/src/test/resources/nebulagraph/fake_to_nebulagraph_update.conf}
(74%)
