public class TestProcessorSupplierContext extends TestProcessorMetaSupplierContext implements ProcessorSupplier.Context
ProcessorSupplier.Context
implementation suitable to be used in tests.logger
Constructor and Description |
---|
TestProcessorSupplierContext() |
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.
|
executionId, jetInstance, jobConfig, jobId, localParallelism, logger, memberCount, setExecutionId, setJobConfig, setJobId, totalParallelism, vertexName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
logger
executionId, jetInstance, jobConfig, jobId, localParallelism, memberCount, totalParallelism, vertexName
@Nonnull public TestProcessorSupplierContext setLogger(@Nonnull ILogger logger)
TestProcessorMetaSupplierContext
setLogger
in class TestProcessorMetaSupplierContext
@Nonnull public TestProcessorSupplierContext setJetInstance(@Nonnull JetInstance jetInstance)
TestProcessorMetaSupplierContext
setJetInstance
in class TestProcessorMetaSupplierContext
@Nonnull public TestProcessorSupplierContext setVertexName(@Nonnull String vertexName)
TestProcessorMetaSupplierContext
setVertexName
in class TestProcessorMetaSupplierContext
@Nonnull public TestProcessorSupplierContext setTotalParallelism(int totalParallelism)
TestProcessorMetaSupplierContext
setTotalParallelism
in class TestProcessorMetaSupplierContext
@Nonnull public TestProcessorSupplierContext setLocalParallelism(int localParallelism)
TestProcessorMetaSupplierContext
setLocalParallelism
in class TestProcessorMetaSupplierContext
public int memberIndex()
ProcessorSupplier.Context
The value is in the range [0...memberCount-1]
.
memberIndex
in interface ProcessorSupplier.Context
public TestProcessorSupplierContext setMemberIndex(int memberIndex)
protected String loggerName()
loggerName
in class TestProcessorMetaSupplierContext
Copyright © 2018 Hazelcast, Inc.. All rights reserved.