This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch io_uring_final
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 7d6ef1591 leave cg by disconnected client
add 8ee56a971 feat(connectors/flink): add flink processor (#2300)
add b8cbb78a8 Merge branch 'master' into io_uring_final
No new revisions were added by this update.
Summary of changes:
.../iggy-connector-flink/docker-compose.yml | 273 ++++++++++++++
.../docker/Dockerfile.flink2_10-java21 | 11 +
.../iggy-connector-library/build.gradle.kts | 7 +-
.../sink/IggyCommittable.java} | 92 ++---
.../apache/iggy/connector/flink/sink/IggySink.java | 223 +++++++++++
.../iggy/connector/flink/sink/IggySinkBuilder.java | 220 +++++++++++
.../iggy/connector/flink/sink/IggySinkWriter.java | 303 +++++++++++++++
.../flink/source/IggyPartitionSplitReader.java | 257 +++++++++++++
.../iggy/connector/flink/source/IggySource.java | 271 ++++++++++++++
.../connector/flink/source/IggySourceBuilder.java | 191 ++++++++++
.../flink/source/IggySourceEnumeratorState.java | 91 +++++
.../IggySourceEnumeratorStateSerializer.java | 100 +++++
.../connector/flink/source/IggySourceReader.java | 192 ++++++++++
.../connector/flink/source/IggySourceSplit.java | 163 ++++++++
.../flink/source/IggySourceSplitEnumerator.java | 279 ++++++++++++++
.../flink/source/IggySourceSplitSerializer.java | 101 +++++
.../serialization/JsonDeserializationSchema.java | 133 +++++++
.../serialization/JsonSerializationSchema.java | 169 +++++++++
.../serialization/StringDeserializationSchema.java | 87 +++++
.../iggy-flink-examples/build.gradle.kts | 108 ++++++
.../data-population-explanation.md | 279 ++++++++++++++
.../deploy-and-run-word-count-job.md | 258 +++++++++++++
.../iggy/flink/example/MultiStreamJoinJob.java | 242 ++++++++++++
.../iggy/flink/example/SendTestMessages.java | 73 ++++
.../iggy/flink/example/StreamTransformJob.java | 222 +++++++++++
.../apache/iggy/flink/example/WordCountJob.java | 166 +++++++++
.../org/apache/iggy/flink/example/model/Alert.java | 107 ++++++
.../iggy/flink/example/model/EnrichedActivity.java | 137 +++++++
.../iggy/flink/example/model/SensorReading.java | 98 +++++
.../iggy/flink/example/model/UserActivity.java | 98 +++++
.../iggy/flink/example/model/UserProfile.java | 97 +++++
.../apache/iggy/flink/example/model/WordCount.java | 75 ++++
.../flink/example/AsyncTcpMessagePollTest.java | 414 +++++++++++++++++++++
.../flink/example/AsyncTcpMessageSendTest.java | 308 +++++++++++++++
.../iggy/flink/example/SendTextDataTest.java | 139 +++++++
foreign/java/java-sdk/build.gradle.kts | 4 +
36 files changed, 5944 insertions(+), 44 deletions(-)
create mode 100644
foreign/java/external-processors/iggy-connector-flink/docker-compose.yml
create mode 100644
foreign/java/external-processors/iggy-connector-flink/docker/Dockerfile.flink2_10-java21
copy
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/{partition/PartitionInfo.java
=> flink/sink/IggyCommittable.java} (50%)
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/sink/IggySink.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/sink/IggySinkBuilder.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/sink/IggySinkWriter.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggyPartitionSplitReader.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySource.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceBuilder.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceEnumeratorState.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceEnumeratorStateSerializer.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceReader.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceSplit.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceSplitEnumerator.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceSplitSerializer.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/serialization/JsonDeserializationSchema.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/serialization/JsonSerializationSchema.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/serialization/StringDeserializationSchema.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/build.gradle.kts
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/data-population-explanation.md
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/deploy-and-run-word-count-job.md
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/MultiStreamJoinJob.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/SendTestMessages.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/StreamTransformJob.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/WordCountJob.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/Alert.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/EnrichedActivity.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/SensorReading.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/UserActivity.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/UserProfile.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/WordCount.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/test/java/org/apache/iggy/flink/example/AsyncTcpMessagePollTest.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/test/java/org/apache/iggy/flink/example/AsyncTcpMessageSendTest.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/test/java/org/apache/iggy/flink/example/SendTextDataTest.java
