org.apache.flink.connector.jdbc.internal.options

Class JdbcReadOptions

java.lang.Object

org.apache.flink.connector.jdbc.internal.options.JdbcReadOptions

All Implemented Interfaces:

Serializable

public class JdbcReadOptions
extends Object
implements Serializable

Options for the JDBC scan.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JdbcReadOptions.Builder Builder of JdbcReadOptions.

Method Summary

Modifier and Type	Method and Description
static JdbcReadOptions.Builder	builder()
boolean	equals(Object o)
boolean	getAutoCommit()
int	getFetchSize()
Optional<Integer>	getNumPartitions()
Optional<String>	getPartitionColumnName()
Optional<Long>	getPartitionLowerBound()
Optional<Long>	getPartitionUpperBound()
Optional<String>	getQuery()

Methods inherited from class java.lang.Object

clone, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getQuery

public Optional<String> getQuery()

getPartitionColumnName

public Optional<String> getPartitionColumnName()

getPartitionLowerBound

public Optional<Long> getPartitionLowerBound()

getPartitionUpperBound

public Optional<Long> getPartitionUpperBound()

getNumPartitions

public Optional<Integer> getNumPartitions()

getFetchSize

public int getFetchSize()

getAutoCommit

public boolean getAutoCommit()

builder

public static JdbcReadOptions.Builder builder()

equals

public boolean equals(Object o)

Overrides:

equals in class Object