Constructor and Description |
---|
CollectBatchTableSink(String accumulatorName,
TypeSerializer<Row> serializer) |
Modifier and Type | Method and Description |
---|---|
TableSink<Row> |
configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Returns a copy of this
TableSink configured with the field names and types of the
table to emit. |
void |
emitDataSet(DataSet<Row> dataSet) |
String[] |
getFieldNames()
Returns the names of the table fields.
|
TypeInformation<?>[] |
getFieldTypes()
Returns the types of the table fields.
|
TypeInformation<Row> |
getOutputType()
Returns the type expected by this
TableSink . |
TypeSerializer<Row> |
getSerializer()
Returns the serializer for deserializing the collected result.
|
public CollectBatchTableSink(String accumulatorName, TypeSerializer<Row> serializer)
public TypeInformation<Row> getOutputType()
TableSink
TableSink
.
This type should depend on the types returned by TableSink.getFieldNames()
.
getOutputType
in interface TableSink<Row>
TableSink
.public String[] getFieldNames()
TableSink
getFieldNames
in interface TableSink<Row>
public TypeInformation<?>[] getFieldTypes()
TableSink
getFieldTypes
in interface TableSink<Row>
public TableSink<Row> configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
TableSink
TableSink
configured with the field names and types of the
table to emit.public void emitDataSet(DataSet<Row> dataSet)
emitDataSet
in interface org.apache.flink.table.sinks.BatchTableSink<Row>
public TypeSerializer<Row> getSerializer()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.