com.hazelcast.jet.core

Class CloseableProcessorSupplier<E extends Processor & Closeable>

java.lang.Object

com.hazelcast.jet.core.CloseableProcessorSupplier<E>

Type Parameters:

E - Processor type

All Implemented Interfaces:

ProcessorSupplier, Serializable

public class CloseableProcessorSupplier<E extends Processor & Closeable>
extends Object
implements ProcessorSupplier

A ProcessorSupplier which closes created processor instances when the job is complete.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface com.hazelcast.jet.core.ProcessorSupplier

ProcessorSupplier.Context

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
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<E>	get(int count) Called after ProcessorSupplier.init(Context) to retrieve instances of Processor that will be used during the execution of the Jet job.
void	init(ProcessorSupplier.Context context) Called on each cluster member after deserialization.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.hazelcast.jet.core.ProcessorSupplier

of

Constructor Detail

CloseableProcessorSupplier

public CloseableProcessorSupplier(DistributedSupplier<E> simpleSupplier)

Parameters:

simpleSupplier - Supplier to create processor instances. Parameter is the local processor index.

CloseableProcessorSupplier

public CloseableProcessorSupplier(DistributedIntFunction<Collection<E>> supplier)

Parameters:

supplier - Supplier to create processor instances.

Method Detail

init

public void init(@Nonnull
                 ProcessorSupplier.Context context)

Description copied from interface: ProcessorSupplier

Called on each cluster member after deserialization.

Specified by:

init in interface ProcessorSupplier

get

@Nonnull
public Collection<E> get(int count)

Description copied from interface: ProcessorSupplier

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

Specified by:

get in interface ProcessorSupplier

Parameters:

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

complete

public void complete(Throwable error)

Description copied from interface: ProcessorSupplier

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.

Specified by:

complete in interface ProcessorSupplier

Parameters:

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