Bulk Operation

FLINK-20435 Remove BatchExecExchange and StreamExecExchange, and replace their functionality with ExecEdge

FLINK-20435 Introduce ExecEdge to connect two ExecNodes

FLINK-20435 Rename ExecEdge to InputProperty

FLINK-20435 Introduce ExecNodeGraph to wrap the ExecNode topology

FLINK-20435 Separate the implementation of StreamExecIntervalJoin

FLINK-20435 Separete the implementation of StreamExecJoin

FLINK-20435 Remove legacy exec nodes

FLINK-20435 Rename Stream(/Batch)ExecIntermediateTableScan to Stream(/Batch)PhysicalIntermediateTableScan

FLINK-20435 Separate the implementation of sink nodes

FLINK-20435 Separate the implementation of StreamExecDeduplicate

FLINK-20435 Separate the implementation of StreamExecMatch

FLINK-20435 Separate the implementation of StreamExecLookup and BatchExecLookup

FLINK-20435 Port StreamExecPythonOverAggregate and BatchExecPythonOverAggregate to Java

FLINK-20435 Separate the implementation of BatchExecOverAggregate and StreamExecOverAggregate

FLINK-20435 Separate the implementation of StreamExecTemporalJoin

FLINK-20435 Port StreamExecPythonGroupWindowAggregate and BatchExecPythonGroupWindowAggregate to Java

FLINK-20435 Separate the implementation of batch window aggregate nodes

FLINK-20435 Separate the implementation of stream window aggregate nodes

FLINK-20435 Separate the implementation of BatchExec nodes for Join

FLINK-20435 Separate the implementation of BatchExecRank

FLINK-20435 Separate the implementation of sort nodes

FLINK-20435 Port batch python group aggregate nodes to Java

FLINK-20435 Port stream python group aggregate nodes to Java

FLINK-20435 Separate the implementation of batch group aggregate nodes

FLINK-20435 Separate the implementation of stream group aggregate nodes

FLINK-20435 Separate the implementation of BatchExecLimit and StreamExecLimit

FLINK-20435 Change BatchExecNode & StreamExecNode to interface and make each node extended from ExecNodeBase directly

FLINK-20435 Separate the implementation of StreamExecMiniBatchAssigner

FLINK-20435 Separate the implementation of StreamExecDropUpdateBefore

FLINK-20435 Separate the implementation of BatchExecExpand and StreamExecExpand

FLINK-20435 Separate the implementation of BatchExecUnion and StreamExecUnion

FLINK-20435 Separate the implementation of BatchExecValues and StreamExecValues

FLINK-20435 Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java

FLINK-20435 Separate the implementation of BatchExecCorrelate and StreamExecCorrelate

FLINK-20435 ExecNode#getOutputType method should return LogicalType instead of RowType

FLINK-20435 Introduce translateToExecNode method for FlinkPhysicalRel

FLINK-20435 Separate the implementation of StreamExecWatermarkAssigner

FLINK-20435 Separate the implementation of StreamExecChangelogNormalize

FLINK-20435 Port BatchExecPythonCalc and StreamExecPythonCalc to Java

FLINK-20435 Separate the implementation of BatchExecCalc and StreamExecCalc

FLINK-20435 Separate the implementation of BatchExecDataStreamScan and StreamExecDataStreamScan

FLINK-20435 Separate the implementation of BatchExecLegacyTableSourceScan and StreamExecLegacyTableSourceScan

FLINK-20435 Separate the implementation of BatchExecTableSourceScan and StreamExecTableSourceScan

FLINK-20435 Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

FLINK-20435 Separate the implementation of BatchExecExchange and StreamExecExchange

FLINK-20435 Introduce getDescription, getOutputType, replaceInput methods for ExecNode

FLINK-20435 Deprecate the classes in scala `nodes.exec` package

FLINK-20435 Refactor verifyPlan methods in TableTestBase

FLINK-20435 Don't share inputs between FlinkPhysicalRel and ExecNode

FLINK-20435 Adjust the explain result

FLINK-20435 Port ExecNode to Java

FLINK-20435 Simplify type parameter of ExecNode