Package | Description |
---|---|
org.apache.flink.table.operations | |
org.apache.flink.table.planner.connectors |
Modifier and Type | Method and Description |
---|---|
T |
ModifyOperationVisitor.visit(ExternalModifyOperation externalModifyOperation) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSinkUtils.convertExternalToRel(FlinkRelBuilder relBuilder,
org.apache.calcite.rel.RelNode input,
ExternalModifyOperation externalModifyOperation)
Converts an external sink (i.e. further
DataStream transformations) to a RelNode . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.