public class DurableExecutorConfig extends Object implements IdentifiedDataSerializable, com.hazelcast.nio.serialization.impl.Versioned
DurableExecutorService
.Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_DURABILITY
Durability of Executor.
|
static int |
DEFAULT_POOL_SIZE
The number of executor threads per Member for the Executor based on this configuration.
|
static int |
DEFAULT_RING_BUFFER_CAPACITY
Capacity of RingBuffer (per partition).
|
Constructor and Description |
---|
DurableExecutorConfig() |
DurableExecutorConfig(DurableExecutorConfig config) |
DurableExecutorConfig(String name) |
DurableExecutorConfig(String name,
int poolSize,
int durability,
int capacity) |
DurableExecutorConfig(String name,
int poolSize,
int durability,
int capacity,
String quorumName) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
getCapacity()
Gets the ring buffer capacity of the executor task.
|
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.
|
String |
getName()
Gets the name of the executor task.
|
int |
getPoolSize()
Gets the number of executor threads per member for the executor.
|
String |
getQuorumName()
Returns the quorum name for operations.
|
int |
hashCode() |
void |
readData(ObjectDataInput in)
Reads fields from the input stream
|
DurableExecutorConfig |
setCapacity(int capacity)
Sets the ring buffer capacity of the executor task.
|
DurableExecutorConfig |
setDurability(int durability)
Sets the durability of the executor
|
DurableExecutorConfig |
setName(String name)
Sets the name of the executor task.
|
DurableExecutorConfig |
setPoolSize(int poolSize)
Sets the number of executor threads per member for the executor.
|
DurableExecutorConfig |
setQuorumName(String quorumName)
Sets the quorum name for operations.
|
String |
toString() |
void |
writeData(ObjectDataOutput out)
Writes object fields to output stream
|
public static final int DEFAULT_POOL_SIZE
public static final int DEFAULT_RING_BUFFER_CAPACITY
public static final int DEFAULT_DURABILITY
public DurableExecutorConfig()
public DurableExecutorConfig(String name)
public DurableExecutorConfig(String name, int poolSize, int durability, int capacity)
public DurableExecutorConfig(String name, int poolSize, int durability, int capacity, String quorumName)
public DurableExecutorConfig(DurableExecutorConfig config)
public String getName()
public DurableExecutorConfig setName(String name)
name
- the name of the executor taskpublic int getPoolSize()
public DurableExecutorConfig setPoolSize(int poolSize)
poolSize
- the number of executor threads per member for the executorpublic int getDurability()
public DurableExecutorConfig setDurability(int durability)
durability
- the durability of the executorpublic int getCapacity()
public DurableExecutorConfig setCapacity(int capacity)
capacity
- Ring Buffer capacity of the executor taskpublic String getQuorumName()
public DurableExecutorConfig setQuorumName(String quorumName)
quorumName
- the quorum namepublic 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.