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
omit f21125312 Merge branch 'master' into io_uring_final
omit 3d15e9177 fix(helm): use proper service for UI ingress (#2313)
omit 8ee56a971 feat(connectors/flink): add flink processor (#2300)
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/io_uring_final (6454be16a)
\
O -- O -- O (f21125312)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
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 +-
.../iggy/connector/flink/sink/IggyCommittable.java | 129 -------
.../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 -
helm/charts/iggy/templates/ingress.yaml | 4 +-
37 files changed, 3 insertions(+), 6026 deletions(-)
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/docker-compose.yml
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/docker/Dockerfile.flink2_10-java21
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/sink/IggyCommittable.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/sink/IggySink.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/sink/IggySinkBuilder.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/sink/IggySinkWriter.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggyPartitionSplitReader.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySource.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceBuilder.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceEnumeratorState.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceEnumeratorStateSerializer.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceReader.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceSplit.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceSplitEnumerator.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/flink/source/IggySourceSplitSerializer.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/serialization/JsonDeserializationSchema.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/serialization/JsonSerializationSchema.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/serialization/StringDeserializationSchema.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/build.gradle.kts
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/data-population-explanation.md
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/deploy-and-run-word-count-job.md
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/MultiStreamJoinJob.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/SendTestMessages.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/StreamTransformJob.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/WordCountJob.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/Alert.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/EnrichedActivity.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/SensorReading.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/UserActivity.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/UserProfile.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/main/java/org/apache/iggy/flink/example/model/WordCount.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/test/java/org/apache/iggy/flink/example/AsyncTcpMessagePollTest.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/test/java/org/apache/iggy/flink/example/AsyncTcpMessageSendTest.java
delete mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-flink-examples/src/test/java/org/apache/iggy/flink/example/SendTextDataTest.java
