Package | Description |
---|---|
org.apache.flink.connector.jdbc.internal.options |
Modifier and Type | Method and Description |
---|---|
static JdbcReadOptions.Builder |
JdbcReadOptions.builder() |
JdbcReadOptions.Builder |
JdbcReadOptions.Builder.setAutoCommit(boolean autoCommit)
optional, whether to set auto commit on the JDBC driver.
|
JdbcReadOptions.Builder |
JdbcReadOptions.Builder.setFetchSize(int fetchSize)
optional, the number of rows to fetch per round trip.
|
JdbcReadOptions.Builder |
JdbcReadOptions.Builder.setNumPartitions(int numPartitions)
optional, the maximum number of partitions that can be used for parallelism in table
reading.
|
JdbcReadOptions.Builder |
JdbcReadOptions.Builder.setPartitionColumnName(String partitionColumnName)
optional, name of the column used for partitioning the input.
|
JdbcReadOptions.Builder |
JdbcReadOptions.Builder.setPartitionLowerBound(long partitionLowerBound)
optional, the smallest value of the first partition.
|
JdbcReadOptions.Builder |
JdbcReadOptions.Builder.setPartitionUpperBound(long partitionUpperBound)
optional, the largest value of the last partition.
|
JdbcReadOptions.Builder |
JdbcReadOptions.Builder.setQuery(String query)
optional, SQL query statement for this JDBC source.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.