Package | Description |
---|---|
org.apache.flink.api.java.io.jdbc |
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(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.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.