public class DeletePushDownUtils extends Object
Constructor and Description |
---|
DeletePushDownUtils() |
Modifier and Type | Method and Description |
---|---|
static Optional<DynamicTableSink> |
getDynamicTableSink(ContextResolvedTable contextResolvedTable,
org.apache.calcite.rel.logical.LogicalTableModify tableModify,
CatalogManager catalogManager)
Get the
DynamicTableSink for the table to be modified. |
static Optional<List<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. |
public static Optional<DynamicTableSink> getDynamicTableSink(ContextResolvedTable contextResolvedTable, org.apache.calcite.rel.logical.LogicalTableModify tableModify, CatalogManager catalogManager)
DynamicTableSink
for the table to be modified. Return Optional.empty() if it
can't get the DynamicTableSink
.public static Optional<List<ResolvedExpression>> getResolvedFilterExpressions(org.apache.calcite.rel.logical.LogicalTableModify tableModify)
WHERE
clause in DELETE statement, return
Optional.empty() if WHERE
clause contains sub-query.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.