Uses of Class
org.apache.flink.api.java.io.jdbc.JDBCAppendTableSinkBuilder

Packages that use JDBCAppendTableSinkBuilder

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

Uses of JDBCAppendTableSinkBuilder in org.apache.flink.api.java.io.jdbc

Methods in org.apache.flink.api.java.io.jdbc that return JDBCAppendTableSinkBuilder

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