Package com.hazelcast.config
Class ScheduledExecutorConfig
java.lang.Object
com.hazelcast.config.ScheduledExecutorConfig
- All Implemented Interfaces:
NamedConfig
,UserCodeNamespaceAwareConfig<ScheduledExecutorConfig>
,DataSerializable
,IdentifiedDataSerializable
,com.hazelcast.nio.serialization.impl.Versioned
public class ScheduledExecutorConfig
extends Object
implements IdentifiedDataSerializable, NamedConfig, com.hazelcast.nio.serialization.impl.Versioned, UserCodeNamespaceAwareConfig<ScheduledExecutorConfig>
Configuration options for the
IScheduledExecutorService
.-
Nested Class Summary
Modifier and TypeClassDescriptionstatic enum
Capacity policy options -
Field Summary
Fields inherited from interface com.hazelcast.config.UserCodeNamespaceAwareConfig
DEFAULT_NAMESPACE
-
Constructor Summary
ConstructorDescriptionScheduledExecutorConfig
(String name, int durability, int capacity, int poolSize, boolean statisticsEnabled, String userCodeNamespace) ScheduledExecutorConfig
(String name, int durability, int capacity, int poolSize, String splitBrainProtectionName, MergePolicyConfig mergePolicyConfig, ScheduledExecutorConfig.CapacityPolicy capacityPolicy, boolean statisticsEnabled, String userCodeNamespace) -
Method Summary
Modifier and TypeMethodDescriptionfinal boolean
int
Gets the capacity of the executorint
Returns type identifier for this class.int
Gets the durability of the executorint
Returns DataSerializableFactory factory ID for this class.Gets theMergePolicyConfig
for the scheduler.getName()
Gets the name of the executor task.int
Gets the number of executor threads per member for the executor.Returns the split brain protection name for operations.Retrieve the User Code Deployment Namespace to be used forClassLoader
awareness during operations related to the structure associated with this configuration.final int
hashCode()
boolean
void
Reads fields from the input streamsetCapacity
(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 or per node according to the capacity policy.setCapacityPolicy
(ScheduledExecutorConfig.CapacityPolicy capacityPolicy) Set the capacity policy for the configured capacity valuesetDurability
(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.setMergePolicyConfig
(MergePolicyConfig mergePolicyConfig) Sets theMergePolicyConfig
for the scheduler.Sets the name of the executor task.setPoolSize
(int poolSize) Sets the number of executor threads per member for the executor.setSplitBrainProtectionName
(String splitBrainProtectionName) Sets the split brain protection name for operations.setStatisticsEnabled
(boolean statisticsEnabled) Enables or disables statistics gathering on the executor task.setUserCodeNamespace
(String userCodeNamespace) Associates the provided Namespace Name with this structure forClassLoader
awareness.toString()
void
Writes object fields to output stream
-
Constructor Details
-
ScheduledExecutorConfig
public ScheduledExecutorConfig() -
ScheduledExecutorConfig
-
ScheduledExecutorConfig
-
ScheduledExecutorConfig
public ScheduledExecutorConfig(String name, int durability, int capacity, int poolSize, String splitBrainProtectionName, MergePolicyConfig mergePolicyConfig, ScheduledExecutorConfig.CapacityPolicy capacityPolicy, boolean statisticsEnabled, @Nullable String userCodeNamespace) -
ScheduledExecutorConfig
-
-
Method Details
-
getName
Gets the name of the executor task.- Specified by:
getName
in interfaceNamedConfig
- Returns:
- the name of the executor task
-
setName
Sets the name of the executor task.- Specified by:
setName
in interfaceNamedConfig
- Parameters:
name
- the name of the executor task- Returns:
- this executor config instance
-
getPoolSize
public int getPoolSize()Gets the number of executor threads per member for the executor.- Returns:
- the number of executor threads per member for the executor
-
setPoolSize
Sets the number of executor threads per member for the executor.- Parameters:
poolSize
- the number of executor threads per member for the executor- Returns:
- this executor config instance
-
getDurability
public int getDurability()Gets the durability of the executor- Returns:
- the durability of the executor
-
setDurability
Sets the durability of the executor The durability represents the number of replicas that exist in a cluster for any given partition-owned task. If this is set to 0 then there is only 1 copy of the task in the cluster, meaning that if the partition owning it, goes down then the task is lost.- Parameters:
durability
- the durability of the executor- Returns:
- this executor config instance
-
getCapacity
public int getCapacity()Gets the capacity of the executor- Returns:
- the capacity of the executor
-
setCapacity
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 or per node according to the capacity policy. If this is set to 0 then there is no limitTo prevent any undesirable data-loss, capacity is ignored during partition migrations, the count is updated accordingly, however the rejection is not enforced.
- Parameters:
capacity
- the capacity of the executor- Returns:
- this executor config instance
-
getCapacityPolicy
- Returns:
- the policy of the capacity setting
-
setCapacityPolicy
public ScheduledExecutorConfig setCapacityPolicy(@Nonnull ScheduledExecutorConfig.CapacityPolicy capacityPolicy) Set the capacity policy for the configured capacity valueTo prevent any undesirable data-loss, capacity is ignored during partition migrations, the count is updated accordingly, however the rejection is not enforced.
- Parameters:
capacityPolicy
-
-
getSplitBrainProtectionName
Returns the split brain protection name for operations.- Returns:
- the split brain protection name
-
setSplitBrainProtectionName
Sets the split brain protection name for operations.- Parameters:
splitBrainProtectionName
- the split brain protection name- Returns:
- the updated configuration
-
getMergePolicyConfig
Gets theMergePolicyConfig
for the scheduler.- Returns:
- the
MergePolicyConfig
for the scheduler
-
setMergePolicyConfig
Sets theMergePolicyConfig
for the scheduler.- Returns:
- this executor config instance
-
isStatisticsEnabled
public boolean isStatisticsEnabled()- Returns:
true
if statistics gathering is enabled on the executor task (default),false
otherwise
-
setStatisticsEnabled
Enables or disables statistics gathering on the executor task.- Parameters:
statisticsEnabled
-true
if statistics gathering is enabled on the executor task,false
otherwise @return this executor config instance
-
getUserCodeNamespace
Retrieve the User Code Deployment Namespace to be used forClassLoader
awareness during operations related to the structure associated with this configuration.- Specified by:
getUserCodeNamespace
in interfaceUserCodeNamespaceAwareConfig<ScheduledExecutorConfig>
- Returns:
- Namespace Name for use with the
UserCodeNamespaceService
, ornull
if there is no User Code Namespace to associate with.
-
setUserCodeNamespace
Associates the provided Namespace Name with this structure forClassLoader
awareness.The behaviour of setting this to
null
is outlined in the documentation forUserCodeNamespaceAwareConfig.DEFAULT_NAMESPACE
.- Specified by:
setUserCodeNamespace
in interfaceUserCodeNamespaceAwareConfig<ScheduledExecutorConfig>
- Parameters:
userCodeNamespace
- The ID of the Namespace to associate with this structure.- Returns:
- the updated
ScheduledExecutorConfig
instance - Since:
- 5.4
-
toString
-
getFactoryId
public int getFactoryId()Description copied from interface:IdentifiedDataSerializable
Returns DataSerializableFactory factory ID for this class.- Specified by:
getFactoryId
in interfaceIdentifiedDataSerializable
- Returns:
- factory ID
-
getClassId
public int getClassId()Description copied from interface:IdentifiedDataSerializable
Returns type identifier for this class. It should be unique per DataSerializableFactory.- Specified by:
getClassId
in interfaceIdentifiedDataSerializable
- Returns:
- type ID
-
writeData
Description copied from interface:DataSerializable
Writes object fields to output stream- Specified by:
writeData
in interfaceDataSerializable
- Parameters:
out
- output- Throws:
IOException
- if an I/O error occurs. In particular, anIOException
may be thrown if the output stream has been closed.
-
readData
Description copied from interface:DataSerializable
Reads fields from the input stream- Specified by:
readData
in interfaceDataSerializable
- Parameters:
in
- input- Throws:
IOException
- if an I/O error occurs. In particular, anIOException
may be thrown if the input stream has been closed.
-
equals
-
hashCode
public final int hashCode()
-