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 |
---|---|
DataSet<Row> |
BatchScan.convertToInternalRow(DataSet<Object> input,
FlinkTable<?> flinkTable,
TableConfig config) |
Modifier and Type | Method and Description |
---|---|
DataStream<CRow> |
StreamScan.convertToInternalRow(RowSchema schema,
DataStream<Object> input,
FlinkTable<?> flinkTable,
TableConfig config) |
Modifier and Type | Class and Description |
---|---|
class |
DataSetTable<T> |
class |
DataStreamTable<T> |
class |
StreamTableSourceTable<T> |
class |
TableSourceTable<T>
Table which defines an external table via a
TableSource |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.