Package org.apache.flink.table.planner.plan.optimize
-
Class Summary Class Description ClearQueryBlockAliasResolver A shuttle to remove query block alias hint.QueryHintsResolver Resolve and validate the query hints.StreamNonDeterministicPhysicalPlanResolver TheStreamNonDeterministicPhysicalPlanResolver
tries to resolve the correctness issue caused by 'Non-Deterministic Updates' (NDU) in a changelog pipeline.StreamNonDeterministicUpdatePlanVisitor An inner visitor to validate if there's any NDU problems which may cause wrong result and try to rewrite lookup join node with materialization (to eliminate the non-deterministic result generated by lookup join node only).