public interface TableSink<T>
TableSink
specifies how to emit a Table
to an external
system or location.
The interface is generic such that it can support different storage locations and formats.
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. |
String[] |
getFieldNames()
Returns the names of the table fields.
|
TypeInformation<?>[] |
getFieldTypes()
Returns the types of the table fields.
|
TypeInformation<T> |
getOutputType()
Return the type expected by this
TableSink . |
TypeInformation<T> getOutputType()
TableSink
.
This type should depend on the types returned by getFieldNames
.
TableSink
.String[] getFieldNames()
TypeInformation<?>[] getFieldTypes()
TableSink<T> configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
TableSink
configured with the field names and types of the
Table
to emit.
fieldNames
- The field names of the table to emit.fieldTypes
- The field types of the table to emit.TableSink
configured with the field names and types of the
Table
to emit.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.