This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from fd23b35 [FLINK-20383][runtime] Fix race condition in notification.
add 06acce0 [fix] Rename method in BroadcastStream
add 4bede4b [fix] Field renaming in BroadcastConnectedStream
add ed82aab [FLINK-20304] Introduce the BroadcastStateTransformation.
add f7fad2c [FLINK-20304] Create base
AbstractTwoInputTransformationTranslator.
No new revisions were added by this update.
Summary of changes:
.../api/datastream/BroadcastConnectedStream.java | 75 ++++++----
.../streaming/api/datastream/BroadcastStream.java | 2 +-
.../flink/streaming/api/datastream/DataStream.java | 2 +-
.../streaming/api/graph/StreamGraphGenerator.java | 3 +
.../BroadcastStateTransformation.java | 164 +++++++++++++++++++++
.../AbstractOneInputTransformationTranslator.java | 1 +
... AbstractTwoInputTransformationTranslator.java} | 72 +++++----
...=> BroadcastStateTransformationTranslator.java} | 42 +++---
.../TwoInputTransformationTranslator.java | 53 ++-----
.../streaming/runtime/BroadcastStateITCase.java | 45 ++++++
10 files changed, 329 insertions(+), 130 deletions(-)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/BroadcastStateTransformation.java
copy
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/{AbstractOneInputTransformationTranslator.java
=> AbstractTwoInputTransformationTranslator.java} (56%)
copy
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/{UnionTransformationTranslator.java
=> BroadcastStateTransformationTranslator.java} (55%)
