Package | Description |
---|---|
org.apache.flink.table.plan.nodes | |
org.apache.flink.table.plan.nodes.dataset | |
org.apache.flink.table.plan.nodes.datastream |
Modifier and Type | Method and Description |
---|---|
abstract PhysicalTableSourceScan |
PhysicalTableSourceScan.copy(org.apache.calcite.plan.RelTraitSet traitSet,
TableSource<?> tableSource) |
Modifier and Type | Class and Description |
---|---|
class |
BatchTableSourceScan
Flink RelNode to read data from an external source defined by a
BatchTableSource . |
Modifier and Type | Method and Description |
---|---|
PhysicalTableSourceScan |
BatchTableSourceScan.copy(org.apache.calcite.plan.RelTraitSet traitSet,
TableSource<?> newTableSource) |
Modifier and Type | Class and Description |
---|---|
class |
StreamTableSourceScan
Flink RelNode to read data from an external source defined by a
StreamTableSource . |
Modifier and Type | Method and Description |
---|---|
PhysicalTableSourceScan |
StreamTableSourceScan.copy(org.apache.calcite.plan.RelTraitSet traitSet,
TableSource<?> newTableSource) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.