Uses of Class
com.hazelcast.jet.pipeline.MapSinkBuilder
Package
Description
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of MapSinkBuilder in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionMapSinkBuilder.clientConfig
(ClientConfig clientConfig) Sets theClientConfig
with configuration for a Hazelcast client to use for remote Map sink.MapSinkBuilder.dataConnectionRef
(DataConnectionRef dataConnectionRef) Sets theDataConnectionRef
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.mergeFn
(BinaryOperatorEx<V> mergeFn) Set the function to merge the existing value with new value.MapSinkBuilder.toKeyFn
(FunctionEx<? super T, ? extends K> toKeyFn) Set the key-extracting function.MapSinkBuilder.toValueFn
(FunctionEx<? super T, ? extends V> toValueFn) Set the function to extract a value from the incoming items.MapSinkBuilder.updateFn
(BiFunctionEx<? super V, ? super T, ? extends V> updateFn) Set the function to update the value in Hazelcast IMap.