public abstract class BaseBroadcastProcessFunction.Context extends Object
context
available to the broadcasted stream side of a BroadcastConnectedStream
.
Apart from the basic functionality of a context
, this also allows to
get and update the elements stored in the broadcast state
. In other
words, it gives read/write access to the broadcast state.
Constructor and Description |
---|
Context() |
Modifier and Type | Method and Description |
---|---|
abstract long |
currentProcessingTime()
Returns the current processing time.
|
abstract long |
currentWatermark()
Returns the current event-time watermark.
|
abstract <K,V> BroadcastState<K,V> |
getBroadcastState(MapStateDescriptor<K,V> stateDescriptor)
Fetches the
BroadcastState with the specified name. |
abstract <X> void |
output(OutputTag<X> outputTag,
X value)
Emits a record to the side output identified by the
OutputTag . |
abstract Long |
timestamp()
Timestamp of the element currently being processed or timestamp of a firing timer.
|
public abstract <K,V> BroadcastState<K,V> getBroadcastState(MapStateDescriptor<K,V> stateDescriptor)
BroadcastState
with the specified name.stateDescriptor
- the MapStateDescriptor
of the state to be fetched.broadcast state
.public abstract Long timestamp()
This might be null
, for example if the time characteristic of your program is
set to TimeCharacteristic.ProcessingTime
.
public abstract <X> void output(OutputTag<X> outputTag, X value)
OutputTag
.outputTag
- the OutputTag
that identifies the side output to emit to.value
- The record to emit.public abstract long currentProcessingTime()
public abstract long currentWatermark()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.