com.hazelcast.jet.core.test

Class TestProcessorMetaSupplierContext

java.lang.Object

com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

All Implemented Interfaces:

ProcessorMetaSupplier.Context

public class TestProcessorMetaSupplierContext
extends Object
implements ProcessorMetaSupplier.Context

Simple implementation of ProcessorMetaSupplier.Context.

Constructor Summary

Constructors

Constructor and Description
TestProcessorMetaSupplierContext()

Method Summary

Modifier and Type	Method and Description
JetInstance	jetInstance() Returns the current Jet instance.
int	localParallelism() Returns the number of processors that each ProcessorSupplier will be asked to create once deserialized on each member.
com.hazelcast.logging.ILogger	logger() Returns a logger for the associated ProcessorSupplier.
TestProcessorMetaSupplierContext	setJetInstance(JetInstance jetInstance) Set the jet instance.
TestProcessorMetaSupplierContext	setLocalParallelism(int localParallelism) Set local parallelism.
TestProcessorMetaSupplierContext	setTotalParallelism(int totalParallelism) Set total parallelism.
int	totalParallelism() Returns the total number of Processors that will be created across the cluster.

Methods inherited from class java.lang.Object

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

Constructor Detail

TestProcessorMetaSupplierContext

public TestProcessorMetaSupplierContext()

Method Detail

jetInstance

@Nonnull
public JetInstance jetInstance()

Description copied from interface: ProcessorMetaSupplier.Context

Returns the current Jet instance.

Specified by:

jetInstance in interface ProcessorMetaSupplier.Context

setJetInstance

public TestProcessorMetaSupplierContext setJetInstance(JetInstance jetInstance)

Set the jet instance.

totalParallelism

public int totalParallelism()

Description copied from interface: ProcessorMetaSupplier.Context

Returns the total number of Processors that will be created across the cluster.

Specified by:

totalParallelism in interface ProcessorMetaSupplier.Context

setTotalParallelism

public TestProcessorMetaSupplierContext setTotalParallelism(int totalParallelism)

Set total parallelism.

localParallelism

public int localParallelism()

Description copied from interface: ProcessorMetaSupplier.Context

Returns the number of processors that each ProcessorSupplier will be asked to create once deserialized on each member.

Specified by:

localParallelism in interface ProcessorMetaSupplier.Context

logger

@Nonnull
public com.hazelcast.logging.ILogger logger()

Description copied from interface: ProcessorMetaSupplier.Context

Returns a logger for the associated ProcessorSupplier.

Specified by:

logger in interface ProcessorMetaSupplier.Context

setLocalParallelism

public TestProcessorMetaSupplierContext setLocalParallelism(int localParallelism)

Set local parallelism.