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 |
---|---|
<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 |
---|
BatchCoBroadcastWithNonKeyedOperator(BroadcastProcessFunction<IN1,IN2,OUT> function,
List<MapStateDescriptor<?,?>> broadcastStateDescriptors) |
CoBroadcastWithNonKeyedOperator(BroadcastProcessFunction<IN1,IN2,OUT> function,
List<MapStateDescriptor<?,?>> broadcastStateDescriptors) |
Modifier and Type | Method and Description |
---|---|
BroadcastProcessFunction<IN1,IN2,OUT> |
BroadcastStateTransformation.getUserFunction() |
Constructor and Description |
---|
BroadcastStateTransformation(String name,
Transformation<IN1> inputStream,
Transformation<IN2> broadcastStream,
BroadcastProcessFunction<IN1,IN2,OUT> userFunction,
List<MapStateDescriptor<?,?>> broadcastStateDescriptors,
TypeInformation<OUT> outTypeInfo,
int parallelism) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.