Interface BucketAssigner.Context
-
- Enclosing interface:
- BucketAssigner<IN,BucketID>
@PublicEvolving public static interface BucketAssigner.Context
Context that theBucketAssigner
can use for getting additional data about an input record.The context is only valid for the duration of a
BucketAssigner.getBucketId(Object, BucketAssigner.Context)
call. Do not store the context and use afterwards!
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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 ornull
if the element does not have an assigned timestamp.
-
-
-
Method Detail
-
currentProcessingTime
long currentProcessingTime()
Returns the current processing time.
-
currentWatermark
long currentWatermark()
Returns the current event-time watermark.
-
timestamp
@Nullable Long timestamp()
Returns the timestamp of the current input record ornull
if the element does not have an assigned timestamp.
-
-