This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kudu.git
from d837674 Initial commit
new 427098d [FLINK-34930] Initialize tools/ and vcs.xml
new 663ffd1 [FLINK-34930] Remove Python CI
new 37a3e55 [BAHIR-99] kudu connector
new 701fabe [BAHIR-179] Fail Docker integration tests silently
new f0cd1d9 [BAHIR-194] bump kudu version to 1.8.0
new 247dfe9 [BAHIR-180] Improve eventual consistence for Kudu connector
new 1e26505 [BAHIR-199] Bump kudu version to 1.9.0
new f9c75bb [BAHIR-202] Improve KuduSink throughput using async FlushMode
new a1b4da5 [BAHIR-200] Move tests from docker to kudu-test-utils (#49)
new 02deb51 [BAHIR-209] upgrade kudu version to 1.10.0 (#61)
new 47133a3 [BAHIR-207] Add tests for scala 2.12 on travis (#59)
new 73e87f9 [BAHIR-214] Improve speed and solve eventual consistence
issues (#64)
new c380e40 Add support "upsert part of columns of a kudu table" (#70)
new 9b99c18 Fix "the client has already been closed" bug (#75)
new 6da6ad7 Fix NotSerializableException in Kudu connector (#74)
new 3c57f2e Kudu Connector rework (#78)
new 6e8b66f Add batch table env support and filter push down to Kudu
connector (#82)
new 3f9db63 BAHIR-240: replace docker test by testcontainer (#89)
new 7b5d717 [BAHIR-241] Upgrade all connectors to Flink 1.11 (#99)
new 4a5ec77 [BAHIR-263] Update flink to 1.12.2 (#115)
new 6500475 [BAHIR-260] Add kudu table writer config (#109)
new 03f0312 [BAHIR-293] Fix documentation tables
new b9cd23e [BAHIR-291] Bump flink to 1.14.0 (#136)
new 7700edb [BAHIR-296] Unify log4j libs
new 1dce829 BAHIR-296: Unify mockito version to 1.10.19
new e9c2a76 [BAHIR-302] Add enforcers
new 6832f05 [BAHIR-243] Change KuduTestHarness with TestContainers
new 285a6e1 [BAHIR-302] Group declaration of flink dependencies on parent
pom
new af8dff4 [maven-release-plugin] prepare for next development iteration
new aca6e7b [BAHIR-305] Kudu Flink SQL Support
DynamicSource/Sink&LookupFunction
new bef51ab [BAHIR-312] Add license header to README.md files
new 2e75a60 [BAHIR-321] Make KuduFilterInfo handle String literals
new 5a1da31 [BAHIR-308] Remove support for scala 2.11
new 6ff53e7 [BAHIR-308] Bump flink version to 1.15.3
new 78c76c5 [BAHIR-308] Remove scala prefix where we can
new d8c803a [BAHIR-324] Closing KuduReader at JobManager
new 0335544 [FLINK-34930] Adapt POM files to the new structure, remove
flink-shaded Guava usage
new abf6eba [FLINK-34930] Apply spotless code format and checkstyle rules
new 34cb67f [FLINK-34930] Rename base package
new abc4a3b [FLINK-34930] Fix KuduTableSourceITCase
new 9253b9d [FLINK-34930] State Bahir fork
new c7dfb67 [FLINK-34930] Skip spotless for JDK 21+
new 5230ec1 [FLINK-34930] Enable module opens for tests for newer JDKs
new 8674446 [FLINK-34930] Migrate Bahir NOTICE
The 44 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:
.github/workflows/push_pr.yml | 7 -
.gitmodules | 4 +
.idea/vcs.xml | 25 +
NOTICE | 6 +-
README.md | 6 +-
flink-connector-kudu/README.md | 324 ++++++++++++
flink-connector-kudu/pom.xml | 97 ++++
.../kudu/connector/ColumnSchemasFactory.java | 43 ++
.../kudu/connector/CreateTableOptionsFactory.java | 42 ++
.../connector/kudu/connector/KuduFilterInfo.java | 199 ++++++++
.../connector/kudu/connector/KuduTableInfo.java | 127 +++++
.../connector/converter/RowResultConverter.java | 41 ++
.../connector/converter/RowResultRowConverter.java | 46 ++
.../converter/RowResultRowDataConverter.java | 104 ++++
.../failure/DefaultKuduFailureHandler.java | 38 ++
.../kudu/connector/failure/KuduFailureHandler.java | 54 ++
.../kudu/connector/reader/KuduInputSplit.java | 46 ++
.../kudu/connector/reader/KuduReader.java | 198 ++++++++
.../kudu/connector/reader/KuduReaderConfig.java | 89 ++++
.../kudu/connector/reader/KuduReaderIterator.java | 68 +++
.../writer/AbstractSingleOperationMapper.java | 108 ++++
.../kudu/connector/writer/KuduOperationMapper.java | 46 ++
.../kudu/connector/writer/KuduWriter.java | 168 ++++++
.../kudu/connector/writer/KuduWriterConfig.java | 206 ++++++++
.../kudu/connector/writer/PojoOperationMapper.java | 86 ++++
.../writer/RowDataUpsertOperationMapper.java | 155 ++++++
.../kudu/connector/writer/RowOperationMapper.java | 39 ++
.../connector/writer/TupleOperationMapper.java | 39 ++
.../kudu/format/AbstractKuduInputFormat.java | 178 +++++++
.../connector/kudu/format/KuduOutputFormat.java | 102 ++++
.../kudu/format/KuduRowDataInputFormat.java | 62 +++
.../connector/kudu/format/KuduRowInputFormat.java | 62 +++
.../flink/connector/kudu/streaming/KuduSink.java | 124 +++++
.../kudu/table/AbstractReadOnlyCatalog.java | 189 +++++++
.../flink/connector/kudu/table/KuduCatalog.java | 373 ++++++++++++++
.../connector/kudu/table/KuduTableFactory.java | 184 +++++++
.../flink/connector/kudu/table/KuduTableSink.java | 111 ++++
.../connector/kudu/table/KuduTableSource.java | 213 ++++++++
.../kudu/table/UpsertOperationMapper.java | 47 ++
.../kudu/table/dynamic/KuduDynamicTableSink.java | 104 ++++
.../kudu/table/dynamic/KuduDynamicTableSource.java | 230 +++++++++
.../dynamic/KuduDynamicTableSourceSinkFactory.java | 235 +++++++++
.../table/dynamic/catalog/KuduCatalogFactory.java | 69 +++
.../table/dynamic/catalog/KuduDynamicCatalog.java | 375 ++++++++++++++
.../table/function/lookup/KuduLookupOptions.java | 78 +++
.../function/lookup/KuduRowDataLookupFunction.java | 239 +++++++++
.../connector/kudu/table/utils/KuduTableUtils.java | 318 ++++++++++++
.../connector/kudu/table/utils/KuduTypeUtils.java | 154 ++++++
.../org.apache.flink.table.factories.Factory | 16 +
.../org.apache.flink.table.factories.TableFactory | 17 +
.../kudu/connector/KuduFilterInfoTest.java | 43 ++
.../connector/kudu/connector/KuduTestBase.java | 419 +++++++++++++++
.../kudu/format/KuduOutputFormatTest.java | 130 +++++
.../kudu/format/KuduRowDataInputFormatTest.java | 142 ++++++
.../kudu/format/KuduRowInputFormatTest.java | 108 ++++
.../connector/kudu/streaming/KuduSinkTest.java | 216 ++++++++
.../connector/kudu/table/KuduCatalogTest.java | 366 ++++++++++++++
.../connector/kudu/table/KuduTableFactoryTest.java | 227 +++++++++
.../kudu/table/KuduTableSourceITCase.java | 86 ++++
.../connector/kudu/table/KuduTableSourceTest.java | 182 +++++++
.../connector/kudu/table/KuduTableTestUtils.java | 48 ++
.../kudu/table/dynamic/KuduDynamicSinkTest.java | 86 ++++
.../kudu/table/dynamic/KuduDynamicSourceTest.java | 222 ++++++++
.../dynamic/KuduRowDataLookupFunctionTest.java | 143 ++++++
.../kudu/writer/AbstractOperationTest.java | 60 +++
.../kudu/writer/PojoOperationMapperTest.java | 88 ++++
.../writer/RowDataUpsertOperationMapperTest.java | 56 ++
.../kudu/writer/RowOperationMapperTest.java | 74 +++
.../kudu/writer/TupleOperationMapperTest.java | 76 +++
.../src/test/resources/log4j.properties | 36 +-
.../src/test/resources/log4j2-test.properties | 37 +-
pom.xml | 353 +++++++++++++
tools/ci/log4j.properties | 43 ++
tools/maven/checkstyle.xml | 562 +++++++++++++++++++++
tools/maven/suppressions.xml | 26 +
75 files changed, 9654 insertions(+), 66 deletions(-)
create mode 100644 .gitmodules
create mode 100644 .idea/vcs.xml
create mode 100644 flink-connector-kudu/README.md
create mode 100644 flink-connector-kudu/pom.xml
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/ColumnSchemasFactory.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/CreateTableOptionsFactory.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/KuduFilterInfo.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/KuduTableInfo.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/converter/RowResultConverter.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/converter/RowResultRowConverter.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/converter/RowResultRowDataConverter.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/failure/DefaultKuduFailureHandler.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/failure/KuduFailureHandler.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/reader/KuduInputSplit.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/reader/KuduReader.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/reader/KuduReaderConfig.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/reader/KuduReaderIterator.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/writer/AbstractSingleOperationMapper.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/writer/KuduOperationMapper.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/writer/KuduWriter.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/writer/KuduWriterConfig.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/writer/PojoOperationMapper.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/writer/RowDataUpsertOperationMapper.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/writer/RowOperationMapper.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/writer/TupleOperationMapper.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/format/AbstractKuduInputFormat.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/format/KuduOutputFormat.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/format/KuduRowDataInputFormat.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/format/KuduRowInputFormat.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/streaming/KuduSink.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/AbstractReadOnlyCatalog.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/KuduCatalog.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/KuduTableFactory.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/KuduTableSink.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/KuduTableSource.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/UpsertOperationMapper.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/dynamic/KuduDynamicTableSink.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/dynamic/KuduDynamicTableSource.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/dynamic/catalog/KuduCatalogFactory.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/dynamic/catalog/KuduDynamicCatalog.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/function/lookup/KuduLookupOptions.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/function/lookup/KuduRowDataLookupFunction.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/utils/KuduTableUtils.java
create mode 100644
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/utils/KuduTypeUtils.java
create mode 100644
flink-connector-kudu/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
create mode 100644
flink-connector-kudu/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/connector/KuduFilterInfoTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/connector/KuduTestBase.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/format/KuduOutputFormatTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/format/KuduRowDataInputFormatTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/format/KuduRowInputFormatTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/streaming/KuduSinkTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/table/KuduCatalogTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/table/KuduTableFactoryTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/table/KuduTableSourceITCase.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/table/KuduTableSourceTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/table/KuduTableTestUtils.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/table/dynamic/KuduDynamicSinkTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/table/dynamic/KuduDynamicSourceTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/table/dynamic/KuduRowDataLookupFunctionTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/writer/AbstractOperationTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/writer/PojoOperationMapperTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/writer/RowDataUpsertOperationMapperTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/writer/RowOperationMapperTest.java
create mode 100644
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/writer/TupleOperationMapperTest.java
copy .github/workflows/push_pr.yml =>
flink-connector-kudu/src/test/resources/log4j.properties (55%)
copy .github/workflows/push_pr.yml =>
flink-connector-kudu/src/test/resources/log4j2-test.properties (55%)
create mode 100644 pom.xml
create mode 100644 tools/ci/log4j.properties
create mode 100644 tools/maven/checkstyle.xml
create mode 100644 tools/maven/suppressions.xml
