public class ScheduledExecutorConfig extends Object implements SplitBrainMergeTypeProvider, IdentifiedDataSerializable, com.hazelcast.nio.serialization.impl.Versioned
IScheduledExecutorService
.Constructor and Description |
---|
ScheduledExecutorConfig() |
ScheduledExecutorConfig(ScheduledExecutorConfig config) |
ScheduledExecutorConfig(String name) |
ScheduledExecutorConfig(String name,
int durability,
int capacity,
int poolSize) |
ScheduledExecutorConfig(String name,
int durability,
int capacity,
int poolSize,
String quorumName,
MergePolicyConfig mergePolicyConfig) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
getCapacity()
Gets the capacity of the executor
|
int |
getDurability()
Gets the durability of the executor
|
int |
getFactoryId()
Returns DataSerializableFactory factory ID for this class.
|
int |
getId()
Returns type identifier for this class.
|
MergePolicyConfig |
getMergePolicyConfig()
Gets the
MergePolicyConfig for the scheduler. |
String |
getName()
Gets the name of the executor task.
|
int |
getPoolSize()
Gets the number of executor threads per member for the executor.
|
Class |
getProvidedMergeTypes() |
String |
getQuorumName()
Returns the quorum name for operations.
|
int |
hashCode() |
void |
readData(ObjectDataInput in)
Reads fields from the input stream
|
ScheduledExecutorConfig |
setCapacity(int capacity)
Sets the capacity of the executor
The capacity represents the maximum number of tasks that a scheduler can have at any given point in time per partition.
|
ScheduledExecutorConfig |
setDurability(int durability)
Sets the durability of the executor
The durability represents the number of replicas that exist in a cluster for any given partition-owned task.
|
ScheduledExecutorConfig |
setMergePolicyConfig(MergePolicyConfig mergePolicyConfig)
Sets the
MergePolicyConfig for the scheduler. |
ScheduledExecutorConfig |
setName(String name)
Sets the name of the executor task.
|
ScheduledExecutorConfig |
setPoolSize(int poolSize)
Sets the number of executor threads per member for the executor.
|
ScheduledExecutorConfig |
setQuorumName(String quorumName)
Sets the quorum name for operations.
|
String |
toString() |
void |
writeData(ObjectDataOutput out)
Writes object fields to output stream
|
public ScheduledExecutorConfig()
public ScheduledExecutorConfig(String name)
public ScheduledExecutorConfig(String name, int durability, int capacity, int poolSize)
public ScheduledExecutorConfig(String name, int durability, int capacity, int poolSize, String quorumName, MergePolicyConfig mergePolicyConfig)
public ScheduledExecutorConfig(ScheduledExecutorConfig config)
public String getName()
public ScheduledExecutorConfig setName(String name)
name
- the name of the executor taskpublic int getPoolSize()
public ScheduledExecutorConfig setPoolSize(int poolSize)
poolSize
- the number of executor threads per member for the executorpublic int getDurability()
public ScheduledExecutorConfig setDurability(int durability)
durability
- the durability of the executorpublic int getCapacity()
public ScheduledExecutorConfig setCapacity(int capacity)
capacity
- the capacity of the executorpublic String getQuorumName()
public ScheduledExecutorConfig setQuorumName(String quorumName)
quorumName
- the quorum namepublic MergePolicyConfig getMergePolicyConfig()
MergePolicyConfig
for the scheduler.MergePolicyConfig
for the schedulerpublic ScheduledExecutorConfig setMergePolicyConfig(MergePolicyConfig mergePolicyConfig)
MergePolicyConfig
for the scheduler.public Class getProvidedMergeTypes()
getProvidedMergeTypes
in interface SplitBrainMergeTypeProvider
public int getFactoryId()
IdentifiedDataSerializable
getFactoryId
in interface IdentifiedDataSerializable
public int getId()
IdentifiedDataSerializable
getId
in interface IdentifiedDataSerializable
public void writeData(ObjectDataOutput out) throws IOException
DataSerializable
writeData
in interface DataSerializable
out
- outputIOException
- if an I/O error occurs. In particular,
an IOException
may be thrown if the
output stream has been closed.public void readData(ObjectDataInput in) throws IOException
DataSerializable
readData
in interface DataSerializable
in
- inputIOException
- if an I/O error occurs. In particular,
an IOException
may be thrown if the
input stream has been closed.Copyright © 2018 Hazelcast, Inc.. All rights reserved.