public abstract class StreamExecWindowAggregateBase extends StreamExecAggregateBase
ExecNode
.Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_NAMED_WINDOW_PROPERTIES |
static String |
FIELD_NAME_WINDOWING |
static long |
WINDOW_AGG_MEMORY_RATIO |
FIELD_NAME_AGG_CALL_NEED_RETRACTIONS, FIELD_NAME_AGG_CALLS, FIELD_NAME_GENERATE_UPDATE_BEFORE, FIELD_NAME_GROUPING, FIELD_NAME_NEED_RETRACTION
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Modifier | Constructor and Description |
---|---|
protected |
StreamExecWindowAggregateBase(int id,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
protected LogicalType[] |
convertToLogicalTypes(DataType[] dataTypes) |
protected SliceAssigner |
createSliceAssigner(WindowingStrategy windowingStrategy,
java.time.ZoneId shiftTimeZone) |
protected SliceAssigner |
createSliceAssigner(WindowSpec windowSpec,
int timeAttributeIndex,
java.time.ZoneId shiftTimeZone) |
accept, getDescription, getId, getInputEdges, getInputProperties, getNewNodeId, getOutputType, inputsContainSingleton, replaceInputEdge, resetIdCounter, setInputEdges, translateToPlan, translateToPlanInternal
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setInputEdges
translateToPlan
public static final long WINDOW_AGG_MEMORY_RATIO
public static final String FIELD_NAME_WINDOWING
public static final String FIELD_NAME_NAMED_WINDOW_PROPERTIES
protected StreamExecWindowAggregateBase(int id, List<InputProperty> inputProperties, LogicalType outputType, String description)
protected SliceAssigner createSliceAssigner(WindowingStrategy windowingStrategy, java.time.ZoneId shiftTimeZone)
protected SliceAssigner createSliceAssigner(WindowSpec windowSpec, int timeAttributeIndex, java.time.ZoneId shiftTimeZone)
protected LogicalType[] convertToLogicalTypes(DataType[] dataTypes)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.