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

Packages that use MapSinkEntryProcessorBuilder

Package	Description
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of MapSinkEntryProcessorBuilder in com.hazelcast.jet.pipeline

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

Modifier and Type	Method	Description
MapSinkEntryProcessorBuilder<E,K,V,R>	MapSinkEntryProcessorBuilder.clientConfig(ClientConfig clientConfig)
MapSinkEntryProcessorBuilder<E,K,V,R>	MapSinkEntryProcessorBuilder.dataConnectionName(DataConnectionRef dataConnectionRef)
static <E, K, V, R> MapSinkEntryProcessorBuilder<E,K,V,R>	Sinks.mapEntryProcessorBuilder(String mapName)	Returns a builder object that offers a step-by-step fluent API to build a custom file sink for the Pipeline API.
MapSinkEntryProcessorBuilder<E,K,V,R>	MapSinkEntryProcessorBuilder.maxParallelAsyncOps(int maxParallelAsyncOps)
MapSinkEntryProcessorBuilder<E,K,V,R>	MapSinkEntryProcessorBuilder.toEntryProcessorFn(FunctionEx<? super E,? extends EntryProcessor<K,V,R>> toEntryProcessorFn)
MapSinkEntryProcessorBuilder<E,K,V,R>	MapSinkEntryProcessorBuilder.toKeyFn(FunctionEx<? super E,? extends K> toKeyFn)