Interface SinkWriter.Context
-
- Enclosing interface:
- SinkWriter<InputT>
@PublicEvolving public static interface SinkWriter.ContextContext thatSinkWriter.write(InputT, org.apache.flink.api.connector.sink2.SinkWriter.Context)can use for getting additional data about an input record.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description longcurrentWatermark()Returns the current event-time watermark.Longtimestamp()Returns the timestamp of the current input record ornullif 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 ornullif the element does not have an assigned timestamp.
-
-