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.

Since:

3.0

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.
boolean	isLightJob() Returns if this job runs as a light job, see JetInstance.newLightJob(Pipeline).
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()
long	maxProcessorAccumulatedRecords() Returns the maximum number of records that can be accumulated by any single Processor.
int	memberCount() Returns the number of members running this job.
ProcessingGuarantee	processingGuarantee() Returns the guarantee for current job.
TestProcessorMetaSupplierContext	setExecutionId(long executionId) Sets the execution ID.
TestProcessorMetaSupplierContext	setIsLightJob(boolean isLightJob) Sets the isLightJob flag.
TestProcessorMetaSupplierContext	setJetInstance(JetInstance jetInstance) Sets the jet instance.
TestProcessorMetaSupplierContext	setJobConfig(JobConfig jobConfig) Sets the config for the job.
TestProcessorMetaSupplierContext	setJobId(long jobId) Sets the job ID.
TestProcessorMetaSupplierContext	setLocalParallelism(int localParallelism) Sets local parallelism.
TestProcessorMetaSupplierContext	setLogger(ILogger logger) Sets the logger.
void	setMaxProcessorAccumulatedRecords(long maxProcessorAccumulatedRecords)
TestProcessorMetaSupplierContext	setProcessingGuarantee(ProcessingGuarantee processingGuarantee) Sets the processing guarantee.
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

Methods inherited from interface com.hazelcast.jet.core.ProcessorMetaSupplier.Context

snapshottingEnabled

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 config for the job.

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()

processingGuarantee

public ProcessingGuarantee processingGuarantee()

Description copied from interface: ProcessorMetaSupplier.Context

Returns the guarantee for current job.

Specified by:

processingGuarantee in interface ProcessorMetaSupplier.Context

setProcessingGuarantee

@Nonnull
public TestProcessorMetaSupplierContext setProcessingGuarantee(@Nonnull
                                                                        ProcessingGuarantee processingGuarantee)

Sets the processing guarantee.

maxProcessorAccumulatedRecords

public long maxProcessorAccumulatedRecords()

Description copied from interface: ProcessorMetaSupplier.Context

Returns the maximum number of records that can be accumulated by any single Processor.

Specified by:

maxProcessorAccumulatedRecords in interface ProcessorMetaSupplier.Context

setMaxProcessorAccumulatedRecords

public void setMaxProcessorAccumulatedRecords(long maxProcessorAccumulatedRecords)

isLightJob

public boolean isLightJob()

Description copied from interface: ProcessorMetaSupplier.Context

Returns if this job runs as a light job, see JetInstance.newLightJob(Pipeline).

Specified by:

isLightJob in interface ProcessorMetaSupplier.Context

setIsLightJob

@Nonnull
public TestProcessorMetaSupplierContext setIsLightJob(boolean isLightJob)

Sets the isLightJob flag.