com.hazelcast.jet.core

Interface ProcessorSupplier

All Superinterfaces:

Serializable

All Known Implementing Classes:

CloseableProcessorSupplier

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface ProcessorSupplier
extends Serializable

Factory of Processor instances. Part of the initialization chain as explained on ProcessorMetaSupplier.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ProcessorSupplier.Context Context passed to the supplier in the init() call.

Method Summary

Modifier and Type	Method and Description
default void	complete(Throwable error) Called after the execution has finished on all members, successfully or not, or immediately, when the execution was aborted due to a member leaving the cluster.
Collection<? extends Processor>	get(int count) Called after init(Context) to retrieve instances of Processor that will be used during the execution of the Jet job.
default void	init(ProcessorSupplier.Context context) Called on each cluster member after deserialization.
static ProcessorSupplier	of(DistributedSupplier<? extends Processor> processorSupplier) Returns a ProcessorSupplier which will delegate to the given Supplier<Processor> to create all Processor instances.

Method Detail

init

default void init(@Nonnull
                  ProcessorSupplier.Context context)

Called on each cluster member after deserialization.

get

@Nonnull
Collection<? extends Processor> get(int count)

Called after init(Context) to retrieve instances of Processor that will be used during the execution of the Jet job.

Parameters:

count - the number of processor this method is required to create and return

complete

default void complete(Throwable error)

Called after the execution has finished on all members, successfully or not, or immediately, when the execution was aborted due to a member leaving the cluster. If called immediately, it can happen that the job is still running on some member.

Note: this method can be called even if init() or get() were not called yet in case the job fails during the init phase.

Parameters:

error - the exception (if any) that caused the job to fail; null in the case of successful job completion

of

@Nonnull
static ProcessorSupplier of(@Nonnull
                                     DistributedSupplier<? extends Processor> processorSupplier)

Returns a ProcessorSupplier which will delegate to the given Supplier<Processor> to create all Processor instances.