Uses of Class
com.hazelcast.jet.pipeline.ExternalDataStoreRef

Packages that use ExternalDataStoreRef

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 ExternalDataStoreRef in com.hazelcast.jet.core.processor

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

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	SinkProcessors.writeJdbcP(String updateQuery, ExternalDataStoreRef externalDataStoreRef, BiConsumerEx<? super PreparedStatement,? super T> bindFn, boolean exactlyOnce, int batchLimit) Returns a supplier of processors for Sinks.jdbcBuilder().

Uses of ExternalDataStoreRef in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline that return ExternalDataStoreRef

Modifier and Type	Method and Description
static ExternalDataStoreRef	ExternalDataStoreRef.externalDataStoreRef(String name) Creates a reference to the configured external datastore

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

Modifier and Type	Method and Description
JdbcSinkBuilder<T>	JdbcSinkBuilder.externalDataStoreRef(ExternalDataStoreRef externalDataStoreRef) Sets the reference to the configured external dataStore of ExternalDataStoreRef from which the instance of the DataSource will be retrieved.
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 given resultSetFn.
static <T> Sink<T>	Sinks.jdbc(String updateQuery, ExternalDataStoreRef externalDataStoreRef, BiConsumerEx<PreparedStatement,T> bindFn) A shortcut for: