Package | Description |
---|---|
org.apache.flink.api.java.io.jdbc |
Modifier and Type | Method and Description |
---|---|
static JDBCReadOptions.Builder |
JDBCReadOptions.builder() |
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.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.