public abstract class KeyedCoProcessFunction.Context extends Object
KeyedCoProcessFunction.processElement1(Object, Context,
Collector)
/ KeyedCoProcessFunction.processElement2(Object, Context, Collector)
or KeyedCoProcessFunction.onTimer(long,
OnTimerContext, Collector)
.Constructor and Description |
---|
Context() |
Modifier and Type | Method and Description |
---|---|
abstract K |
getCurrentKey()
Get key of the element being processed.
|
abstract <X> void |
output(OutputTag<X> outputTag,
X value)
Emits a record to the side output identified by the
OutputTag . |
abstract TimerService |
timerService()
A
TimerService for querying time and registering timers. |
abstract Long |
timestamp()
Timestamp of the element currently being processed or timestamp of a firing timer.
|
public abstract Long timestamp()
This might be null
, for example if the time characteristic of your program is
set to TimeCharacteristic.ProcessingTime
.
public abstract TimerService timerService()
TimerService
for querying time and registering timers.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 K getCurrentKey()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.