Uses of Interface
org.apache.flink.table.runtime.operators.window.tvf.unslicing.UnsliceAssigner
-
Packages that use UnsliceAssigner Package Description org.apache.flink.table.runtime.operators.aggregate.window.processors org.apache.flink.table.runtime.operators.window.tvf.unslicing -
-
Uses of UnsliceAssigner 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 UnsliceAssigner Constructor Description UnsliceWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<TimeWindow> genAggsHandler, UnsliceAssigner<TimeWindow> unsliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, int indexOfCountStar, java.time.ZoneId shiftTimeZone) -
Uses of UnsliceAssigner in org.apache.flink.table.runtime.operators.window.tvf.unslicing
Classes in org.apache.flink.table.runtime.operators.window.tvf.unslicing that implement UnsliceAssigner Modifier and Type Class Description static classUnsliceAssigners.SessionUnsliceAssignerTheUnsliceAssignerfor session windows.static classUnsliceAssigners.WindowedUnsliceAssignerTheUnsliceAssignerfor elements have been merged into unslicing windows and attached window start and end timestamps.Methods in org.apache.flink.table.runtime.operators.window.tvf.unslicing with parameters of type UnsliceAssigner Modifier and Type Method Description static UnsliceAssigners.WindowedUnsliceAssignerUnsliceAssigners. windowed(int windowStartIndex, int windowEndIndex, UnsliceAssigner<TimeWindow> innerAssigner)Creates aUnsliceAssignerthat assigns elements which has been attached window start and window end timestamp to windows.Constructors in org.apache.flink.table.runtime.operators.window.tvf.unslicing with parameters of type UnsliceAssigner Constructor Description WindowedUnsliceAssigner(int windowStartIndex, int windowEndIndex, UnsliceAssigner<TimeWindow> innerAssigner)
-