org.apache.flink.api.java.io.jdbc.split

Class GenericParameterValuesProvider

java.lang.Object

org.apache.flink.api.java.io.jdbc.split.GenericParameterValuesProvider

All Implemented Interfaces:

ParameterValuesProvider

public class GenericParameterValuesProvider
extends Object
implements ParameterValuesProvider

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
GenericParameterValuesProvider(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

GenericParameterValuesProvider

public GenericParameterValuesProvider(Serializable[][] parameters)

Method Detail

getParameterValues

public Serializable[][] getParameterValues()

Description copied from interface: ParameterValuesProvider

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

Specified by:

getParameterValues in interface ParameterValuesProvider