org.apache.flink.walkthrough.common.table

Class SpendReportTableSink

java.lang.Object

org.apache.flink.walkthrough.common.table.SpendReportTableSink

All Implemented Interfaces:

AppendStreamTableSink<Row>, BatchTableSink<Row>, StreamTableSink<Row>, TableSink<Row>

@PublicEvolving
public class SpendReportTableSink
extends Object
implements AppendStreamTableSink<Row>, BatchTableSink<Row>

A simple table sink for writing to stdout.

Constructor Summary

Constructors

Constructor and Description
SpendReportTableSink()

Method Summary

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) Emits the DataSet.
void	emitDataStream(DataStream<Row> dataStream) Emits the DataStream.
DataType	getConsumedDataType() Returns the data type consumed by this TableSink.
String[]	getFieldNames()
TypeInformation<?>[]	getFieldTypes()
TableSchema	getTableSchema() Returns the schema of the consumed table.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.sinks.StreamTableSink

consumeDataStream

Methods inherited from interface org.apache.flink.table.sinks.TableSink

getOutputType

Constructor Detail

SpendReportTableSink

public SpendReportTableSink()

Method Detail

emitDataSet

public void emitDataSet(DataSet<Row> dataSet)

Description copied from interface: BatchTableSink

Emits the DataSet.

Specified by:

emitDataSet in interface BatchTableSink<Row>

emitDataStream

public void emitDataStream(DataStream<Row> dataStream)

Description copied from interface: StreamTableSink

Emits the DataStream.

Specified by:

emitDataStream in interface StreamTableSink<Row>

getTableSchema

public TableSchema getTableSchema()

Description copied from interface: TableSink

Returns the schema of the consumed table.

Specified by:

getTableSchema in interface TableSink<Row>

Returns:

The TableSchema of the consumed table.

getConsumedDataType

public DataType getConsumedDataType()

Description copied from interface: TableSink

Returns the data type consumed by this TableSink.

Specified by:

getConsumedDataType in interface TableSink<Row>

Returns:

The data type expected by this TableSink.

getFieldNames

public String[] getFieldNames()

Specified by:

getFieldNames in interface TableSink<Row>

getFieldTypes

public TypeInformation<?>[] getFieldTypes()

Specified by:

getFieldTypes in interface TableSink<Row>

configure

public TableSink<Row> configure(String[] fieldNames,
                                TypeInformation<?>[] fieldTypes)

Description copied from interface: TableSink

Returns a copy of this TableSink configured with the field names and types of the table to emit.

Specified by:

configure in interface TableSink<Row>

Parameters:

fieldNames - The field names of the table to emit.

fieldTypes - The field types of the table to emit.

Returns:

A copy of this TableSink configured with the field names and types of the table to emit.