Interface WindowAssigner
-
- All Superinterfaces:
Serializable
- All Known Subinterfaces:
SliceAssigner,SliceSharedAssigner,SliceUnsharedAssigner,UnsliceAssigner<W>
- All Known Implementing Classes:
SliceAssigners.CumulativeSliceAssigner,SliceAssigners.HoppingSliceAssigner,SliceAssigners.SlicedSharedSliceAssigner,SliceAssigners.SlicedUnsharedSliceAssigner,SliceAssigners.TumblingSliceAssigner,SliceAssigners.WindowedSliceAssigner,UnsliceAssigners.SessionUnsliceAssigner,UnsliceAssigners.WindowedUnsliceAssigner
@Internal public interface WindowAssigner extends Serializable
WindowAssigner is used to assign windows to elements.The differences between
WindowAssignerandGroupWindowAssigneris that, this window assigner is translated from the new window TVF syntax, but the other is from the legacy GROUP WINDOW FUNCTION syntax. In the long future,GroupWindowAssignerwill be dropped.See more details in
WindowAggOperator.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StringgetDescription()Returns a description of this window assigner.booleanisEventTime()Returnstrueif elements are assigned to windows based on event time,falsebased on processing time.
-
-
-
Method Detail
-
isEventTime
boolean isEventTime()
Returnstrueif elements are assigned to windows based on event time,falsebased on processing time.
-
getDescription
String getDescription()
Returns a description of this window assigner.
-
-