public class SetService extends CollectionService
Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME |
nodeEngine, partitionService, serializationService
Constructor and Description |
---|
SetService(NodeEngine nodeEngine) |
Modifier and Type | Method and Description |
---|---|
DistributedObject |
createDistributedObject(String objectId,
boolean local)
Creates a distributed object on the local member only (when
local is
true ), else cluster-wide. |
TransactionalSetProxy |
createTransactionalObject(String name,
Transaction transaction) |
void |
destroyDistributedObject(String name,
boolean local)
Destroys a distributed object.
|
ConcurrentMap<String,? extends CollectionContainer> |
getContainerMap() |
SetContainer |
getOrCreateContainer(String name,
boolean backup) |
String |
getServiceName() |
String |
getSplitBrainProtectionName(String name)
Gets the name of the split brain protection associated with specified operation name.
|
Operation |
prepareReplicationOperation(PartitionReplicationEvent event)
Returns an operation to replicate service data and/or state for a specific partition replica
on another cluster member.
|
addContainer, beforeMigration, commitMigration, dispatchEvent, getMigrationData, init, prepareMergeRunnable, reset, rollbackMigration, rollbackTransaction, shutdown
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createDistributedObject, destroyDistributedObject
public static final String SERVICE_NAME
public SetService(NodeEngine nodeEngine)
public SetContainer getOrCreateContainer(String name, boolean backup)
getOrCreateContainer
in class CollectionService
public ConcurrentMap<String,? extends CollectionContainer> getContainerMap()
getContainerMap
in class CollectionService
public String getServiceName()
getServiceName
in class CollectionService
public DistributedObject createDistributedObject(String objectId, boolean local)
RemoteService
local
is
true
), else cluster-wide.objectId
- the name for the created distributed objectlocal
- when true
then only perform required proxy creation
actions on the local member, otherwise perform cluster-wide
proxy creation.public void destroyDistributedObject(String name, boolean local)
RemoteService
destroyDistributedObject
in interface RemoteService
destroyDistributedObject
in class CollectionService
name
- the name of the distributed object to destroypublic TransactionalSetProxy createTransactionalObject(String name, Transaction transaction)
public Operation prepareReplicationOperation(PartitionReplicationEvent event)
MigrationAwareService
This method will be called on source member whenever partitioning system requires to copy/replicate a partition replica. Returned operation will be executed on destination member. If operation fails by throwing exception, migration process will fail and will be rolled back.
Returning null is allowed and means service does not have anything to replicate.
event
- replicationpublic String getSplitBrainProtectionName(String name)
SplitBrainProtectionAwareService
name
- the operation name for which the split brain protection name is returnedCopyright © 2019 Hazelcast, Inc.. All rights reserved.