org.apache.flink.streaming.api.functions.sink.filesystem

Interface BucketAssigner.Context

Enclosing interface:

BucketAssigner<IN,BucketID>

@PublicEvolving
public static interface BucketAssigner.Context

Context that the 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!

Method Summary

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.

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 or null if the element does not have an assigned timestamp.