public interface TableSource<T>
DataSet
or DataStream
.
Schema information consists of a data type, field names, and corresponding indices of
these names in the data type.
To define a TableSource one needs to implement getReturnType()
. In this case
field names and field indices are derived from the returned type.
In case if custom field names are required one need to additionally implement
the DefinedFieldNames
trait.
Modifier and Type | Method and Description |
---|---|
String |
explainSource()
Describes the table source
|
TypeInformation<T> |
getReturnType()
Returns the
TypeInformation for the return type of the TableSource . |
TypeInformation<T> getReturnType()
TypeInformation
for the return type of the TableSource
.String explainSource()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.