com.hazelcast.jet.function

Interface ToResultSetFunction

All Superinterfaces:

Serializable

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface ToResultSetFunction
extends Serializable

A function that accepts a JDBC connection to the database, the total parallelism and processor index as arguments and produces a result set. This result set should return a part of the whole result set specific to this processor.

Since:

Jet 3.0

Method Summary

Modifier and Type	Method and Description
ResultSet	createResultSet(Connection connection, int parallelism, int index) Creates a result set which returns a part of the rows pertaining to the given processor.

Method Detail

createResultSet

ResultSet createResultSet(Connection connection,
                          int parallelism,
                          int index)
                   throws SQLException

Creates a result set which returns a part of the rows pertaining to the given processor.

Parameters:

connection - the JDBC connection

parallelism - the total parallelism for the processor

index - the global processor index

Throws:

SQLException