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