This is an automated email from the ASF dual-hosted git repository.
fokko pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from c6a772618d API, Core: Fix errorprone warnings (#9419)
add d1a3c10450 Kafka Connect: Initial project setup and event data
structures (#8701)
No new revisions were added by this update.
Summary of changes:
.github/labeler.yml | 6 +
.../org/apache/iceberg/avro/AvroSchemaUtil.java | 13 +-
.../java/org/apache/iceberg/avro/TypeToSchema.java | 94 +++++++++---
.../apache/iceberg/data/avro/DecoderResolver.java | 4 +
.../build.gradle | 22 ++-
.../apache/iceberg/connect/events/AvroUtil.java | 95 +++++++++++++
.../iceberg/connect/events/CommitComplete.java | 113 +++++++++++++++
.../iceberg/connect/events/CommitToTable.java | 140 ++++++++++++++++++
.../iceberg/connect/events/DataComplete.java | 112 +++++++++++++++
.../apache/iceberg/connect/events/DataWritten.java | 158 +++++++++++++++++++++
.../org/apache/iceberg/connect/events/Event.java | 147 +++++++++++++++++++
.../org/apache/iceberg/connect/events/Payload.java | 17 +--
.../apache/iceberg/connect/events/PayloadType.java | 21 ++-
.../apache/iceberg/connect/events/StartCommit.java | 91 ++++++++++++
.../iceberg/connect/events/TableReference.java | 118 +++++++++++++++
.../connect/events/TopicPartitionOffset.java | 124 ++++++++++++++++
.../connect/events/EventSerializationTest.java | 126 ++++++++++++++++
.../iceberg/connect/events/EventTestUtil.java | 99 +++++++++++++
settings.gradle | 5 +
19 files changed, 1454 insertions(+), 51 deletions(-)
copy api/src/main/java/org/apache/iceberg/view/SQLViewRepresentation.java =>
kafka-connect/build.gradle (69%)
create mode 100644
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/AvroUtil.java
create mode 100644
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/CommitComplete.java
create mode 100644
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/CommitToTable.java
create mode 100644
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/DataComplete.java
create mode 100644
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/DataWritten.java
create mode 100644
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/Event.java
copy api/src/main/java/org/apache/iceberg/StructLike.java =>
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/Payload.java
(70%)
copy api/src/main/java/org/apache/iceberg/FileContent.java =>
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/PayloadType.java
(64%)
create mode 100644
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/StartCommit.java
create mode 100644
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/TableReference.java
create mode 100644
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/TopicPartitionOffset.java
create mode 100644
kafka-connect/kafka-connect-events/src/test/java/org/apache/iceberg/connect/events/EventSerializationTest.java
create mode 100644
kafka-connect/kafka-connect-events/src/test/java/org/apache/iceberg/connect/events/EventTestUtil.java
