Package | Description |
---|---|
org.apache.flink.table.plan.nodes.dataset | |
org.apache.flink.table.plan.nodes.datastream | |
org.apache.flink.table.plan.schema |
Modifier and Type | Method and Description |
---|---|
protected DataSet<Object> |
BatchScan.convertToExpectedType(DataSet<Object> input,
FlinkTable<?> flinkTable,
scala.Option<TypeInformation<Object>> expectedType,
TableConfig config) |
Modifier and Type | Method and Description |
---|---|
protected DataStream<Object> |
StreamScan.convertToExpectedType(DataStream<Object> input,
FlinkTable<?> flinkTable,
scala.Option<TypeInformation<Object>> expectedType,
TableConfig config) |
Modifier and Type | Class and Description |
---|---|
class |
DataSetTable<T> |
class |
DataStreamTable<T> |
class |
TableSourceTable<T>
Table which defines an external table via a
TableSource |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.