public static interface SinkWriter.Context
SinkWriter.write(InputT, org.apache.flink.api.connector.sink.SinkWriter.Context)can use for getting additional data about an input record.
|Modifier and Type||Method and Description|
Returns the current event-time watermark.
Returns the timestamp of the current input record or
nullif the element does not have an assigned timestamp.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.