public class TableSourceTable extends FlinkTable<Row>
TableSource
Constructor and Description |
---|
TableSourceTable(TableSource<?> tableSource) |
Modifier and Type | Method and Description |
---|---|
Object |
tableSource() |
fieldIndexes, fieldNames, fieldTypes, getRowType, typeInfo
public TableSourceTable(TableSource<?> tableSource)
public Object tableSource()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.