public abstract class ProcessJoinFunction.Context extends Object
ProcessJoinFunction.processElement(Object, Object, Context, Collector)
. It gives access to the timestamps of the
left element in the joined pair, the right one, and that of the joined pair. In addition, this context
allows to emit elements on a side output.Constructor and Description |
---|
Context() |
Modifier and Type | Method and Description |
---|---|
abstract long |
getLeftTimestamp() |
abstract long |
getRightTimestamp() |
abstract long |
getTimestamp() |
abstract <X> void |
output(OutputTag<X> outputTag,
X value)
Emits a record to the side output identified by the
OutputTag . |
public abstract long getLeftTimestamp()
public abstract long getRightTimestamp()
public abstract long getTimestamp()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.