This is an automated email from the ASF dual-hosted git repository.
kirs pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from 1c68c6d6e [Hotfix][core] Add serializable features to
SerializationSchema (#2552)
add 05ccf9d68 [Feature][Connector-V2] Add phoenix connector sink (#2499)
No new revisions were added by this update.
Summary of changes:
docs/en/connector-v2/sink/Phoenix.md | 41 +++++
docs/en/connector-v2/source/Phoenix.md | 39 +++++
pom.xml | 7 +
seatunnel-connectors-v2/connector-jdbc/pom.xml | 4 +
.../PhoenixDialect.java} | 10 +-
.../PhoenixDialectFactory.java} | 14 +-
.../PhoenixJdbcRowConverter.java} | 6 +-
.../dialect/phoenix/PhoenixTypeMapper.java | 133 +++++++++++++++
.../executor/SimpleBatchStatementExecutor.java | 6 +
.../seatunnel/e2e/flink/v2/jdbc/JdbcPhoenixIT.java | 181 +++++++++++++++++++++
...jdbc.conf => jdbc_phoenix_source_and_sink.conf} | 28 ++--
.../seatunnel/e2e/spark/v2/jdbc/JdbcPhoenixIT.java | 181 +++++++++++++++++++++
...sink.conf => jdbc_phoenix_source_and_sink.conf} | 16 +-
13 files changed, 623 insertions(+), 43 deletions(-)
create mode 100644 docs/en/connector-v2/sink/Phoenix.md
create mode 100644 docs/en/connector-v2/source/Phoenix.md
copy
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/{mysql/MysqlDialect.java
=> phoenix/PhoenixDialect.java} (88%)
copy
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/{mysql/MySqlDialectFactory.java
=> phoenix/PhoenixDialectFactory.java} (83%)
copy
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/{psql/PostgresJdbcRowConverter.java
=> phoenix/PhoenixJdbcRowConverter.java} (92%)
create mode 100644
seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/phoenix/PhoenixTypeMapper.java
create mode 100644
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcPhoenixIT.java
copy
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/src/test/resources/jdbc/{fakesource_to_jdbc.conf
=> jdbc_phoenix_source_and_sink.conf} (78%)
create mode 100644
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcPhoenixIT.java
copy
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/src/test/resources/jdbc/{jdbc_greenplum_source_and_sink.conf
=> jdbc_phoenix_source_and_sink.conf} (79%)
