File tree Expand file tree Collapse file tree
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2020
2121import org .apache .flink .table .api .TableException ;
2222import org .apache .flink .table .planner .calcite .FlinkTypeFactory ;
23- import org .apache .flink .table .planner .hint .FlinkHints ;
24- import org .apache .flink .table .planner .hint .StateTtlHint ;
2523import org .apache .flink .table .planner .plan .nodes .logical .FlinkLogicalJoin ;
2624import org .apache .flink .table .planner .plan .nodes .physical .stream .StreamPhysicalMultiJoin ;
2725import org .apache .flink .table .planner .plan .utils .IntervalJoinUtil ;
4038import org .apache .calcite .rel .core .Join ;
4139import org .apache .calcite .rel .core .JoinInfo ;
4240import org .apache .calcite .rel .core .JoinRelType ;
43- import org .apache .calcite .rel .core .TableFunctionScan ;
44- import org .apache .calcite .rel .core .TableScan ;
45- import org .apache .calcite .rel .core .Values ;
46- import org .apache .calcite .rel .hint .RelHint ;
4741import org .apache .calcite .rel .logical .LogicalJoin ;
4842import org .apache .calcite .rel .logical .LogicalSnapshot ;
4943import org .apache .calcite .rel .rules .CoreRules ;
6761import java .util .HashMap ;
6862import java .util .List ;
6963import java .util .Map ;
70- import java .util .Objects ;
71- import java .util .Set ;
7264import java .util .stream .Collectors ;
7365import java .util .stream .Stream ;
7466
75- import static org .apache .flink .table .planner .hint .StateTtlHint .STATE_TTL ;
7667import static org .apache .flink .table .planner .plan .utils .MultiJoinUtil .createJoinAttributeMap ;
7768
7869/**
You can’t perform that action at this time.
0 commit comments