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