Package | Description |
---|---|
org.apache.flink.table.operations | |
org.apache.flink.table.operations.ddl | |
org.apache.flink.table.planner.connectors |
Modifier and Type | Method and Description |
---|---|
T |
ModifyOperationVisitor.visit(SinkModifyOperation catalogSink) |
Modifier and Type | Method and Description |
---|---|
SinkModifyOperation |
CreateTableASOperation.toSinkModifyOperation(CatalogManager catalogManager) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSinkUtils.convertSinkToRel(FlinkRelBuilder relBuilder,
org.apache.calcite.rel.RelNode input,
SinkModifyOperation sinkModifyOperation,
DynamicTableSink sink)
Converts a given
DynamicTableSink to a RelNode . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.