Class BaseBroadcastProcessFunction
- java.lang.Object
-
- org.apache.flink.api.common.functions.AbstractRichFunction
-
- org.apache.flink.streaming.api.functions.co.BaseBroadcastProcessFunction
-
- All Implemented Interfaces:
Serializable
,Function
,RichFunction
- Direct Known Subclasses:
BroadcastProcessFunction
,KeyedBroadcastProcessFunction
@PublicEvolving public abstract class BaseBroadcastProcessFunction extends AbstractRichFunction
The base class containing the functionality available to all broadcast process function. These include theBroadcastProcessFunction
and theKeyedBroadcastProcessFunction
.- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
BaseBroadcastProcessFunction.Context
A basecontext
available to the broadcasted stream side of aBroadcastConnectedStream
.class
BaseBroadcastProcessFunction.ReadOnlyContext
Acontext
available to the non-broadcasted stream side of aBroadcastConnectedStream
.
-
Constructor Summary
Constructors Constructor Description BaseBroadcastProcessFunction()
-
Method Summary
-
Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
-
-