org.apache.flink.connector.jdbc.split

Interface JdbcParameterValuesProvider

All Known Implementing Classes:

JdbcGenericParameterValuesProvider, JdbcNumericBetweenParametersProvider

@Experimental
public interface JdbcParameterValuesProvider

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 JdbcParameterValuesProvider 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.