public interface TableSinkBase<T> extends TableSink<T>
Modifier and Type | Method and Description |
---|---|
TableSink<T> |
configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Return a copy of this
TableSink configured with the field names and types of the
Table to emit. |
TableSinkBase<T> |
copy()
Return a deep copy of the
TableSink . |
scala.Option<String[]> |
fieldNames() |
scala.Option<TypeInformation<?>[]> |
fieldTypes() |
String[] |
getFieldNames()
Return the field names of the
Table to emit. |
TypeInformation<?>[] |
getFieldTypes()
Return the field types of the
Table to emit. |
getOutputType
scala.Option<String[]> fieldNames()
scala.Option<TypeInformation<?>[]> fieldTypes()
TableSinkBase<T> copy()
TableSink
.String[] getFieldNames()
Table
to emit.getFieldNames
in interface TableSink<T>
TypeInformation<?>[] getFieldTypes()
Table
to emit.getFieldTypes
in interface TableSink<T>
TableSink<T> configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
TableSink
configured with the field names and types of the
Table
to emit.
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.