org.apache.flink.api.java.io.jdbc

Class JDBCAppendTableSink

java.lang.Object

org.apache.flink.api.java.io.jdbc.JDBCAppendTableSink

All Implemented Interfaces:

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

public class JDBCAppendTableSink
extends Object
implements AppendStreamTableSink<Row>, BatchTableSink<Row>

An at-least-once Table sink for JDBC.

The mechanisms of Flink guarantees delivering messages at-least-once to this sink (if checkpointing is enabled). However, one common use case is to run idempotent queries (e.g., REPLACE or INSERT OVERWRITE) to upsert into the database and achieve exactly-once semantic.

Method Summary

Modifier and Type	Method and Description
static JDBCAppendTableSinkBuilder	builder()
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.
DataStreamSink<?>	consumeDataStream(DataStream<Row> dataStream) Consumes the DataStream and return the sink transformation DataStreamSink.
void	emitDataSet(DataSet<Row> dataSet) Emits the DataSet.
void	emitDataStream(DataStream<Row> dataStream) Emits the DataStream.
String[]	getFieldNames()
TypeInformation<?>[]	getFieldTypes()
TypeInformation<Row>	getOutputType()

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.TableSink

getConsumedDataType, getTableSchema

Method Detail

builder

public static JDBCAppendTableSinkBuilder builder()

consumeDataStream

public DataStreamSink<?> consumeDataStream(DataStream<Row> dataStream)

Description copied from interface: StreamTableSink

Consumes the DataStream and return the sink transformation DataStreamSink. The returned DataStreamSink will be used to set resources for the sink operator.

Specified by:

consumeDataStream in interface StreamTableSink<Row>

emitDataStream

public void emitDataStream(DataStream<Row> dataStream)

Description copied from interface: StreamTableSink

Emits the DataStream.

Specified by:

emitDataStream in interface StreamTableSink<Row>

emitDataSet

public void emitDataSet(DataSet<Row> dataSet)

Description copied from interface: BatchTableSink

Emits the DataSet.

Specified by:

emitDataSet in interface BatchTableSink<Row>

getOutputType

public TypeInformation<Row> getOutputType()

Specified by:

getOutputType in interface TableSink<Row>

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.