Uses of Class
com.hazelcast.jet.pipeline.MapSinkEntryProcessorBuilder
Package
Description
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of MapSinkEntryProcessorBuilder in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionMapSinkEntryProcessorBuilder.clientConfig
(ClientConfig clientConfig) 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.maxParallelAsyncOps
(int maxParallelAsyncOps) MapSinkEntryProcessorBuilder.toEntryProcessorFn
(FunctionEx<? super E, ? extends EntryProcessor<K, V, R>> toEntryProcessorFn) MapSinkEntryProcessorBuilder.toKeyFn
(FunctionEx<? super E, ? extends K> toKeyFn)