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:

Jet 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
ClassLoader	classLoader() Processor classloader configured via JobConfig.addCustomClasspath(String, String)
long	executionId() Returns the job execution ID.
HazelcastInstance	hazelcastInstance() Returns the current Hazelcast instance.
boolean	isLightJob() Returns if this job runs as a light job, see JetService.newLightJob(Pipeline).
JetInstance	jetInstance() Deprecated.
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.
Map<Address,int[]>	partitionAssignment() Returns the partition assignment used by this job.
ProcessingGuarantee	processingGuarantee() Returns the guarantee for current job.
TestProcessorMetaSupplierContext	setClassLoader(ClassLoader classLoader)
TestProcessorMetaSupplierContext	setExecutionId(long executionId) Sets the execution ID.
TestProcessorMetaSupplierContext	setHazelcastInstance(HazelcastInstance instance) Sets the Hazelcast instance.
TestProcessorMetaSupplierContext	setIsLightJob(boolean isLightJob) Sets the isLightJob flag.
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	setPartitionAssignment(Map<Address,int[]> partitionAssignment) Sets the partition assignment.
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

hazelcastInstance

@Nonnull
public HazelcastInstance hazelcastInstance()

Description copied from interface: ProcessorMetaSupplier.Context

Returns the current Hazelcast instance.

Specified by:

hazelcastInstance in interface ProcessorMetaSupplier.Context

jetInstance

@Nonnull
 @Deprecated
public JetInstance jetInstance()

Deprecated.

Description copied from interface: ProcessorMetaSupplier.Context

Returns the current Jet instance.

Specified by:

jetInstance in interface ProcessorMetaSupplier.Context

setHazelcastInstance

@Nonnull
public TestProcessorMetaSupplierContext setHazelcastInstance(@Nonnull
                                                                      HazelcastInstance instance)

Sets the Hazelcast 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 JetService.newLightJob(Pipeline).

Specified by:

isLightJob in interface ProcessorMetaSupplier.Context

setIsLightJob

@Nonnull
public TestProcessorMetaSupplierContext setIsLightJob(boolean isLightJob)

Sets the isLightJob flag.

partitionAssignment

public Map<Address,int[]> partitionAssignment()

Description copied from interface: ProcessorMetaSupplier.Context

Returns the partition assignment used by this job. This is the assignment partitioned edges will use and the assignment processors dealing with Hazelcast data structures should use.

Specified by:

partitionAssignment in interface ProcessorMetaSupplier.Context

setPartitionAssignment

@Nonnull
public TestProcessorMetaSupplierContext setPartitionAssignment(Map<Address,int[]> partitionAssignment)

Sets the partition assignment.

classLoader

public ClassLoader classLoader()

Description copied from interface: ProcessorMetaSupplier.Context

Processor classloader configured via JobConfig.addCustomClasspath(String, String)

Specified by:

classLoader in interface ProcessorMetaSupplier.Context

Returns:

processor classloader, null if no custom classpath elements are configured

setClassLoader

@Nonnull
public TestProcessorMetaSupplierContext setClassLoader(ClassLoader classLoader)