org.apache.flink.connector.jdbc.split

Class JdbcGenericParameterValuesProvider

java.lang.Object

org.apache.flink.connector.jdbc.split.JdbcGenericParameterValuesProvider

All Implemented Interfaces:

JdbcParameterValuesProvider

Direct Known Subclasses:

GenericParameterValuesProvider

@Experimental
public class JdbcGenericParameterValuesProvider
extends Object
implements JdbcParameterValuesProvider

This splits generator actually does nothing but wrapping the query parameters computed by the user before creating the JdbcInputFormat instance.

Constructor Summary

Constructors

Constructor and Description
JdbcGenericParameterValuesProvider(Serializable[][] parameters)

Method Summary

Modifier and Type	Method and Description
Serializable[][]	getParameterValues() Returns the necessary parameters array to use for query in parallel a table.

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcGenericParameterValuesProvider

public JdbcGenericParameterValuesProvider(Serializable[][] parameters)

Method Detail

getParameterValues

public Serializable[][] getParameterValues()

Description copied from interface: JdbcParameterValuesProvider

Returns the necessary parameters array to use for query in parallel a table.

Specified by:

getParameterValues in interface JdbcParameterValuesProvider