org.apache.flink.streaming.api.functions.sink

Interface SinkFunction.Context<T>

Type Parameters:

T - The type of elements accepted by the sink.

Enclosing interface:

SinkFunction<IN>

@Public
public static interface SinkFunction.Context<T>

Context that SinkFunctions can use for getting additional data about an input record.

The context is only valid for the duration of a SinkFunction.invoke(Object, Context) call. Do not store the context and use afterwards!

Method Summary

Modifier and Type	Method and Description
long	currentProcessingTime() Returns the current processing time.
long	currentWatermark() Returns the current event-time watermark.
Long	timestamp() Returns the timestamp of the current input record or null if the element does not have an assigned timestamp.

Method Detail

currentProcessingTime

long currentProcessingTime()

Returns the current processing time.

currentWatermark

long currentWatermark()

Returns the current event-time watermark.

timestamp

Long timestamp()

Returns the timestamp of the current input record or null if the element does not have an assigned timestamp.