Uses of Interface
com.hazelcast.jet.function.DistributedIntFunction

Packages that use DistributedIntFunction

Package	Description
com.hazelcast.jet.core	Jet's Core API.
com.hazelcast.jet.core.processor	Apache Kafka reader/writer support for Hazelcast Jet.
com.hazelcast.jet.stream	java.util.stream implementation using Hazelcast Jet

Uses of DistributedIntFunction in com.hazelcast.jet.core

Constructors in com.hazelcast.jet.core with parameters of type DistributedIntFunction

Constructor and Description
CloseableProcessorSupplier(DistributedIntFunction<Collection<E>> supplier)

Uses of DistributedIntFunction in com.hazelcast.jet.core.processor

Methods in com.hazelcast.jet.core.processor with parameters of type DistributedIntFunction

Modifier and Type	Method and Description
static <B,T> ProcessorSupplier	SinkProcessors.writeBufferedP(DistributedIntFunction<B> newBufferFn, DistributedBiConsumer<B,T> addToBufferFn, DistributedConsumer<B> flushBufferFn) Returns a supplier of processors for a vertex that drains all the items from its inbox to an intermediate buffer and then flushes the buffer.
static <B,T> ProcessorSupplier	SinkProcessors.writeBufferedP(DistributedIntFunction<B> newBufferFn, DistributedBiConsumer<B,T> addToBufferFn, DistributedConsumer<B> flushBufferFn, DistributedConsumer<B> disposeBufferFn) Returns a supplier of processors for a vertex that drains all the items from the inbox to an intermediate buffer and then flushes the buffer.

Uses of DistributedIntFunction in com.hazelcast.jet.stream

Methods in com.hazelcast.jet.stream with parameters of type DistributedIntFunction

Modifier and Type	Method and Description
default DistributedIntStream	DistributedIntStream.flatMap(DistributedIntFunction<? extends java.util.stream.IntStream> mapper) Returns a stream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.
default <U> DistributedStream<U>	DistributedIntStream.mapToObj(DistributedIntFunction<? extends U> mapper) Returns an object-valued DistributedStream consisting of the results of applying the given function to the elements of this stream.