public abstract class BatchExecOverAggregateBase extends ExecNodeBase<RowData> implements InputSortedExecNode<RowData>, SingleTransformationTranslator<RowData>
ExecNode
base class for sort-based over window aggregate.Modifier and Type | Class and Description |
---|---|
static class |
BatchExecOverAggregateBase.OverWindowMode
OverWindowMode describes the mode of a group in over window.
|
Modifier and Type | Field and Description |
---|---|
protected OverSpec |
overSpec |
FIELD_NAME_CONFIGURATION, FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE, FIELD_NAME_STATE, FIELD_NAME_TYPE
Constructor and Description |
---|
BatchExecOverAggregateBase(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
OverSpec overSpec,
InputProperty inputProperty,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
containSizeBasedWindowFunction(OverSpec.GroupSpec group) |
protected List<org.apache.calcite.rex.RexLiteral> |
getConstants() |
protected RowType |
getInputTypeWithConstants() |
protected BatchExecOverAggregateBase.OverWindowMode |
inferGroupMode(OverSpec.GroupSpec group)
Infer the over window mode based on given group info.
|
protected boolean |
isSlidingWindow(OverSpec.GroupSpec group) |
protected boolean |
isUnboundedFollowingWindow(OverSpec.GroupSpec group) |
protected boolean |
isUnboundedPrecedingWindow(OverSpec.GroupSpec group) |
protected boolean |
isUnboundedWindow(OverSpec.GroupSpec group) |
accept, createFormattedTransformationDescription, createFormattedTransformationName, createTransformationDescription, createTransformationMeta, createTransformationMeta, createTransformationName, createTransformationUid, getContextFromAnnotation, getDescription, getId, getInputEdges, getInputProperties, getOutputType, getPersistedConfig, getSimplifiedName, getTransformation, inputsContainSingleton, replaceInputEdge, setCompiled, setInputEdges, supportFusionCodegen, translateToFusionCodegenSpec, translateToFusionCodegenSpecInternal, translateToPlan, translateToPlanInternal
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setCompiled, setInputEdges
translateToPlan
supportFusionCodegen, translateToFusionCodegenSpec
protected final OverSpec overSpec
public BatchExecOverAggregateBase(int id, ExecNodeContext context, ReadableConfig persistedConfig, OverSpec overSpec, InputProperty inputProperty, RowType outputType, String description)
protected RowType getInputTypeWithConstants()
protected boolean isUnboundedWindow(OverSpec.GroupSpec group)
protected boolean isUnboundedPrecedingWindow(OverSpec.GroupSpec group)
protected boolean isUnboundedFollowingWindow(OverSpec.GroupSpec group)
protected boolean isSlidingWindow(OverSpec.GroupSpec group)
protected List<org.apache.calcite.rex.RexLiteral> getConstants()
protected boolean containSizeBasedWindowFunction(OverSpec.GroupSpec group)
protected BatchExecOverAggregateBase.OverWindowMode inferGroupMode(OverSpec.GroupSpec group)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.