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

Class JDBCAppendTableSink

java.lang.Object

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

All Implemented Interfaces:

org.apache.flink.table.sinks.AppendStreamTableSink<org.apache.flink.types.Row>, org.apache.flink.table.sinks.BatchTableSink<org.apache.flink.types.Row>, org.apache.flink.table.sinks.StreamTableSink<org.apache.flink.types.Row>, org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>

public class JDBCAppendTableSink
extends Object
implements org.apache.flink.table.sinks.AppendStreamTableSink<org.apache.flink.types.Row>, org.apache.flink.table.sinks.BatchTableSink<org.apache.flink.types.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()
org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>	configure(String[] fieldNames, org.apache.flink.api.common.typeinfo.TypeInformation<?>[] fieldTypes)
void	emitDataSet(org.apache.flink.api.java.DataSet<org.apache.flink.types.Row> dataSet)
void	emitDataStream(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.types.Row> dataStream)
String[]	getFieldNames()
org.apache.flink.api.common.typeinfo.TypeInformation<?>[]	getFieldTypes()
org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row>	getOutputType()

Methods inherited from class java.lang.Object

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

Method Detail

builder

public static JDBCAppendTableSinkBuilder builder()

emitDataStream

public void emitDataStream(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.types.Row> dataStream)

Specified by:

emitDataStream in interface org.apache.flink.table.sinks.AppendStreamTableSink<org.apache.flink.types.Row>

Specified by:

emitDataStream in interface org.apache.flink.table.sinks.StreamTableSink<org.apache.flink.types.Row>

emitDataSet

public void emitDataSet(org.apache.flink.api.java.DataSet<org.apache.flink.types.Row> dataSet)

Specified by:

emitDataSet in interface org.apache.flink.table.sinks.BatchTableSink<org.apache.flink.types.Row>

getOutputType

public org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> getOutputType()

Specified by:

getOutputType in interface org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>

getFieldNames

public String[] getFieldNames()

Specified by:

getFieldNames in interface org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>

getFieldTypes

public org.apache.flink.api.common.typeinfo.TypeInformation<?>[] getFieldTypes()

Specified by:

getFieldTypes in interface org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>

configure

public org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row> configure(String[] fieldNames,
                                                                                    org.apache.flink.api.common.typeinfo.TypeInformation<?>[] fieldTypes)

Specified by:

configure in interface org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>