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

Packages that use DataConnectionRef

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

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

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

Uses of DataConnectionRef in com.hazelcast.jet.pipeline

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

Modifier and Type	Method and Description
static DataConnectionRef	DataConnectionRef.dataConnectionRef(String name) Creates a reference to the configured data connection

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

Modifier and Type	Method and Description
JdbcSinkBuilder<T>	JdbcSinkBuilder.dataConnectionRef(DataConnectionRef dataConnectionRef) Sets the reference to the configured data connection of DataConnectionRef from which the instance of the DataSource will be retrieved.
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> Sink<T>	Sinks.jdbc(String updateQuery, DataConnectionRef dataConnectionRef, BiConsumerEx<PreparedStatement,T> bindFn) A shortcut for:
static <K,V> StreamSource<Map.Entry<K,V>>	Sources.remoteMapJournal(String mapName, DataConnectionRef dataConnectionRef, JournalInitialPosition initialPos) Convenience for Sources.remoteMapJournal(String, DataConnectionRef, JournalInitialPosition, FunctionEx, PredicateEx) which will pass only ADDED and UPDATED events and will project the event's key and new value into a Map.Entry.
static <T,K,V> StreamSource<T>	Sources.remoteMapJournal(String mapName, DataConnectionRef dataConnectionRef, JournalInitialPosition initialPos, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn) The same as the Sources.remoteMapJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx) method.