Interface BucketAssigner.Context
-
- Enclosing interface:
- BucketAssigner<IN,BucketID>
@PublicEvolving public static interface BucketAssigner.ContextContext that theBucketAssignercan 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 longcurrentProcessingTime()Returns the current processing time.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.
-