org.apache.flink.connector.jdbc

Class JdbcRowOutputFormat

java.lang.Object

org.apache.flink.api.common.io.RichOutputFormat<In>

org.apache.flink.connector.jdbc.internal.JdbcOutputFormat<Row,Row,JdbcBatchStatementExecutor<Row>>

org.apache.flink.connector.jdbc.JdbcRowOutputFormat

All Implemented Interfaces:

Flushable, Serializable, OutputFormat<Row>, InputTypeConfigurable

@Experimental
public class JdbcRowOutputFormat
extends JdbcOutputFormat<Row,Row,JdbcBatchStatementExecutor<Row>>

OutputFormat to write Rows into a JDBC database. The OutputFormat has to be configured using the supplied OutputFormatBuilder.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JdbcRowOutputFormat.JdbcOutputFormatBuilder Builder for JdbcRowOutputFormat.

Nested classes/interfaces inherited from class org.apache.flink.connector.jdbc.internal.JdbcOutputFormat

JdbcOutputFormat.Builder, JdbcOutputFormat.RecordExtractor<F,T>, JdbcOutputFormat.StatementExecutorFactory<T extends JdbcBatchStatementExecutor<?>>

Field Summary

Fields inherited from class org.apache.flink.connector.jdbc.internal.JdbcOutputFormat

connectionProvider

Method Summary

Modifier and Type	Method and Description
static JdbcRowOutputFormat.JdbcOutputFormatBuilder	buildJdbcOutputFormat()

Methods inherited from class org.apache.flink.connector.jdbc.internal.JdbcOutputFormat

addToBatch, attemptFlush, builder, close, configure, flush, getConnection, getExecutionOptions, open, setInputType, updateExecutor, writeRecord

Methods inherited from class org.apache.flink.api.common.io.RichOutputFormat

getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

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

Method Detail

buildJdbcOutputFormat

public static JdbcRowOutputFormat.JdbcOutputFormatBuilder buildJdbcOutputFormat()