Class SessionWindowSpec
- java.lang.Object
-
- org.apache.flink.table.planner.plan.logical.SessionWindowSpec
-
- All Implemented Interfaces:
WindowSpec
public class SessionWindowSpec extends Object implements WindowSpec
Logical representation of a session window specification.
-
-
Field Summary
Fields Modifier and Type Field Description static String
FIELD_NAME_GAP
static String
FIELD_NAME_PARTITION_KEYS
-
Constructor Summary
Constructors Constructor Description SessionWindowSpec(Duration gap, int[] partitionKeyIndices)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
Duration
getGap()
int[]
getPartitionKeyIndices()
int
hashCode()
boolean
isAlignedWindow()
Return true if the window is aligned.String
toString()
String
toSummaryString(String windowing, String[] inputFieldNames)
-
-
-
Field Detail
-
FIELD_NAME_GAP
public static final String FIELD_NAME_GAP
- See Also:
- Constant Field Values
-
FIELD_NAME_PARTITION_KEYS
public static final String FIELD_NAME_PARTITION_KEYS
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
SessionWindowSpec
public SessionWindowSpec(Duration gap, int[] partitionKeyIndices)
-
-
Method Detail
-
toSummaryString
public String toSummaryString(String windowing, String[] inputFieldNames)
- Specified by:
toSummaryString
in interfaceWindowSpec
-
getGap
public Duration getGap()
-
getPartitionKeyIndices
public int[] getPartitionKeyIndices()
-
isAlignedWindow
public boolean isAlignedWindow()
Description copied from interface:WindowSpec
Return true if the window is aligned.See more details about aligned window and unaligned window in
WindowAggOperator
.- Specified by:
isAlignedWindow
in interfaceWindowSpec
-
-