This is an automated email from the ASF dual-hosted git repository.
eskabetxe pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/bahir-flink.git
from 379fc87 Bump httpclient to 4.5.13
new 3dec25b feat: add dynamic source/sink&lookup function&hash bucket
nums config
new 3e24c95 feat: add dynamicSourceSinkFactory SPI Class&add dynamicSink
test
new 62600e6 feat: add KuduRowDataInputFormatTest
new 06d8eb9 fix: kudu.master config -> kudu.masters
new d28d71f fix: update KuduDynamicSinkTest
new 10b9c36 fix: update KuduDynamicSinkTest
new 73a4fbd fix: reformat code style
new 987b0d8 fix: reformat code style
new 959df22 fix: reformat code style
new a0102df fix: fix ExtractionUtils.extractionError，update lookup
function
new e6c0017 Update RowResultRowDataConvertor.java
new ebb9085 Update RowDataUpsertOperationMapper.java
new a36999b Update RowResultRowDataConvertor.java
new 3ac6a21 Update RowDataUpsertOperationMapper.java
new 7b2563e Update AbstractKuduInputFormat.java
new 80a57e9 fix: reformat code style
The 16 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
flink-connector-kudu/README.md | 104 +++++----
.../connector/convertor/RowResultConvertor.java | 25 ++-
.../convertor/RowResultRowConvertor.java} | 39 ++--
.../convertor/RowResultRowDataConvertor.java | 88 ++++++++
.../kudu/connector/reader/KuduReader.java | 49 +++--
.../kudu/connector/reader/KuduReaderConfig.java | 2 +-
.../kudu/connector/reader/KuduReaderIterator.java | 30 +--
.../kudu/connector/writer/KuduWriterConfig.java | 2 +-
.../writer/RowDataUpsertOperationMapper.java | 144 ++++++++++++
.../AbstractKuduInputFormat.java} | 45 ++--
.../kudu/{batch => format}/KuduOutputFormat.java | 2 +-
.../kudu/format/KuduRowDataInputFormat.java | 52 +++++
.../connectors/kudu/format/KuduRowInputFormat.java | 55 +++++
.../flink/connectors/kudu/table/KuduCatalog.java | 5 +
.../connectors/kudu/table/KuduCatalogFactory.java | 73 -------
.../connectors/kudu/table/KuduTableFactory.java | 1 -
.../connectors/kudu/table/KuduTableSource.java | 40 ++--
.../kudu/table/dynamic/KuduDynamicTableSink.java | 88 ++++++++
.../kudu/table/dynamic/KuduDynamicTableSource.java | 173 +++++++++++++++
.../dynamic/KuduDynamicTableSourceSinkFactory.java | 243 +++++++++++++++++++++
.../table/dynamic/catalog/KuduCatalogFactory.java | 71 ++++++
.../catalog/KuduDynamicCatalog.java} | 58 ++---
.../table/function/lookup/KuduLookupOptions.java | 81 +++++++
.../function/lookup/KuduRowDataLookupFunction.java | 233 ++++++++++++++++++++
.../kudu/table/utils/KuduTableUtils.java | 68 +++---
.../org.apache.flink.table.factories.Factory | 2 +-
.../org.apache.flink.table.factories.TableFactory | 2 +-
.../connectors/kudu/connector/KuduTestBase.java | 123 ++++++++---
.../{batch => format}/KuduOutputFormatTest.java | 2 +-
.../KuduRowDataInputFormatTest.java} | 49 ++++-
.../KuduRowInputFormatTest.java} | 18 +-
.../kudu/table/KuduTableSourceITCase.java | 4 +-
.../kudu/table/dynamic/KuduDynamicSinkTest.java | 84 +++++++
.../kudu/table/dynamic/KuduDynamicSourceTest.java | 164 ++++++++++++++
.../dynamic/KuduRowDataLookupFunctionTest.java | 150 +++++++++++++
....java => RowDataUpsertOperationMapperTest.java} | 35 ++-
36 files changed, 2035 insertions(+), 369 deletions(-)
copy
flink-connector-flume/src/main/java/org/apache/flink/streaming/connectors/flume/FlumeEventBuilder.java
=>
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultConvertor.java
(61%)
copy
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/{table/UpsertOperationMapper.java
=> connector/convertor/RowResultRowConvertor.java} (53%)
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultRowDataConvertor.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/RowDataUpsertOperationMapper.java
rename
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/{batch/KuduRowInputFormat.java
=> format/AbstractKuduInputFormat.java} (70%)
rename
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/{batch =>
format}/KuduOutputFormat.java (98%)
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/KuduRowDataInputFormat.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/KuduRowInputFormat.java
delete mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduCatalogFactory.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSink.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSource.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/catalog/KuduCatalogFactory.java
copy
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/{KuduCatalog.java
=> dynamic/catalog/KuduDynamicCatalog.java} (85%)
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduLookupOptions.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduRowDataLookupFunction.java
copy
flink-connector-redis/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
=>
flink-connector-kudu/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
(90%)
rename
flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/{batch =>
format}/KuduOutputFormatTest.java (98%)
copy
flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/{batch/KuduInputFormatTest.java
=> format/KuduRowDataInputFormatTest.java} (62%)
rename
flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/{batch/KuduInputFormatTest.java
=> format/KuduRowInputFormatTest.java} (86%)
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSourceTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduRowDataLookupFunctionTest.java
copy
flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/writer/{RowOperationMapperTest.java
=> RowDataUpsertOperationMapperTest.java} (53%)
