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

Interface ParameterValuesProvider

All Known Implementing Classes:

GenericParameterValuesProvider, NumericBetweenParametersProvider

public interface ParameterValuesProvider

This interface is used by the JDBCInputFormat to compute the list of parallel query to run (i.e. splits). Each query will be parameterized using a row of the matrix provided by each ParameterValuesProvider implementation.

Method Summary

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

Method Detail

getParameterValues

Serializable[][] getParameterValues()

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