This is an automated email from the ASF dual-hosted git repository.
zongwen pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from a5a39598c Revert "[Feature] [Plugin] add spark cache transform
(#2854)" (#3491)
add efa04b38f [Feature][Connector][Neo4j] expose configurable options in
Neo4j (#3342)
No new revisions were added by this update.
Summary of changes:
docs/en/connector-v2/sink/Neo4j.md | 2 +-
docs/en/connector-v2/source/Neo4j.md | 2 +-
.../seatunnel/neo4j/config/Neo4jCommonConfig.java | 78 +++++++++---
.../{Neo4jSinkConfig.java => Neo4jQueryInfo.java} | 19 ++-
.../seatunnel/neo4j/config/Neo4jSinkConfig.java | 16 +--
...4jSourceConfig.java => Neo4jSinkQueryInfo.java} | 7 +-
...SourceConfig.java => Neo4jSourceQueryInfo.java} | 3 +-
.../connectors/seatunnel/neo4j/sink/Neo4jSink.java | 51 ++++----
.../seatunnel/neo4j/sink/Neo4jSinkFactory.java | 53 ++++++++
.../seatunnel/neo4j/sink/Neo4jSinkWriter.java | 18 +--
.../seatunnel/neo4j/source/Neo4jSource.java | 55 ++++----
.../seatunnel/neo4j/source/Neo4jSourceFactory.java | 53 ++++++++
.../seatunnel/neo4j/source/Neo4jSourceReader.java | 18 +--
.../connector-neo4j-e2e}/pom.xml | 23 +---
.../seatunnel/e2e/connector}/neo4j/Neo4jIT.java | 53 +++++---
.../src/test/resources/neo4j/neo4j_to_neo4j.conf | 3 +-
seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml | 1 +
.../connector-neo4j-flink-e2e/pom.xml | 59 ---------
.../src/test/resources/neo4j/neo4j_to_neo4j.conf | 90 -------------
.../seatunnel-flink-connector-v2-e2e/pom.xml | 1 -
.../seatunnel/e2e/spark/v2/neo4j/Neo4jIT.java | 139 ---------------------
.../seatunnel-spark-connector-v2-e2e/pom.xml | 1 -
22 files changed, 312 insertions(+), 433 deletions(-)
copy
seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/{Neo4jSinkConfig.java
=> Neo4jQueryInfo.java} (72%)
copy
seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/{Neo4jSourceConfig.java
=> Neo4jSinkQueryInfo.java} (84%)
copy
seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/{Neo4jSourceConfig.java
=> Neo4jSourceQueryInfo.java} (93%)
create mode 100644
seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/sink/Neo4jSinkFactory.java
create mode 100644
seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/source/Neo4jSourceFactory.java
rename
seatunnel-e2e/{seatunnel-spark-connector-v2-e2e/connector-neo4j-spark-e2e =>
seatunnel-connector-v2-e2e/connector-neo4j-e2e}/pom.xml (81%)
rename
seatunnel-e2e/{seatunnel-flink-connector-v2-e2e/connector-neo4j-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2
=>
seatunnel-connector-v2-e2e/connector-neo4j-e2e/src/test/java/org/apache/seatunnel/e2e/connector}/neo4j/Neo4jIT.java
(75%)
rename
seatunnel-e2e/{seatunnel-spark-connector-v2-e2e/connector-neo4j-spark-e2e =>
seatunnel-connector-v2-e2e/connector-neo4j-e2e}/src/test/resources/neo4j/neo4j_to_neo4j.conf
(97%)
delete mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-neo4j-flink-e2e/pom.xml
delete mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-neo4j-flink-e2e/src/test/resources/neo4j/neo4j_to_neo4j.conf
delete mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-neo4j-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/neo4j/Neo4jIT.java
