com.hazelcast.jet.core.test

Class TestProcessorContext

java.lang.Object

com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

com.hazelcast.jet.core.test.TestProcessorSupplierContext

com.hazelcast.jet.core.test.TestProcessorContext

All Implemented Interfaces:

Processor.Context, ProcessorMetaSupplier.Context, ProcessorSupplier.Context

public class TestProcessorContext
extends TestProcessorSupplierContext
implements Processor.Context

Processor.Context implementation suitable to be used in tests.

Since:

Jet 3.0

Field Summary

Fields inherited from class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

logger

Constructor Summary

Constructors

Constructor and Description
TestProcessorContext() Constructor with default values.

Method Summary

Modifier and Type	Method and Description
int	globalProcessorIndex() Returns the index of the processor among all the processors created for this vertex on all nodes: it's a unique cluster-wide index.
int	localProcessorIndex() Returns the index of the processor among all the processors created for this vertex on a single node: it's a unique node-wide index.
protected String	loggerName()
TestProcessorContext	setGlobalProcessorIndex(int globalProcessorIndex) Set the global processor index
TestProcessorContext	setHazelcastInstance(HazelcastInstance instance) Sets the Hazelcast instance.
TestProcessorContext	setIsLightJob(boolean isLightJob) Sets the isLightJob flag.
TestProcessorContext	setJobConfig(JobConfig jobConfig) Sets the config for the job.
TestProcessorContext	setLocalParallelism(int localParallelism) Sets local parallelism.
TestProcessorContext	setLocalProcessorIndex(int localProcessorIndex) Set the local processor index
TestProcessorContext	setLogger(ILogger logger) Sets the logger.
TestProcessorContext	setManagedContext(ManagedContext managedContext) Sets the ManagedContext
TestProcessorContext	setPartitionAssignment(Map<Address,int[]> partitionAssignment) Sets the partition assignment.
TestProcessorContext	setProcessingGuarantee(ProcessingGuarantee processingGuarantee) Sets the processing guarantee.
TestProcessorContext	setTotalParallelism(int totalParallelism) Sets the total parallelism.
TestProcessorContext	setVertexName(String vertexName) Sets the vertex name.

Methods inherited from class com.hazelcast.jet.core.test.TestProcessorSupplierContext

addFile, attachedDirectory, attachedFile, managedContext, memberIndex, recreateAttachedDirectory, recreateAttachedFile, setMemberIndex

Methods inherited from class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

classLoader, dataLinkService, executionId, hazelcastInstance, isLightJob, jetInstance, jobConfig, jobId, localParallelism, logger, maxProcessorAccumulatedRecords, memberCount, partitionAssignment, processingGuarantee, setClassLoader, setExecutionId, setJobId, setMaxProcessorAccumulatedRecords, totalParallelism, vertexName

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.Processor.Context

logger, processorPartitions

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

attachedDirectory, attachedFile, managedContext, memberIndex, memberPartitions, recreateAttachedDirectory, recreateAttachedFile

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

classLoader, dataLinkService, executionId, hazelcastInstance, isLightJob, jetInstance, jobConfig, jobId, localParallelism, maxProcessorAccumulatedRecords, memberCount, partitionAssignment, processingGuarantee, snapshottingEnabled, totalParallelism, vertexName

Constructor Detail

TestProcessorContext

public TestProcessorContext()

Constructor with default values.

Method Detail

localProcessorIndex

public int localProcessorIndex()

Description copied from interface: Processor.Context

Returns the index of the processor among all the processors created for this vertex on a single node: it's a unique node-wide index.

The value is in the range [0...localParallelism-1].

Specified by:

localProcessorIndex in interface Processor.Context

globalProcessorIndex

public int globalProcessorIndex()

Description copied from interface: Processor.Context

Returns the index of the processor among all the processors created for this vertex on all nodes: it's a unique cluster-wide index.

The value is in the range [0...totalParallelism-1]. For example if there are 2 members in the cluster and local parallelism is 4, the processors on the 1st cluster member will have indexes 0..3 and on the second member they will have indexes 4..7.

Specified by:

globalProcessorIndex in interface Processor.Context

setLocalProcessorIndex

public TestProcessorContext setLocalProcessorIndex(int localProcessorIndex)

Set the local processor index

setGlobalProcessorIndex

public TestProcessorContext setGlobalProcessorIndex(int globalProcessorIndex)

Set the global processor index

setLogger

@Nonnull
public TestProcessorContext setLogger(@Nonnull
                                               ILogger logger)

Description copied from class: TestProcessorMetaSupplierContext

Sets the logger.

Overrides:

setLogger in class TestProcessorSupplierContext

setHazelcastInstance

@Nonnull
public TestProcessorContext setHazelcastInstance(@Nonnull
                                                          HazelcastInstance instance)

Description copied from class: TestProcessorMetaSupplierContext

Sets the Hazelcast instance.

Overrides:

setHazelcastInstance in class TestProcessorSupplierContext

setJobConfig

@Nonnull
public TestProcessorContext setJobConfig(@Nonnull
                                                  JobConfig jobConfig)

Description copied from class: TestProcessorMetaSupplierContext

Sets the config for the job.

Overrides:

setJobConfig in class TestProcessorSupplierContext

setTotalParallelism

@Nonnull
public TestProcessorContext setTotalParallelism(int totalParallelism)

Description copied from class: TestProcessorMetaSupplierContext

Sets the total parallelism.

Overrides:

setTotalParallelism in class TestProcessorSupplierContext

setLocalParallelism

@Nonnull
public TestProcessorContext setLocalParallelism(int localParallelism)

Description copied from class: TestProcessorMetaSupplierContext

Sets local parallelism.

Overrides:

setLocalParallelism in class TestProcessorSupplierContext

setVertexName

@Nonnull
public TestProcessorContext setVertexName(@Nonnull
                                                   String vertexName)

Description copied from class: TestProcessorMetaSupplierContext

Sets the vertex name.

Overrides:

setVertexName in class TestProcessorSupplierContext

setProcessingGuarantee

@Nonnull
public TestProcessorContext setProcessingGuarantee(@Nonnull
                                                            ProcessingGuarantee processingGuarantee)

Description copied from class: TestProcessorMetaSupplierContext

Sets the processing guarantee.

Overrides:

setProcessingGuarantee in class TestProcessorSupplierContext

setIsLightJob

@Nonnull
public TestProcessorContext setIsLightJob(boolean isLightJob)

Description copied from class: TestProcessorMetaSupplierContext

Sets the isLightJob flag.

Overrides:

setIsLightJob in class TestProcessorSupplierContext

setPartitionAssignment

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

Description copied from class: TestProcessorMetaSupplierContext

Sets the partition assignment.

Overrides:

setPartitionAssignment in class TestProcessorSupplierContext

setManagedContext

@Nonnull
public TestProcessorContext setManagedContext(@Nonnull
                                                       ManagedContext managedContext)

Description copied from class: TestProcessorSupplierContext

Sets the ManagedContext

Overrides:

setManagedContext in class TestProcessorSupplierContext

loggerName

protected String loggerName()

Overrides:

loggerName in class TestProcessorSupplierContext