Class BroadcastProcessFunction.ReadOnlyContext
- java.lang.Object
-
- org.apache.flink.streaming.api.functions.co.BaseBroadcastProcessFunction.ReadOnlyContext
-
- org.apache.flink.streaming.api.functions.co.BroadcastProcessFunction.ReadOnlyContext
-
- Enclosing class:
- BroadcastProcessFunction<IN1,IN2,OUT>
public abstract class BroadcastProcessFunction.ReadOnlyContext extends BaseBroadcastProcessFunction.ReadOnlyContext
Acontext
available to the non-keyed side of aBroadcastConnectedStream
(if any).
-
-
Constructor Summary
Constructors Constructor Description ReadOnlyContext()
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description abstract long
currentProcessingTime()
Returns the current processing time.abstract long
currentWatermark()
Returns the current event-time watermark.abstract <X> void
output(OutputTag<X> outputTag, X value)
Emits a record to the side output identified by theOutputTag
.abstract Long
timestamp()
Timestamp of the element currently being processed or timestamp of a firing timer.-
Methods inherited from class org.apache.flink.streaming.api.functions.co.BaseBroadcastProcessFunction.ReadOnlyContext
getBroadcastState
-
-
-
-
Method Detail
-
timestamp
public abstract Long timestamp()
Timestamp of the element currently being processed or timestamp of a firing timer.This might be
null
, depending on the stream's watermark strategy.
-
output
public abstract <X> void output(OutputTag<X> outputTag, X value)
Emits a record to the side output identified by theOutputTag
.- Parameters:
outputTag
- theOutputTag
that identifies the side output to emit to.value
- The record to emit.
-
currentProcessingTime
public abstract long currentProcessingTime()
Returns the current processing time.
-
currentWatermark
public abstract long currentWatermark()
Returns the current event-time watermark.
-
-