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

Packages that use MapSinkBuilder

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

Uses of MapSinkBuilder in com.hazelcast.jet.pipeline

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

Modifier and Type	Method	Description
MapSinkBuilder<T,K,V>	MapSinkBuilder.clientConfig(ClientConfig clientConfig)	Sets the ClientConfig with configuration for a Hazelcast client to use for remote Map sink.
MapSinkBuilder<T,K,V>	MapSinkBuilder.dataConnectionRef(DataConnectionRef dataConnectionRef)	Sets the DataConnectionRef reference to a HazelcastDataConnection to use for remote Map sink.
static <T, K, V> MapSinkBuilder<T,K,V>	Sinks.mapBuilder(String mapName)	Returns a builder object that offers a step-by-step fluent API to build a custom file sink for the Pipeline API.
MapSinkBuilder<T,K,V>	MapSinkBuilder.mergeFn(BinaryOperatorEx<V> mergeFn)	Set the function to merge the existing value with new value.
MapSinkBuilder<T,K,V>	MapSinkBuilder.toKeyFn(FunctionEx<? super T,? extends K> toKeyFn)	Set the key-extracting function.
MapSinkBuilder<T,K,V>	MapSinkBuilder.toValueFn(FunctionEx<? super T,? extends V> toValueFn)	Set the function to extract a value from the incoming items.
MapSinkBuilder<T,K,V>	MapSinkBuilder.updateFn(BiFunctionEx<? super V,? super T,? extends V> updateFn)	Set the function to update the value in Hazelcast IMap.