org.apache.flink.table.planner.plan.nodes.exec.stream

Class StreamExecWindowAggregateBase

java.lang.Object

org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase<RowData>

org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecAggregateBase

org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecWindowAggregateBase

All Implemented Interfaces:

ExecNode<RowData>, ExecNodeTranslator<RowData>, SingleTransformationTranslator<RowData>, StreamExecNode<RowData>

Direct Known Subclasses:

StreamExecGlobalWindowAggregate, StreamExecLocalWindowAggregate, StreamExecWindowAggregate

public abstract class StreamExecWindowAggregateBase
extends StreamExecAggregateBase

The base class for window aggregate ExecNode.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_NAMED_WINDOW_PROPERTIES
static String	FIELD_NAME_WINDOWING
static long	WINDOW_AGG_MEMORY_RATIO

Fields inherited from class org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecAggregateBase

FIELD_NAME_AGG_CALL_NEED_RETRACTIONS, FIELD_NAME_AGG_CALLS, FIELD_NAME_GENERATE_UPDATE_BEFORE, FIELD_NAME_GROUPING, FIELD_NAME_NEED_RETRACTION

Fields inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNode

FIELD_NAME_CONFIGURATION, FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE, FIELD_NAME_TYPE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	StreamExecWindowAggregateBase(int id, ExecNodeContext context, ReadableConfig persistedConfig, List<InputProperty> inputProperties, LogicalType outputType, String description)

Method Summary

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)

Methods inherited from class org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase

accept, createFormattedTransformationDescription, createFormattedTransformationName, createTransformationDescription, createTransformationMeta, createTransformationMeta, createTransformationName, createTransformationUid, getContextFromAnnotation, getDescription, getId, getInputEdges, getInputProperties, getOutputType, getPersistedConfig, getSimplifiedName, getTransformation, inputsContainSingleton, replaceInputEdge, resetTransformation, setCompiled, setInputEdges, translateToPlan, translateToPlanInternal

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNode

accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setCompiled, setInputEdges

Methods inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNodeTranslator

translateToPlan

Field Detail

WINDOW_AGG_MEMORY_RATIO

public static final long WINDOW_AGG_MEMORY_RATIO

See Also:

Constant Field Values

FIELD_NAME_WINDOWING

public static final String FIELD_NAME_WINDOWING

See Also:

Constant Field Values

FIELD_NAME_NAMED_WINDOW_PROPERTIES

public static final String FIELD_NAME_NAMED_WINDOW_PROPERTIES

See Also:

Constant Field Values

Constructor Detail

StreamExecWindowAggregateBase

protected StreamExecWindowAggregateBase(int id,
                                        ExecNodeContext context,
                                        ReadableConfig persistedConfig,
                                        List<InputProperty> inputProperties,
                                        LogicalType outputType,
                                        String description)

Method Detail

createSliceAssigner

protected SliceAssigner createSliceAssigner(WindowingStrategy windowingStrategy,
                                            java.time.ZoneId shiftTimeZone)

createSliceAssigner

protected SliceAssigner createSliceAssigner(WindowSpec windowSpec,
                                            int timeAttributeIndex,
                                            java.time.ZoneId shiftTimeZone)

convertToLogicalTypes

protected LogicalType[] convertToLogicalTypes(DataType[] dataTypes)