com.orientechnologies.orient.server.distributed.conflict

Class OQuorumDistributedConflictResolver

java.lang.Object

com.orientechnologies.orient.server.distributed.conflict.OAbstractDistributedConflictResolver

com.orientechnologies.orient.server.distributed.conflict.OQuorumDistributedConflictResolver

All Implemented Interfaces:

ODistributedConflictResolver

public class OQuorumDistributedConflictResolver
extends OAbstractDistributedConflictResolver

Conflict resolver implementation based on the write quorum of results. If there is no quorum, no operation is executed.

Author:

Luca Garulli

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.server.distributed.conflict.ODistributedConflictResolver

ODistributedConflictResolver.OConflictResult

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAME

Fields inherited from class com.orientechnologies.orient.server.distributed.conflict.OAbstractDistributedConflictResolver

configuration

Fields inherited from interface com.orientechnologies.orient.server.distributed.conflict.ODistributedConflictResolver

NOT_FOUND

Constructor Summary

Constructors

Constructor and Description
OQuorumDistributedConflictResolver()

Method Summary

Modifier and Type	Method and Description
String	getName() Name to register in the factory.
ODistributedConflictResolver.OConflictResult	onConflict(String databaseName, String clusterName, ORecordId rid, ODistributedServerManager dManager, Map<Object,List<String>> candidates) Called on distributed conflict.

Methods inherited from class com.orientechnologies.orient.server.distributed.conflict.OAbstractDistributedConflictResolver

compareRecords, configure, getBestResult

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

NAME

public static final String NAME

See Also:

Constant Field Values

Constructor Detail

OQuorumDistributedConflictResolver

public OQuorumDistributedConflictResolver()

Method Detail

onConflict

public ODistributedConflictResolver.OConflictResult onConflict(String databaseName,
                                                               String clusterName,
                                                               ORecordId rid,
                                                               ODistributedServerManager dManager,
                                                               Map<Object,List<String>> candidates)

Description copied from interface: ODistributedConflictResolver

Called on distributed conflict. It is responsible to resolve the conflicts by providing the winning result. If it's not able to do that, NULL is returned.

rid - RecordID of the record in conflict

dManager - Current distributed manager instance

candidates - All the values from the servers grouped by value. The key could also be an exception in case the record was not found. @return The winning object

Returns:

The winning result object

getName

public String getName()

Description copied from interface: ODistributedConflictResolver

Name to register in the factory.