public class TestProcessorContext extends TestProcessorSupplierContext implements Processor.Context
Processor.Context
implementation suitable to be used in tests.logger
Constructor and Description |
---|
TestProcessorContext()
Constructor with default values.
|
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() |
ProcessingGuarantee |
processingGuarantee()
Returns the guarantee for current job.
|
TestProcessorContext |
setGlobalProcessorIndex(int globalProcessorIndex)
Set the global processor index
|
TestProcessorContext |
setJetInstance(JetInstance jetInstance)
Sets the jet instance.
|
TestProcessorContext |
setLocalParallelism(int localParallelism)
Sets local parallelism.
|
TestProcessorContext |
setLocalProcessorIndex(int localProcessorIndex)
Set the local processor index
|
TestProcessorContext |
setLogger(ILogger logger)
Sets the logger.
|
TestProcessorContext |
setProcessingGuarantee(ProcessingGuarantee processingGuarantee)
Sets the processing guarantee.
|
TestProcessorContext |
setTotalParallelism(int totalParallelism)
Sets the total parallelism.
|
TestProcessorContext |
setVertexName(String vertexName)
Sets the vertex name.
|
memberIndex, setMemberIndex
executionId, jetInstance, jobConfig, jobId, localParallelism, logger, memberCount, setExecutionId, setJobConfig, setJobId, totalParallelism, vertexName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
logger, snapshottingEnabled
memberIndex
executionId, jetInstance, jobConfig, jobId, localParallelism, memberCount, totalParallelism, vertexName
public TestProcessorContext()
public int localProcessorIndex()
Processor.Context
The value is in the range [0...localParallelism-1]
.
localProcessorIndex
in interface Processor.Context
public int globalProcessorIndex()
Processor.Context
The value is in the range [0...totalParallelism-1]
.
globalProcessorIndex
in interface Processor.Context
public TestProcessorContext setLocalProcessorIndex(int localProcessorIndex)
public TestProcessorContext setGlobalProcessorIndex(int globalProcessorIndex)
public ProcessingGuarantee processingGuarantee()
Processor.Context
processingGuarantee
in interface Processor.Context
@Nonnull public TestProcessorContext setProcessingGuarantee(ProcessingGuarantee processingGuarantee)
@Nonnull public TestProcessorContext setLogger(@Nonnull ILogger logger)
TestProcessorMetaSupplierContext
setLogger
in class TestProcessorSupplierContext
@Nonnull public TestProcessorContext setJetInstance(@Nonnull JetInstance jetInstance)
TestProcessorMetaSupplierContext
setJetInstance
in class TestProcessorSupplierContext
@Nonnull public TestProcessorContext setTotalParallelism(int totalParallelism)
TestProcessorMetaSupplierContext
setTotalParallelism
in class TestProcessorSupplierContext
@Nonnull public TestProcessorContext setLocalParallelism(int localParallelism)
TestProcessorMetaSupplierContext
setLocalParallelism
in class TestProcessorSupplierContext
@Nonnull public TestProcessorContext setVertexName(@Nonnull String vertexName)
TestProcessorMetaSupplierContext
setVertexName
in class TestProcessorSupplierContext
protected String loggerName()
loggerName
in class TestProcessorSupplierContext
Copyright © 2018 Hazelcast, Inc.. All rights reserved.