This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from eaea43d2f9 [Doc] Add hive jdbc reference value (#5882)
add 8d9a0b7d11 [Feature][Kudu] Support multi-table source read (#5878)
No new revisions were added by this update.
Summary of changes:
docs/en/connector-v2/source/Kudu.md | 70 ++++++++++++++----
.../seatunnel/kudu/config/CommonConfig.java | 4 -
.../seatunnel/kudu/config/KuduSinkConfig.java | 3 +
.../seatunnel/kudu/config/KuduSourceConfig.java | 15 +++-
.../kudu/config/KuduSourceTableConfig.java | 85 ++++++++++++++++++++++
.../seatunnel/kudu/kuduclient/KuduInputFormat.java | 23 +++---
.../seatunnel/kudu/source/KuduSource.java | 27 ++++---
.../seatunnel/kudu/source/KuduSourceFactory.java | 63 +---------------
.../seatunnel/kudu/source/KuduSourceReader.java | 28 ++++++-
.../seatunnel/kudu/source/KuduSourceSplit.java | 3 +
.../kudu/source/KuduSourceSplitEnumerator.java | 84 +++++++++++++--------
.../seatunnel/kudu/state/KuduSourceState.java | 3 +-
.../connectors/seatunnel/kudu/util/KuduUtil.java | 39 +++++-----
.../connector-kudu-e2e/pom.xml | 14 ++++
.../{KuduIT.java => KuduWIthMultipleTableIT.java} | 60 +++++----------
...conf => kudu_to_assert_with_multipletable.conf} | 22 +++---
16 files changed, 334 insertions(+), 209 deletions(-)
create mode 100644
seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/config/KuduSourceTableConfig.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kudu-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kudu/{KuduIT.java
=> KuduWIthMultipleTableIT.java} (84%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kudu-e2e/src/test/resources/{kudu_to_console.conf
=> kudu_to_assert_with_multipletable.conf} (82%)
