Package | Description |
---|---|
org.apache.flink.table.operations | |
org.apache.flink.table.planner.connectors |
Modifier and Type | Method and Description |
---|---|
T |
ModifyOperationVisitor.visit(CollectModifyOperation selectOperation) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSinkUtils.convertCollectToRel(org.apache.flink.table.planner.calcite.FlinkRelBuilder relBuilder,
org.apache.calcite.rel.RelNode input,
CollectModifyOperation collectModifyOperation)
Converts an
TableResult.collect() sink to a RelNode . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.