public static class JDBCReadOptions.Builder extends Object
JDBCReadOptions
.Constructor and Description |
---|
Builder() |
Modifier and Type | Method and Description |
---|---|
JDBCReadOptions |
build() |
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.
|
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 build()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.