public class TestProcessorMetaSupplierContext extends Object implements ProcessorMetaSupplier.Context
ProcessorMetaSupplier.Context
.Constructor and Description |
---|
TestProcessorMetaSupplierContext() |
Modifier and Type | Method and Description |
---|---|
JetInstance |
jetInstance()
Returns the current Jet instance.
|
int |
localParallelism()
Returns the number of processors that each
ProcessorSupplier
will be asked to create once deserialized on each member. |
com.hazelcast.logging.ILogger |
logger()
Returns a logger for the associated
ProcessorSupplier . |
TestProcessorMetaSupplierContext |
setJetInstance(JetInstance jetInstance)
Set the jet instance.
|
TestProcessorMetaSupplierContext |
setLocalParallelism(int localParallelism)
Set local parallelism.
|
TestProcessorMetaSupplierContext |
setTotalParallelism(int totalParallelism)
Set total parallelism.
|
int |
totalParallelism()
Returns the total number of
Processor s that will be
created across the cluster. |
@Nonnull public JetInstance jetInstance()
ProcessorMetaSupplier.Context
jetInstance
in interface ProcessorMetaSupplier.Context
public TestProcessorMetaSupplierContext setJetInstance(JetInstance jetInstance)
public int totalParallelism()
ProcessorMetaSupplier.Context
Processor
s that will be
created across the cluster.totalParallelism
in interface ProcessorMetaSupplier.Context
public TestProcessorMetaSupplierContext setTotalParallelism(int totalParallelism)
public int localParallelism()
ProcessorMetaSupplier.Context
ProcessorSupplier
will be asked to create once deserialized on each member.localParallelism
in interface ProcessorMetaSupplier.Context
@Nonnull public com.hazelcast.logging.ILogger logger()
ProcessorMetaSupplier.Context
ProcessorSupplier
.logger
in interface ProcessorMetaSupplier.Context
public TestProcessorMetaSupplierContext setLocalParallelism(int localParallelism)
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.