Uses of Interface
org.apache.flink.table.runtime.operators.window.tvf.slicing.SliceUnsharedAssigner
-
Packages that use SliceUnsharedAssigner Package Description org.apache.flink.table.runtime.operators.aggregate.window.processors org.apache.flink.table.runtime.operators.window.tvf.slicing -
-
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 SliceUnsharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, WindowBuffer.Factory windowBufferFactory, SliceUnsharedAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, int indexOfCountStar, java.time.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.static classSliceAssigners.TumblingSliceAssignerTheSliceAssignerfor tumbling windows.static classSliceAssigners.WindowedSliceAssignerTheSliceAssignerfor elements have been attached window start and end timestamps.
-