Package com.hazelcast.jet.pipeline

Class MapSinkEntryProcessorBuilder<E,K,V,R>

java.lang.Object

com.hazelcast.jet.pipeline.MapSinkEntryProcessorBuilder<E,K,V,R>

public class MapSinkEntryProcessorBuilder<E,K,V,R>
extends Object

Parameters for using a map as a sink with an EntryProcessor: TODO review if this can be merged with MapSinkEntryProcessorBuilder, add full javadoc if not

Constructor Summary

Constructors

Constructor	Description
MapSinkEntryProcessorBuilder(String mapName)

Method Summary

Modifier and Type	Method	Description
Sink<E>	build()
MapSinkEntryProcessorBuilder<E,K,V,R>	clientConfig(ClientConfig clientConfig)
MapSinkEntryProcessorBuilder<E,K,V,R>	dataConnectionName(DataConnectionRef dataConnectionRef)
MapSinkEntryProcessorBuilder<E,K,V,R>	maxParallelAsyncOps(int maxParallelAsyncOps)
MapSinkEntryProcessorBuilder<E,K,V,R>	toEntryProcessorFn(FunctionEx<? super E,? extends EntryProcessor<K,V,R>> toEntryProcessorFn)
MapSinkEntryProcessorBuilder<E,K,V,R>	toKeyFn(FunctionEx<? super E,? extends K> toKeyFn)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MapSinkEntryProcessorBuilder

public MapSinkEntryProcessorBuilder(String mapName)

Method Details

dataConnectionName

public MapSinkEntryProcessorBuilder<E,K,V,R> dataConnectionName(DataConnectionRef dataConnectionRef)

clientConfig

public MapSinkEntryProcessorBuilder<E,K,V,R> clientConfig(ClientConfig clientConfig)

toKeyFn

public MapSinkEntryProcessorBuilder<E,K,V,R> toKeyFn(FunctionEx<? super E,? extends K> toKeyFn)

toEntryProcessorFn

public MapSinkEntryProcessorBuilder<E,K,V,R> toEntryProcessorFn(FunctionEx<? super E,? extends EntryProcessor<K,V,R>> toEntryProcessorFn)

maxParallelAsyncOps

public MapSinkEntryProcessorBuilder<E,K,V,R> maxParallelAsyncOps(int maxParallelAsyncOps)

build

public Sink<E> build()