Uses of Interface
org.apache.flink.table.runtime.operators.window.tvf.slicing.SliceSharedAssigner
-
-
Uses of SliceSharedAssigner 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 SliceSharedAssigner Constructor Description AsyncStateSliceSharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, AsyncStateWindowBuffer.Factory bufferFactory, SliceSharedAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, int indexOfCountStar, ZoneId shiftTimeZone) -
Uses of SliceSharedAssigner 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 SliceSharedAssigner Constructor Description SliceSharedSyncStateWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, WindowBuffer.Factory bufferFactory, SliceSharedAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, int indexOfCountStar, ZoneId shiftTimeZone) -
Uses of SliceSharedAssigner in org.apache.flink.table.runtime.operators.window.tvf.slicing
Classes in org.apache.flink.table.runtime.operators.window.tvf.slicing that implement SliceSharedAssigner Modifier and Type Class Description static classSliceAssigners.CumulativeSliceAssignerTheSliceAssignerfor cumulative windows.static classSliceAssigners.HoppingSliceAssignerTheSliceAssignerfor hopping windows.static classSliceAssigners.SlicedSharedSliceAssignerTheSliceAssignerfor elements have been attached slice end timestamp, and the slices are shared.Constructors in org.apache.flink.table.runtime.operators.window.tvf.slicing with parameters of type SliceSharedAssigner Constructor Description SlicedSharedSliceAssigner(int sliceEndIndex, SliceSharedAssigner innerAssigner)
-