Package | Description |
---|---|
org.apache.flink.table.operations | |
org.apache.flink.table.planner.sinks |
Modifier and Type | Method and Description |
---|---|
T |
ModifyOperationVisitor.visit(CatalogSinkModifyOperation catalogSink) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSinkUtils.toRel(org.apache.flink.table.planner.calcite.FlinkRelBuilder relBuilder,
org.apache.calcite.rel.RelNode input,
CatalogSinkModifyOperation sinkOperation,
DynamicTableSink sink,
CatalogTable table)
Similar to
CatalogSourceTable.toRel(RelOptTable.ToRelContext) , converts a given
DynamicTableSink to a RelNode . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.