org.apache.flink.api.connector.sink2

Interface SinkWriter.Context

Enclosing interface:

SinkWriter<InputT>

@PublicEvolving
public static interface SinkWriter.Context

Context that SinkWriter.write(InputT, org.apache.flink.api.connector.sink2.SinkWriter.Context) can use for getting additional data about an input record.

Method Summary

Modifier and Type	Method and Description
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

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.