| 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. | 
| Modifier and Type | Method and Description | 
|---|---|
| static <T> ProcessorMetaSupplier | SourceProcessors. readJdbcP(ExternalDataStoreRef externalDataStoreRef,
         ToResultSetFunction resultSetFn,
         FunctionEx<? super ResultSet,? extends T> mapOutputFn)Returns a supplier of processors for  Sources.jdbc(
ExternalDataStoreRef, 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). | 
| Modifier and Type | Method and Description | 
|---|---|
| static <T> BatchSource<T> | Sources. jdbc(ExternalDataStoreRef externalDataStoreRef,
    ToResultSetFunction resultSetFn,
    FunctionEx<? super ResultSet,? extends T> createOutputFn)Returns a source which connects to the specified database using the given
  externalDataStoreRef, queries the database and creates a result set
 using the givenresultSetFn. | 
| 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 givenresultSetFn. | 
Copyright © 2022 Hazelcast, Inc.. All rights reserved.