Package | Description |
---|---|
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.operators.co | |
org.apache.flink.streaming.api.transformations |
Modifier and Type | Method and Description |
---|---|
<KEY,OUT> SingleOutputStreamOperator<OUT> |
BroadcastConnectedStream.process(KeyedBroadcastProcessFunction<KEY,IN1,IN2,OUT> function)
Assumes as inputs a
BroadcastStream and a KeyedStream and applies the given
KeyedBroadcastProcessFunction on them, thereby creating a transformed output stream. |
<KEY,OUT> SingleOutputStreamOperator<OUT> |
BroadcastConnectedStream.process(KeyedBroadcastProcessFunction<KEY,IN1,IN2,OUT> function,
TypeInformation<OUT> outTypeInfo)
Assumes as inputs a
BroadcastStream and a KeyedStream and applies the given
KeyedBroadcastProcessFunction on them, thereby creating a transformed output stream. |
Constructor and Description |
---|
BatchCoBroadcastWithKeyedOperator(KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT> function,
List<MapStateDescriptor<?,?>> broadcastStateDescriptors) |
CoBroadcastWithKeyedOperator(KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT> function,
List<MapStateDescriptor<?,?>> broadcastStateDescriptors) |
Modifier and Type | Method and Description |
---|---|
KeyedBroadcastProcessFunction<KEY,IN1,IN2,OUT> |
KeyedBroadcastStateTransformation.getUserFunction() |
Constructor and Description |
---|
KeyedBroadcastStateTransformation(String name,
Transformation<IN1> inputStream,
Transformation<IN2> broadcastStream,
KeyedBroadcastProcessFunction<KEY,IN1,IN2,OUT> userFunction,
List<MapStateDescriptor<?,?>> broadcastStateDescriptors,
TypeInformation<KEY> keyType,
KeySelector<IN1,KEY> keySelector,
TypeInformation<OUT> outTypeInfo,
int parallelism) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.