Uses of Interface
com.hazelcast.jet.function.ToResultSetFunction

Packages that use ToResultSetFunction

Package	Description
com.hazelcast.jet.core.processor	Contains static utility classes with factories of Jet processors.
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of ToResultSetFunction in com.hazelcast.jet.core.processor

Methods in com.hazelcast.jet.core.processor with parameters of type ToResultSetFunction

Modifier and Type	Method and Description
static <T> ProcessorMetaSupplier	SourceProcessors.readJdbcP(DataConnectionRef dataConnectionRef, ToResultSetFunction resultSetFn, FunctionEx<? super ResultSet,? extends T> mapOutputFn) Returns a supplier of processors for Sources.jdbc( DataConnectionRef, ToResultSetFunction, FunctionEx).
static <T> ProcessorMetaSupplier	SourceProcessors.readJdbcP(SupplierEx<? extends Connection> newConnectionFn, ToResultSetFunction resultSetFn, FunctionEx<? super ResultSet,? extends T> mapOutputFn) Returns a supplier of processors for Sources.jdbc( SupplierEx, ToResultSetFunction, FunctionEx).

Uses of ToResultSetFunction in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline with parameters of type ToResultSetFunction

Modifier and Type	Method and Description
static <T> BatchSource<T>	Sources.jdbc(DataConnectionRef dataConnectionRef, ToResultSetFunction resultSetFn, FunctionEx<? super ResultSet,? extends T> createOutputFn) Returns a source which connects to the specified database using the given dataConnectionRef, queries the database and creates a result set using the given resultSetFn.
static <T> BatchSource<T>	Sources.jdbc(SupplierEx<? extends Connection> newConnectionFn, ToResultSetFunction resultSetFn, FunctionEx<? super ResultSet,? extends T> createOutputFn) Returns a source which connects to the specified database using the given newConnectionFn, queries the database and creates a result set using the the given resultSetFn.