This is an automated email from the ASF dual-hosted git repository. juri pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/wayang.git
commit 745fc5cb9a765796533ca673c8d331fef15b2e63 Merge: 6172a5f46 65147cfa1 Author: Juri Petersen <[email protected]> AuthorDate: Sun Feb 8 10:59:12 2026 +0100 Merge pull request #661 from mspruc/flink-datastream Source, map, collection, sink for bounded data streams in Flink wayang-platforms/wayang-flink/pom.xml | 10 ++ .../wayang/flink/channels/DataStreamChannel.java | 103 +++++++++++ .../wayang/flink/compiler/FunctionCompiler.java | 31 ++-- .../wayang/flink/execution/FlinkExecutor.java | 9 +- ...ping.java => BoundedTextFileSourceMapping.java} | 21 +-- .../org/apache/wayang/flink/mapping/Mappings.java | 15 +- ...SourceMapping.java => StreamedJoinMapping.java} | 30 ++-- ....java => StreamedLocalCallbackSinkMapping.java} | 33 ++-- ...eSourceMapping.java => StreamedMapMapping.java} | 30 ++-- .../flink/mapping/TextFileSourceMapping.java | 3 +- .../operators/FlinkBoundedTextFileSource.java | 102 +++++++++++ .../operators/FlinkDataStreamCollectionSink.java | 112 ++++++++++++ .../operators/FlinkDataStreamJoinOperator.java | 146 +++++++++++++++ .../FlinkDataStreamLocalCallbackSink.java | 102 +++++++++++ .../operators/FlinkDataStreamMapOperator.java | 81 +++++++++ .../wayang/flink/platform/FlinkPlatform.java | 133 +++++++------- .../wayang/flink/plugin/FlinkBasicPlugin.java | 9 +- .../flink/operators/FlinkDataStreamTests.java | 197 +++++++++++++++++++++ .../flink/operators/FlinkOperatorTestBase.java | 74 ++++---- .../apache/wayang/flink/test/ChannelFactory.java | 58 +++--- .../wayang/flink/operators/dataStreamTest.txt | 19 ++ 21 files changed, 1107 insertions(+), 211 deletions(-)
