SortPartitionNode (Flink : Optimizer 1.18.1-cp2 API)

java.lang.Object
- org.apache.flink.optimizer.dag.OptimizerNode
- - org.apache.flink.optimizer.dag.SingleInputNode
  - - org.apache.flink.optimizer.dag.SortPartitionNode

All Implemented Interfaces:

EstimateProvider, DumpableNode<OptimizerNode>, org.apache.flink.util.Visitable<OptimizerNode>
```
public class SortPartitionNode
extends SingleInputNode
```
The optimizer's internal representation of a SortPartition operator node.

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class SortPartitionNode.SortPartitionDescriptor
- Nested classes/interfaces inherited from class org.apache.flink.optimizer.dag.OptimizerNode
  OptimizerNode.UnclosedBranchDescriptor

Field Summary
- Fields inherited from class org.apache.flink.optimizer.dag.SingleInputNode
  inConn, keys
- Fields inherited from class org.apache.flink.optimizer.dag.OptimizerNode
  cachedPlans, closedBranchingNodes, costWeight, estimatedNumRecords, estimatedOutputSize, hereJoinedBranches, id, MAX_DYNAMIC_PATH_COST_WEIGHT, onDynamicPath, openBranches, uniqueFields

Constructor Summary

Constructors
Constructor Description

SortPartitionNode(org.apache.flink.api.common.operators.base.SortPartitionOperatorBase<?> operator)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected void`	`computeOperatorSpecificDefaultEstimates(DataStatistics statistics)`
`org.apache.flink.api.common.operators.base.SortPartitionOperatorBase<?>`	`getOperator()`	Gets the operator represented by this optimizer node.
`String`	`getOperatorName()`	Gets the name of this node, which is the name of the function/operator, or data source / data sink.
`protected List<OperatorDescriptorSingle>`	`getPossibleProperties()`
`org.apache.flink.api.common.operators.SemanticProperties`	`getSemanticProperties()`

Methods inherited from class org.apache.flink.optimizer.dag.SingleInputNode
accept, addLocalCandidates, computeInterestingPropertiesForInputs, computeUnclosedBranchStack, getAlternativePlans, getIncomingConnection, getIncomingConnections, getPredecessorNode, getSemanticPropertiesForGlobalPropertyFiltering, getSemanticPropertiesForLocalPropertyFiltering, instantiateCandidate, setIncomingConnection, setInput

Methods inherited from class org.apache.flink.optimizer.dag.OptimizerNode
addBroadcastConnection, addClosedBranch, addClosedBranches, addOutgoingConnection, areBranchCompatible, clearInterestingProperties, computeOutputEstimates, computeUnclosedBranchStackForBroadcastInputs, computeUnionOfInterestingPropertiesFromSuccessors, getBranchesForParent, getBroadcastConnectionNames, getBroadcastConnections, getClosedBranchingNodes, getCostWeight, getDumpableInputs, getEstimatedAvgWidthPerOutputRecord, getEstimatedNumRecords, getEstimatedOutputSize, getId, getInterestingProperties, getMaxDepth, getMinimalMemoryAcrossAllSubTasks, getOpenBranches, getOptimizerNode, getOutgoingConnections, getParallelism, getPlanNode, getPredecessors, getUniqueFields, hasUnclosedBranches, haveAllOutputConnectionInterestingProperties, identifyDynamicPath, initId, isBranching, isOnDynamicPath, markAllOutgoingConnectionsAsPipelineBreaking, mergeLists, prunePlanAlternatives, prunePlanAlternativesWithCommonBranching, readStubAnnotations, readUniqueFieldsAnnotation, removeClosedBranches, setBroadcastInputs, setEstimatedNumRecords, setEstimatedOutputSize, setParallelism, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - SortPartitionNode
```
public SortPartitionNode(org.apache.flink.api.common.operators.base.SortPartitionOperatorBase<?> operator)
```
- Method Detail
  - getOperator
```
public org.apache.flink.api.common.operators.base.SortPartitionOperatorBase<?> getOperator()
```
    Description copied from class: OptimizerNode
    
    Gets the operator represented by this optimizer node.
    
    Overrides:
    
    getOperator in class SingleInputNode
    
    Returns:
    
    This node's operator.
  - getOperatorName
```
public String getOperatorName()
```
    Description copied from class: OptimizerNode
    
    Gets the name of this node, which is the name of the function/operator, or data source / data sink.
    
    Specified by:
    
    getOperatorName in class OptimizerNode
    
    Returns:
    
    The node name.
  - getPossibleProperties
```
protected List<OperatorDescriptorSingle> getPossibleProperties()
```
    Specified by:
    
    getPossibleProperties in class SingleInputNode
  - computeOperatorSpecificDefaultEstimates
```
protected void computeOperatorSpecificDefaultEstimates(DataStatistics statistics)
```
    Specified by:
    
    computeOperatorSpecificDefaultEstimates in class OptimizerNode
  - getSemanticProperties
```
public org.apache.flink.api.common.operators.SemanticProperties getSemanticProperties()
```
    Overrides:
    
    getSemanticProperties in class SingleInputNode