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.

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: its unique cluster-wide index.
protected String	loggerName()
ProcessingGuarantee	processingGuarantee() Returns the guarantee for current job.
TestProcessorContext	setGlobalProcessorIndex(int globalProcessorIndex) Set the global processor index
TestProcessorContext	setJetInstance(JetInstance jetInstance) Set the jet instance.
TestProcessorContext	setLocalParallelism(int localParallelism) Set local parallelism.
TestProcessorContext	setLogger(ILogger logger) Set the logger.
TestProcessorContext	setProcessingGuarantee(ProcessingGuarantee processingGuarantee) Sets the processing guarantee.
TestProcessorContext	setTotalParallelism(int totalParallelism) Set total parallelism.
TestProcessorContext	setVertexName(String vertexName) Set the vertex name.

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

jetInstance, localParallelism, logger, 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, snapshottingEnabled

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

jetInstance, localParallelism, totalParallelism, vertexName

Constructor Detail

TestProcessorContext

public TestProcessorContext()

Constructor with default values.

Method Detail

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: its unique cluster-wide index.

The index values will be in the range of [0...totalParallelism-1].

Specified by:

globalProcessorIndex in interface Processor.Context

setGlobalProcessorIndex

public TestProcessorContext setGlobalProcessorIndex(int globalProcessorIndex)

Set the global processor index

processingGuarantee

public ProcessingGuarantee processingGuarantee()

Description copied from interface: Processor.Context

Returns the guarantee for current job.

Specified by:

processingGuarantee in interface Processor.Context

setProcessingGuarantee

@Nonnull
public TestProcessorContext setProcessingGuarantee(ProcessingGuarantee processingGuarantee)

Sets the processing guarantee.

setLogger

@Nonnull
public TestProcessorContext setLogger(@Nonnull
                                               ILogger logger)

Description copied from class: TestProcessorMetaSupplierContext

Set the logger.

Overrides:

setLogger in class TestProcessorSupplierContext

setJetInstance

@Nonnull
public TestProcessorContext setJetInstance(@Nonnull
                                                    JetInstance jetInstance)

Description copied from class: TestProcessorMetaSupplierContext

Set the jet instance.

Overrides:

setJetInstance in class TestProcessorSupplierContext

setTotalParallelism

@Nonnull
public TestProcessorContext setTotalParallelism(int totalParallelism)

Description copied from class: TestProcessorMetaSupplierContext

Set total parallelism.

Overrides:

setTotalParallelism in class TestProcessorSupplierContext

setLocalParallelism

@Nonnull
public TestProcessorContext setLocalParallelism(int localParallelism)

Description copied from class: TestProcessorMetaSupplierContext

Set local parallelism.

Overrides:

setLocalParallelism in class TestProcessorSupplierContext

setVertexName

@Nonnull
public TestProcessorContext setVertexName(@Nonnull
                                                   String vertexName)

Description copied from class: TestProcessorMetaSupplierContext

Set the vertex name.

Overrides:

setVertexName in class TestProcessorSupplierContext

loggerName

protected String loggerName()

Overrides:

loggerName in class TestProcessorSupplierContext