@Public public static interface SinkFunction.Context
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!
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. |
long currentProcessingTime()
long currentWatermark()
Long timestamp()
null
if the element does not
have an assigned timestamp.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.