@Public public static interface SinkWriter.Context
SinkWriter.write(InputT, org.apache.flink.api.connector.sink2.SinkWriter.Context)
can use for getting additional data about an input record.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. |
long currentWatermark()
Long timestamp()
null
if the element does not
have an assigned timestamp.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.