Package | Description |
---|---|
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.operators.co |
Modifier and Type | Method and Description |
---|---|
<OUT> SingleOutputStreamOperator<OUT> |
BroadcastConnectedStream.process(BroadcastProcessFunction<IN1,IN2,OUT> function)
Assumes as inputs a
BroadcastStream and a non-keyed DataStream and applies the given
BroadcastProcessFunction on them, thereby creating a transformed output stream. |
<OUT> SingleOutputStreamOperator<OUT> |
BroadcastConnectedStream.process(BroadcastProcessFunction<IN1,IN2,OUT> function,
TypeInformation<OUT> outTypeInfo)
Assumes as inputs a
BroadcastStream and a non-keyed DataStream and applies the given
BroadcastProcessFunction on them, thereby creating a transformed output stream. |
Constructor and Description |
---|
CoBroadcastWithNonKeyedOperator(BroadcastProcessFunction<IN1,IN2,OUT> function,
List<MapStateDescriptor<?,?>> broadcastStateDescriptors) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.