com.hazelcast.jet.core.test

Class TestProcessorSupplierContext

java.lang.Object

com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

com.hazelcast.jet.core.test.TestProcessorSupplierContext

All Implemented Interfaces:

ProcessorMetaSupplier.Context, ProcessorSupplier.Context

Direct Known Subclasses:

TestProcessorContext

public class TestProcessorSupplierContext
extends TestProcessorMetaSupplierContext
implements ProcessorSupplier.Context

ProcessorSupplier.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
TestProcessorSupplierContext()

Method Summary

Modifier and Type	Method and Description
protected String	loggerName()
int	memberIndex() Returns the index of the member among all the members that run this job: it's a unique cluster-wide index.
TestProcessorSupplierContext	setJetInstance(JetInstance jetInstance) Sets the jet instance.
TestProcessorSupplierContext	setLocalParallelism(int localParallelism) Sets local parallelism.
TestProcessorSupplierContext	setLogger(ILogger logger) Sets the logger.
TestProcessorSupplierContext	setMemberIndex(int memberIndex) Set the member index.
TestProcessorSupplierContext	setTotalParallelism(int totalParallelism) Sets the total parallelism.
TestProcessorSupplierContext	setVertexName(String vertexName) Sets the vertex name.

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

executionId, jetInstance, jobConfig, jobId, localParallelism, logger, memberCount, setExecutionId, setJobConfig, setJobId, 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.ProcessorSupplier.Context

logger

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

executionId, jetInstance, jobConfig, jobId, localParallelism, memberCount, totalParallelism, vertexName

Constructor Detail

TestProcessorSupplierContext

public TestProcessorSupplierContext()

Method Detail

setLogger

@Nonnull
public TestProcessorSupplierContext setLogger(@Nonnull
                                                       ILogger logger)

Description copied from class: TestProcessorMetaSupplierContext

Sets the logger.

Overrides:

setLogger in class TestProcessorMetaSupplierContext

setJetInstance

@Nonnull
public TestProcessorSupplierContext setJetInstance(@Nonnull
                                                            JetInstance jetInstance)

Description copied from class: TestProcessorMetaSupplierContext

Sets the jet instance.

Overrides:

setJetInstance in class TestProcessorMetaSupplierContext

setVertexName

@Nonnull
public TestProcessorSupplierContext setVertexName(@Nonnull
                                                           String vertexName)

Description copied from class: TestProcessorMetaSupplierContext

Sets the vertex name.

Overrides:

setVertexName in class TestProcessorMetaSupplierContext

setTotalParallelism

@Nonnull
public TestProcessorSupplierContext setTotalParallelism(int totalParallelism)

Description copied from class: TestProcessorMetaSupplierContext

Sets the total parallelism.

Overrides:

setTotalParallelism in class TestProcessorMetaSupplierContext

setLocalParallelism

@Nonnull
public TestProcessorSupplierContext setLocalParallelism(int localParallelism)

Description copied from class: TestProcessorMetaSupplierContext

Sets local parallelism.

Overrides:

setLocalParallelism in class TestProcessorMetaSupplierContext

memberIndex

public int memberIndex()

Description copied from interface: ProcessorSupplier.Context

Returns the index of the member among all the members that run this job: it's a unique cluster-wide index.

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

Specified by:

memberIndex in interface ProcessorSupplier.Context

setMemberIndex

public TestProcessorSupplierContext setMemberIndex(int memberIndex)

Set the member index.

loggerName

protected String loggerName()

Overrides:

loggerName in class TestProcessorMetaSupplierContext