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
long	executionId() Returns the job execution ID.
JetInstance	jetInstance() Returns the current Jet instance.
JobConfig	jobConfig() Returns the JobConfig.
long	jobId() Returns the job ID.
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	setExecutionId(long executionId) Sets the execution ID.
TestProcessorMetaSupplierContext	setJetInstance(JetInstance jetInstance) Sets the jet instance.
TestProcessorMetaSupplierContext	setJobConfig(JobConfig jobConfig) Sets the job name.
TestProcessorMetaSupplierContext	setJobId(long jobId) Sets the job ID.
TestProcessorMetaSupplierContext	setLocalParallelism(int localParallelism) Sets local parallelism.
TestProcessorMetaSupplierContext	setLogger(ILogger logger) Sets the logger.
TestProcessorMetaSupplierContext	setTotalParallelism(int totalParallelism) Sets the total parallelism.
TestProcessorMetaSupplierContext	setVertexName(String vertexName) Sets 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

@Nonnull
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)

Sets the jet instance.

jobId

public long jobId()

Description copied from interface: ProcessorMetaSupplier.Context

Returns the job ID. Job id is unique for job submission and doesn't change when the job restarts. It's also unique for all running and archived jobs.

Specified by:

jobId in interface ProcessorMetaSupplier.Context

setJobId

public TestProcessorMetaSupplierContext setJobId(long jobId)

Sets the job ID.

executionId

public long executionId()

Description copied from interface: ProcessorMetaSupplier.Context

Returns the job execution ID. It's unique for one execution, but changes when the job restarts.

Specified by:

executionId in interface ProcessorMetaSupplier.Context

setExecutionId

public TestProcessorMetaSupplierContext setExecutionId(long executionId)

Sets the execution ID.

jobConfig

@Nonnull
public JobConfig jobConfig()

Description copied from interface: ProcessorMetaSupplier.Context

Returns the JobConfig.

Specified by:

jobConfig in interface ProcessorMetaSupplier.Context

setJobConfig

public TestProcessorMetaSupplierContext setJobConfig(@Nonnull
                                                     JobConfig jobConfig)

Sets the job name.

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)

Sets the 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. 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)

Sets local 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)

Sets the logger.

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)

Sets the vertex name.

loggerName

protected String loggerName()