@PublicEvolving public abstract class BaseBroadcastProcessFunction extends AbstractRichFunction
BroadcastProcessFunction
and the KeyedBroadcastProcessFunction
.Modifier and Type | Class and Description |
---|---|
class |
BaseBroadcastProcessFunction.Context
A base
context available to the broadcasted stream side of
a BroadcastConnectedStream . |
class |
BaseBroadcastProcessFunction.ReadOnlyContext
A
context available to the non-broadcasted stream side of
a BroadcastConnectedStream . |
Constructor and Description |
---|
BaseBroadcastProcessFunction() |
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.