Package com.orientechnologies.orient.core.command

Interface OCommandDistributedReplicateRequest

public interface OCommandDistributedReplicateRequest

Interface to know if the command must be distributed in clustered scenario.

Author:

Luca Garulli

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	OCommandDistributedReplicateRequest.DISTRIBUTED_EXECUTION_MODE
static enum	OCommandDistributedReplicateRequest.DISTRIBUTED_RESULT_MGMT
static enum	OCommandDistributedReplicateRequest.QUORUM_TYPE

Method Summary

Modifier and Type	Method	Description
OCommandDistributedReplicateRequest.DISTRIBUTED_EXECUTION_MODE	getDistributedExecutionMode()	Returns the execution mode when distributed configuration is active: LOCAL: executed on local node only REPLICATE: executed on all the nodes and expect the same result SHARDED: executed on all the involved nodes and merge results
OCommandDistributedReplicateRequest.DISTRIBUTED_RESULT_MGMT	getDistributedResultManagement()	Returns how to manage the distributed result between: CHECK_FOR_EQUALS: all results must be the same MERGE: merges results.
long	getDistributedTimeout()	Returns the distributed timeout in milliseconds.
OCommandDistributedReplicateRequest.QUORUM_TYPE	getQuorumType()	Returns the quorum type for the command: NONE: no quorum READ: configured Read quorum WRITE: configured Write quorum ALL: all nodes
String	getUndoCommand()	Returns the undo command if any.
boolean	isDistributedExecutingOnLocalNodeFirst()	Returns true if the command is executed on local node first and then distributed, or false if it's executed to all the servers at the same time.

Method Details

getDistributedExecutionMode

OCommandDistributedReplicateRequest.DISTRIBUTED_EXECUTION_MODE getDistributedExecutionMode()

Returns the execution mode when distributed configuration is active:

• LOCAL: executed on local node only
• REPLICATE: executed on all the nodes and expect the same result
• SHARDED: executed on all the involved nodes and merge results

getDistributedResultManagement

OCommandDistributedReplicateRequest.DISTRIBUTED_RESULT_MGMT getDistributedResultManagement()

Returns how to manage the distributed result between:

• CHECK_FOR_EQUALS: all results must be the same
• MERGE: merges results. This is typically used on sharding

getQuorumType

OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()

Returns the quorum type for the command:

• NONE: no quorum
• READ: configured Read quorum
• WRITE: configured Write quorum
• ALL: all nodes

getDistributedTimeout

long getDistributedTimeout()

Returns the distributed timeout in milliseconds.

getUndoCommand

String getUndoCommand()

Returns the undo command if any.

isDistributedExecutingOnLocalNodeFirst

boolean isDistributedExecutingOnLocalNodeFirst()

Returns true if the command is executed on local node first and then distributed, or false if it's executed to all the servers at the same time.