org.apache.flink.table.planner.operations

Class DeletePushDownUtils

java.lang.Object

org.apache.flink.table.planner.operations.DeletePushDownUtils

public class DeletePushDownUtils
extends Object

A utility class for delete push down.

Constructor Summary

Constructors

Constructor and Description
DeletePushDownUtils()

Method Summary

Modifier and Type	Method and Description
static Optional<org.apache.flink.table.connector.sink.DynamicTableSink>	getDynamicTableSink(org.apache.flink.table.catalog.ContextResolvedTable contextResolvedTable, org.apache.calcite.rel.logical.LogicalTableModify tableModify, org.apache.flink.table.catalog.CatalogManager catalogManager) Get the DynamicTableSink for the table to be modified.
static Optional<List<org.apache.flink.table.expressions.ResolvedExpression>>	getResolvedFilterExpressions(org.apache.calcite.rel.logical.LogicalTableModify tableModify) Get the resolved filter expressions from the WHERE clause in DELETE statement, return Optional.empty() if WHERE clause contains sub-query.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DeletePushDownUtils

public DeletePushDownUtils()

Method Detail

getDynamicTableSink

public static Optional<org.apache.flink.table.connector.sink.DynamicTableSink> getDynamicTableSink(org.apache.flink.table.catalog.ContextResolvedTable contextResolvedTable,
                                                                                                   org.apache.calcite.rel.logical.LogicalTableModify tableModify,
                                                                                                   org.apache.flink.table.catalog.CatalogManager catalogManager)

Get the DynamicTableSink for the table to be modified. Return Optional.empty() if it can't get the DynamicTableSink.

getResolvedFilterExpressions

public static Optional<List<org.apache.flink.table.expressions.ResolvedExpression>> getResolvedFilterExpressions(org.apache.calcite.rel.logical.LogicalTableModify tableModify)

Get the resolved filter expressions from the WHERE clause in DELETE statement, return Optional.empty() if WHERE clause contains sub-query.