com.hazelcast.jet.core.test

Class TestProcessorMetaSupplierContext

java.lang.Object

com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

All Implemented Interfaces:

ProcessorMetaSupplier.Context

Direct Known Subclasses:

TestProcessorSupplierContext

public class TestProcessorMetaSupplierContext
extends Object
implements ProcessorMetaSupplier.Context

ProcessorMetaSupplier.Context implementation suitable to be used in tests.

Field Summary

Fields

Modifier and Type	Field and Description
protected ILogger	logger

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.
ILogger	logger() Returns a logger for the associated ProcessorMetaSupplier.
protected String	loggerName()
int	memberCount() Returns the number of members running this job.
TestProcessorMetaSupplierContext	setJetInstance(JetInstance jetInstance) Set the jet instance.
TestProcessorMetaSupplierContext	setLocalParallelism(int localParallelism) Set local parallelism.
TestProcessorMetaSupplierContext	setLogger(ILogger logger) Set the logger.
TestProcessorMetaSupplierContext	setTotalParallelism(int totalParallelism) Set total parallelism.
TestProcessorMetaSupplierContext	setVertexName(String vertexName) Set the vertex name.
int	totalParallelism() Returns the total number of Processors that will be created across the cluster.
String	vertexName() Returns the name of the associated vertex.

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected ILogger logger

Constructor Detail

TestProcessorMetaSupplierContext

public TestProcessorMetaSupplierContext()

Method Detail

jetInstance

public JetInstance jetInstance()

Description copied from interface: ProcessorMetaSupplier.Context

Returns the current Jet instance.

Specified by:

jetInstance in interface ProcessorMetaSupplier.Context

setJetInstance

@Nonnull
public TestProcessorMetaSupplierContext setJetInstance(@Nonnull
                                                                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. This number remains stable for entire job execution. It is equal to ProcessorMetaSupplier.Context.memberCount() * ProcessorMetaSupplier.Context.localParallelism().

Specified by:

totalParallelism in interface ProcessorMetaSupplier.Context

setTotalParallelism

@Nonnull
public TestProcessorMetaSupplierContext setTotalParallelism(int totalParallelism)

Set total parallelism.

logger

@Nonnull
public ILogger logger()

Description copied from interface: ProcessorMetaSupplier.Context

Returns a logger for the associated ProcessorMetaSupplier.

Specified by:

logger in interface ProcessorMetaSupplier.Context

setLogger

public TestProcessorMetaSupplierContext setLogger(@Nonnull
                                                  ILogger logger)

Set the logger.

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. All members have equal local parallelism. The count doesn't change unless the job restarts.

Specified by:

localParallelism in interface ProcessorMetaSupplier.Context

setLocalParallelism

@Nonnull
public TestProcessorMetaSupplierContext setLocalParallelism(int localParallelism)

Set local parallelism.

memberCount

public int memberCount()

Description copied from interface: ProcessorMetaSupplier.Context

Returns the number of members running this job.

Note that the value might be lower than current member count if members were added after the job started. The count doesn't change unless the job restarts.

Specified by:

memberCount in interface ProcessorMetaSupplier.Context

vertexName

@Nonnull
public String vertexName()

Description copied from interface: ProcessorMetaSupplier.Context

Returns the name of the associated vertex.

Specified by:

vertexName in interface ProcessorMetaSupplier.Context

setVertexName

@Nonnull
public TestProcessorMetaSupplierContext setVertexName(@Nonnull
                                                               String vertexName)

Set the vertex name.

loggerName

protected String loggerName()