Uses of Interface
org.apache.flink.table.runtime.operators.window.tvf.slicing.SliceUnsharedAssigner
-
-
Uses of SliceUnsharedAssigner in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors
Constructors in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors with parameters of type SliceUnsharedAssigner Constructor Description AsyncStateSliceUnsharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, AsyncStateWindowBuffer.Factory windowBufferFactory, SliceUnsharedAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, int indexOfCountStar, ZoneId shiftTimeZone) -
Uses of SliceUnsharedAssigner in org.apache.flink.table.runtime.operators.aggregate.window.processors
Constructors in org.apache.flink.table.runtime.operators.aggregate.window.processors with parameters of type SliceUnsharedAssigner Constructor Description SliceUnsharedSyncStateWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, WindowBuffer.Factory windowBufferFactory, SliceUnsharedAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, int indexOfCountStar, ZoneId shiftTimeZone) -
Uses of SliceUnsharedAssigner in org.apache.flink.table.runtime.operators.window.tvf.slicing
Classes in org.apache.flink.table.runtime.operators.window.tvf.slicing that implement SliceUnsharedAssigner Modifier and Type Class Description static classSliceAssigners.SlicedUnsharedSliceAssignerTheSliceAssignerfor elements have been attached slice end timestamp, but the slices are not shared, i.e. the assigned slice is equal to the final window.static classSliceAssigners.TumblingSliceAssignerTheSliceAssignerfor tumbling windows.static classSliceAssigners.WindowedSliceAssignerTheSliceAssignerfor elements have been attached window start and end timestamps.
-