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

Class JDBCAppendTableSinkBuilder

java.lang.Object

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

public class JDBCAppendTableSinkBuilder
extends Object

A builder to configure and build the JDBCAppendTableSink.

Constructor Summary

Constructors

Constructor and Description
JDBCAppendTableSinkBuilder()

Method Summary

Modifier and Type	Method and Description
JDBCAppendTableSink	build() Finalizes the configuration and checks validity.
JDBCAppendTableSinkBuilder	setBatchSize(int batchSize) Specify the size of the batch.
JDBCAppendTableSinkBuilder	setDBUrl(String dbURL) Specify the URL of the JDBC database.
JDBCAppendTableSinkBuilder	setDrivername(String drivername) Specify the name of the JDBC driver that will be used.
JDBCAppendTableSinkBuilder	setParameterTypes(int... types) Specify the type of the rows that the sink will be accepting.
JDBCAppendTableSinkBuilder	setParameterTypes(org.apache.flink.api.common.typeinfo.TypeInformation<?>... types) Specify the type of the rows that the sink will be accepting.
JDBCAppendTableSinkBuilder	setPassword(String password) Specify the password of the JDBC connection.
JDBCAppendTableSinkBuilder	setQuery(String query) Specify the query that the sink will execute.
JDBCAppendTableSinkBuilder	setUsername(String username) Specify the username of the JDBC connection.

Methods inherited from class java.lang.Object

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

Constructor Detail

JDBCAppendTableSinkBuilder

public JDBCAppendTableSinkBuilder()

Method Detail

setUsername

public JDBCAppendTableSinkBuilder setUsername(String username)

Specify the username of the JDBC connection.

Parameters:

username - the username of the JDBC connection.

setPassword

public JDBCAppendTableSinkBuilder setPassword(String password)

Specify the password of the JDBC connection.

Parameters:

password - the password of the JDBC connection.

setDrivername

public JDBCAppendTableSinkBuilder setDrivername(String drivername)

Specify the name of the JDBC driver that will be used.

Parameters:

drivername - the name of the JDBC driver.

setDBUrl

public JDBCAppendTableSinkBuilder setDBUrl(String dbURL)

Specify the URL of the JDBC database.

Parameters:

dbURL - the URL of the database, whose format is specified by the corresponding JDBC driver.

setQuery

public JDBCAppendTableSinkBuilder setQuery(String query)

Specify the query that the sink will execute. Usually user can specify INSERT, REPLACE or UPDATE to push the data to the database.

Parameters:

query - The query to be executed by the sink.

See Also:

JDBCOutputFormat.JDBCOutputFormatBuilder.setQuery(String)

setBatchSize

public JDBCAppendTableSinkBuilder setBatchSize(int batchSize)

Specify the size of the batch. By default the sink will batch the query to improve the performance

Parameters:

batchSize - the size of batch

setParameterTypes

public JDBCAppendTableSinkBuilder setParameterTypes(org.apache.flink.api.common.typeinfo.TypeInformation<?>... types)

Specify the type of the rows that the sink will be accepting.

Parameters:

types - the type of each field

setParameterTypes

public JDBCAppendTableSinkBuilder setParameterTypes(int... types)

Specify the type of the rows that the sink will be accepting.

Parameters:

types - the type of each field defined by Types.

build

public JDBCAppendTableSink build()

Finalizes the configuration and checks validity.

Returns:

Configured JDBCOutputFormat