This is an automated email from the ASF dual-hosted git repository.
juri pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/wayang.git
from 6172a5f46 Merge pull request #675 from mspruc/cast-for-filters
add 2aebabd1e Source, map & collection sink
add 00dc3a268 licenses
add 25305e32a license
add 08b3ea0a5 add configuration options for flink platform bounded
datastreams
add 0e3cfa55f data stream join operators for flink platform & code quality
add 24bb94b32 mappings & collection sink operator
add 65147cfa1 remove continuous sources, for a separate PR
new 745fc5cb9 Merge pull request #661 from mspruc/flink-datastream
The 1 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:
wayang-platforms/wayang-flink/pom.xml | 10 ++
...{DataSetChannel.java => DataStreamChannel.java} | 101 +++++------
.../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 +-
.../{JoinMapping.java => StreamedJoinMapping.java} | 24 ++-
.../mapping/StreamedLocalCallbackSinkMapping.java} | 32 ++--
.../{MapMapping.java => StreamedMapMapping.java} | 24 ++-
.../flink/mapping/TextFileSourceMapping.java | 3 +-
...Source.java => FlinkBoundedTextFileSource.java} | 96 +++++-----
...ink.java => FlinkDataStreamCollectionSink.java} | 70 ++++----
.../operators/FlinkDataStreamJoinOperator.java | 146 +++++++++++++++
.../FlinkDataStreamLocalCallbackSink.java} | 76 ++++----
.../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 | 11 +-
21 files changed, 823 insertions(+), 398 deletions(-)
copy
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/channels/{DataSetChannel.java
=> DataStreamChannel.java} (62%)
copy
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/{TextFileSourceMapping.java
=> BoundedTextFileSourceMapping.java} (83%)
copy
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/{JoinMapping.java
=> StreamedJoinMapping.java} (80%)
copy
wayang-platforms/{wayang-java/src/main/java/org/apache/wayang/java/mapping/LocalCallbackSinkMapping.java
=>
wayang-flink/src/main/java/org/apache/wayang/flink/mapping/StreamedLocalCallbackSinkMapping.java}
(76%)
copy
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/{MapMapping.java
=> StreamedMapMapping.java} (81%)
copy
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/{FlinkTextFileSource.java
=> FlinkBoundedTextFileSource.java} (50%)
copy
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/{FlinkCollectionSink.java
=> FlinkDataStreamCollectionSink.java} (63%)
create mode 100644
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDataStreamJoinOperator.java
copy
wayang-platforms/{wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkLocalCallbackSink.java
=>
wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDataStreamLocalCallbackSink.java}
(60%)
create mode 100644
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDataStreamMapOperator.java
create mode 100644
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkDataStreamTests.java
copy
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java
=>
wayang-platforms/wayang-flink/src/test/resources/org/apache/wayang/flink/operators/dataStreamTest.txt
(88%)
