@PublicEvolving public static interface BucketAssigner.Context
BucketAssigner
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!
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. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.