com.orientechnologies.orient.server.distributed.impl.task

Class OSQLCommandTask

java.lang.Object

com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask

com.orientechnologies.orient.server.distributed.task.OAbstractReplicatedTask

com.orientechnologies.orient.server.distributed.task.OAbstractCommandTask

com.orientechnologies.orient.server.distributed.impl.task.OSQLCommandTask

All Implemented Interfaces:

ORemoteTask

public class OSQLCommandTask
extends OAbstractCommandTask

Distributed task used for synchronization.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.server.distributed.task.ORemoteTask

ORemoteTask.RESULT_STRATEGY

Field Summary

Fields

Modifier and Type	Field and Description
protected Collection<String>	clusters
static int	FACTORYID
protected boolean	idempotent
protected Map<Object,Object>	params
protected OCommandDistributedReplicateRequest.QUORUM_TYPE	quorumType
protected ORemoteTask.RESULT_STRATEGY	resultStrategy
protected String	text
protected long	timeout

Fields inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractReplicatedTask

lastLSN

Fields inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask

ALL, ANY, FAST_NOLOCK, LOCK, nodeSource

Constructor Summary

Constructors

Constructor and Description
OSQLCommandTask()
OSQLCommandTask(OCommandRequestText iCommand, Collection<String> iClusterNames)

Method Summary

Modifier and Type	Method and Description
Object	execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
void	fromStream(DataInput in, ORemoteTaskFactory factory)
long	getDistributedTimeout()
int	getFactoryId()
String	getName()
OCommandDistributedReplicateRequest.QUORUM_TYPE	getQuorumType()
ORemoteTask.RESULT_STRATEGY	getResultStrategy()
ORemoteTask	getUndoTask(ODistributedServerManager dManager, ODistributedRequestId reqId, List<String> servers)
boolean	isIdempotent()
void	setResultStrategy(ORemoteTask.RESULT_STRATEGY resultStrategy)
void	toStream(DataOutput out)
String	toString()

Methods inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractReplicatedTask

getFixTask, getLastLSN

Methods inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask

checkIsValid, getNodeSource, getPartitionKey, getSynchronousTimeout, getTotalTimeout, hasResponse, isNodeOnlineRequired, isUsingDatabase, setNodeSource

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.server.distributed.task.ORemoteTask

finished, received

Field Detail

FACTORYID

public static final int FACTORYID

See Also:

Constant Field Values

text

protected String text

params

protected Map<Object,Object> params

resultStrategy

protected ORemoteTask.RESULT_STRATEGY resultStrategy

clusters

protected Collection<String> clusters

quorumType

protected OCommandDistributedReplicateRequest.QUORUM_TYPE quorumType

timeout

protected long timeout

idempotent

protected boolean idempotent

Constructor Detail

OSQLCommandTask

public OSQLCommandTask()

OSQLCommandTask

public OSQLCommandTask(OCommandRequestText iCommand,
                       Collection<String> iClusterNames)

Method Detail

execute

public Object execute(ODistributedRequestId requestId,
                      OServer iServer,
                      ODistributedServerManager iManager,
                      ODatabaseDocumentInternal database)
               throws Exception

Specified by:

execute in interface ORemoteTask

Specified by:

execute in class OAbstractRemoteTask

Throws:

Exception

getQuorumType

public OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()

Specified by:

getQuorumType in interface ORemoteTask

Specified by:

getQuorumType in class OAbstractRemoteTask

getResultStrategy

public ORemoteTask.RESULT_STRATEGY getResultStrategy()

Specified by:

getResultStrategy in interface ORemoteTask

Specified by:

getResultStrategy in class OAbstractCommandTask

setResultStrategy

public void setResultStrategy(ORemoteTask.RESULT_STRATEGY resultStrategy)

Specified by:

setResultStrategy in class OAbstractCommandTask

getDistributedTimeout

public long getDistributedTimeout()

Specified by:

getDistributedTimeout in interface ORemoteTask

Overrides:

getDistributedTimeout in class OAbstractRemoteTask

toStream

public void toStream(DataOutput out)
              throws IOException

Specified by:

toStream in interface ORemoteTask

Overrides:

toStream in class OAbstractRemoteTask

Throws:

IOException

fromStream

public void fromStream(DataInput in,
                       ORemoteTaskFactory factory)
                throws IOException

Specified by:

fromStream in interface ORemoteTask

Overrides:

fromStream in class OAbstractRemoteTask

Throws:

IOException

getName

public String getName()

Specified by:

getName in interface ORemoteTask

Specified by:

getName in class OAbstractRemoteTask

toString

public String toString()

Overrides:

toString in class OAbstractRemoteTask

getUndoTask

public ORemoteTask getUndoTask(ODistributedServerManager dManager,
                               ODistributedRequestId reqId,
                               List<String> servers)

Overrides:

getUndoTask in class OAbstractReplicatedTask

isIdempotent

public boolean isIdempotent()

Specified by:

isIdempotent in interface ORemoteTask

Overrides:

isIdempotent in class OAbstractRemoteTask

getFactoryId

public int getFactoryId()