public class CollectBatchTableSink extends Object implements org.apache.flink.table.sinks.BatchTableSink<Row>
Constructor and Description |
---|
CollectBatchTableSink(String accumulatorName,
TypeSerializer<Row> serializer) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.table.sinks.TableSink<Row> |
configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes) |
void |
emitDataSet(DataSet<Row> dataSet) |
String[] |
getFieldNames() |
TypeInformation<?>[] |
getFieldTypes() |
TypeInformation<Row> |
getOutputType() |
TypeSerializer<Row> |
getSerializer()
Returns the serializer for deserializing the collected result.
|
public CollectBatchTableSink(String accumulatorName, TypeSerializer<Row> serializer)
public TypeInformation<Row> getOutputType()
getOutputType
in interface org.apache.flink.table.sinks.TableSink<Row>
public String[] getFieldNames()
getFieldNames
in interface org.apache.flink.table.sinks.TableSink<Row>
public TypeInformation<?>[] getFieldTypes()
getFieldTypes
in interface org.apache.flink.table.sinks.TableSink<Row>
public org.apache.flink.table.sinks.TableSink<Row> configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
configure
in interface org.apache.flink.table.sinks.TableSink<Row>
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.