org.apache.flink.table.runtime.operators.window.slicing

Class SliceAssigners

java.lang.Object

org.apache.flink.table.runtime.operators.window.slicing.SliceAssigners

@Internal
public final class SliceAssigners
extends Object

Utilities to create SliceAssigners.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SliceAssigners.CumulativeSliceAssigner The SliceAssigner for cumulative windows.
static class	SliceAssigners.HoppingSliceAssigner The SliceAssigner for hopping windows.
static class	SliceAssigners.SlicedSharedSliceAssigner The SliceAssigner for elements have been attached slice end timestamp, and the slices are shared.
static class	SliceAssigners.SlicedUnsharedSliceAssigner The SliceAssigner for elements have been attached slice end timestamp, but the slices are not shared, i.e.
static class	SliceAssigners.TumblingSliceAssigner The SliceAssigner for tumbling windows.
static class	SliceAssigners.WindowedSliceAssigner The SliceAssigner for elements have been attached window start and end timestamps.

Method Summary

Modifier and Type	Method and Description
static SliceAssigners.CumulativeSliceAssigner	cumulative(int rowtimeIndex, java.time.ZoneId shiftTimeZone, java.time.Duration maxSize, java.time.Duration step) Creates a cumulative window SliceAssigner that assigns elements to slices of cumulative windows.
static SliceAssigners.HoppingSliceAssigner	hopping(int rowtimeIndex, java.time.ZoneId shiftTimeZone, java.time.Duration size, java.time.Duration slide) Creates a hopping window SliceAssigner that assigns elements to slices of hopping windows.
static SliceAssigner	sliced(int sliceEndIndex, SliceAssigner innerAssigner) Creates a SliceAssigner that assigns elements which has been attached slice end timestamp.
static SliceAssigners.TumblingSliceAssigner	tumbling(int rowtimeIndex, java.time.ZoneId shiftTimeZone, java.time.Duration size) Creates a tumbling window SliceAssigner that assigns elements to slices of tumbling windows.
static SliceAssigners.WindowedSliceAssigner	windowed(int windowEndIndex, SliceAssigner innerAssigner) Creates a SliceAssigner that assigns elements which has been attached window start and window end timestamp to slices.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

tumbling

public static SliceAssigners.TumblingSliceAssigner tumbling(int rowtimeIndex,
                                                            java.time.ZoneId shiftTimeZone,
                                                            java.time.Duration size)

Creates a tumbling window SliceAssigner that assigns elements to slices of tumbling windows.

Parameters:

rowtimeIndex - the index of rowtime field in the input row, -1 if based on processing time.

shiftTimeZone - The shift timezone of the window, if the proctime or rowtime type is TIMESTAMP_LTZ, the shift timezone is the timezone user configured in TableConfig, other cases the timezone is UTC which means never shift when assigning windows.

size - the size of the generated windows.

hopping

public static SliceAssigners.HoppingSliceAssigner hopping(int rowtimeIndex,
                                                          java.time.ZoneId shiftTimeZone,
                                                          java.time.Duration size,
                                                          java.time.Duration slide)

Creates a hopping window SliceAssigner that assigns elements to slices of hopping windows.

Parameters:

rowtimeIndex - the index of rowtime field in the input row, -1 if based on * processing time.

shiftTimeZone - The shift timezone of the window, if the proctime or rowtime type is TIMESTAMP_LTZ, the shift timezone is the timezone user configured in TableConfig, other cases the timezone is UTC which means never shift when assigning windows.

slide - the slide interval of the generated windows.

cumulative

public static SliceAssigners.CumulativeSliceAssigner cumulative(int rowtimeIndex,
                                                                java.time.ZoneId shiftTimeZone,
                                                                java.time.Duration maxSize,
                                                                java.time.Duration step)

Creates a cumulative window SliceAssigner that assigns elements to slices of cumulative windows.

Parameters:

rowtimeIndex - the index of rowtime field in the input row, -1 if based on * processing time.

shiftTimeZone - The shift timezone of the window, if the proctime or rowtime type is TIMESTAMP_LTZ, the shift timezone is the timezone user configured in TableConfig, other cases the timezone is UTC which means never shift when assigning windows.

step - the step interval of the generated windows.

windowed

public static SliceAssigners.WindowedSliceAssigner windowed(int windowEndIndex,
                                                            SliceAssigner innerAssigner)

Creates a SliceAssigner that assigns elements which has been attached window start and window end timestamp to slices. The assigned slice is equal to the given window.

Parameters:

windowEndIndex - the index of window end field in the input row, mustn't be a negative value.

innerAssigner - the inner assigner which assigns the attached windows

sliced

public static SliceAssigner sliced(int sliceEndIndex,
                                   SliceAssigner innerAssigner)

Creates a SliceAssigner that assigns elements which has been attached slice end timestamp.

Parameters:

sliceEndIndex - the index of slice end field in the input row, mustn't be a negative value.

innerAssigner - the inner assigner which assigns the attached windows