public class BatchExecPythonOverAggregate extends BatchExecOverAggregateBase
ExecNode
for sort-based over window aggregate (Python user defined aggregate
function).BatchExecOverAggregateBase.OverWindowMode
overSpec
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
BatchExecPythonOverAggregate(OverSpec overSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
protected Transformation<RowData> |
translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
Internal method, translates this node into a Flink operator.
|
getConstants, getInputTypeWithConstants, inferGroupMode, isSlidingWindow, isUnboundedFollowingWindow, isUnboundedPrecedingWindow, isUnboundedWindow
accept, getDescription, getId, getInputEdges, getInputProperties, getNewNodeId, getOutputType, inputsContainSingleton, replaceInputEdge, resetIdCounter, setInputEdges, translateToPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setInputEdges
translateToPlan
public BatchExecPythonOverAggregate(OverSpec overSpec, InputProperty inputProperty, RowType outputType, String description)
protected Transformation<RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
ExecNodeBase
translateToPlanInternal
in class ExecNodeBase<RowData>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.