public class TestProcessorMetaSupplierContext extends Object implements ProcessorMetaSupplier.Context
ProcessorMetaSupplier.Context
implementation suitable to be used
in tests.Constructor and Description |
---|
TestProcessorMetaSupplierContext() |
Modifier and Type | Method and Description |
---|---|
long |
executionId()
Returns the job execution ID.
|
JetInstance |
jetInstance()
Returns the current Jet instance.
|
JobConfig |
jobConfig()
Returns the
JobConfig . |
long |
jobId()
Returns the job ID.
|
int |
localParallelism()
Returns the number of processors that each
ProcessorSupplier
will be asked to create once deserialized on each member. |
ILogger |
logger()
Returns a logger for the associated
ProcessorMetaSupplier . |
protected String |
loggerName() |
int |
memberCount()
Returns the number of members running this job.
|
TestProcessorMetaSupplierContext |
setExecutionId(long executionId)
Sets the execution ID.
|
TestProcessorMetaSupplierContext |
setJetInstance(JetInstance jetInstance)
Sets the jet instance.
|
TestProcessorMetaSupplierContext |
setJobConfig(JobConfig jobConfig)
Sets the job name.
|
TestProcessorMetaSupplierContext |
setJobId(long jobId)
Sets the job ID.
|
TestProcessorMetaSupplierContext |
setLocalParallelism(int localParallelism)
Sets local parallelism.
|
TestProcessorMetaSupplierContext |
setLogger(ILogger logger)
Sets the logger.
|
TestProcessorMetaSupplierContext |
setTotalParallelism(int totalParallelism)
Sets the total parallelism.
|
TestProcessorMetaSupplierContext |
setVertexName(String vertexName)
Sets the vertex name.
|
int |
totalParallelism()
Returns the total number of
Processor s that will be created
across the cluster. |
String |
vertexName()
Returns the name of the associated vertex.
|
protected ILogger logger
@Nonnull public JetInstance jetInstance()
ProcessorMetaSupplier.Context
jetInstance
in interface ProcessorMetaSupplier.Context
@Nonnull public TestProcessorMetaSupplierContext setJetInstance(@Nonnull JetInstance jetInstance)
public long jobId()
ProcessorMetaSupplier.Context
jobId
in interface ProcessorMetaSupplier.Context
public TestProcessorMetaSupplierContext setJobId(long jobId)
public long executionId()
ProcessorMetaSupplier.Context
executionId
in interface ProcessorMetaSupplier.Context
public TestProcessorMetaSupplierContext setExecutionId(long executionId)
@Nonnull public JobConfig jobConfig()
ProcessorMetaSupplier.Context
JobConfig
.jobConfig
in interface ProcessorMetaSupplier.Context
public TestProcessorMetaSupplierContext setJobConfig(@Nonnull JobConfig jobConfig)
public int totalParallelism()
ProcessorMetaSupplier.Context
Processor
s that will be created
across the cluster. This number remains stable for entire job
execution. It is equal to ProcessorMetaSupplier.Context.memberCount()
* ProcessorMetaSupplier.Context.localParallelism()
.totalParallelism
in interface ProcessorMetaSupplier.Context
@Nonnull public TestProcessorMetaSupplierContext setTotalParallelism(int totalParallelism)
public int localParallelism()
ProcessorMetaSupplier.Context
ProcessorSupplier
will be asked to create once deserialized on each member. All
members have equal local parallelism. The count doesn't change
unless the job restarts.localParallelism
in interface ProcessorMetaSupplier.Context
@Nonnull public TestProcessorMetaSupplierContext setLocalParallelism(int localParallelism)
@Nonnull public ILogger logger()
ProcessorMetaSupplier.Context
ProcessorMetaSupplier
.logger
in interface ProcessorMetaSupplier.Context
public TestProcessorMetaSupplierContext setLogger(@Nonnull ILogger logger)
public int memberCount()
ProcessorMetaSupplier.Context
Note that the value might be lower than current member count if members were added after the job started. The count doesn't change unless the job restarts.
memberCount
in interface ProcessorMetaSupplier.Context
@Nonnull public String vertexName()
ProcessorMetaSupplier.Context
vertexName
in interface ProcessorMetaSupplier.Context
@Nonnull public TestProcessorMetaSupplierContext setVertexName(@Nonnull String vertexName)
protected String loggerName()
Copyright © 2018 Hazelcast, Inc.. All rights reserved.