com.orientechnologies.orient.server.distributed.impl.task
Class OSQLCommandTask
public class OSQLCommandTask extends OAbstractCommandTask
ORemoteTask.RESULT_STRATEGY| Modifier and Type | Field and Description |
|---|---|
protected Collection<String> |
clusters |
static int |
FACTORYID |
protected Map<Object,Object> |
params |
protected OCommandDistributedReplicateRequest.QUORUM_TYPE |
quorumType |
protected ORemoteTask.RESULT_STRATEGY |
resultStrategy |
protected String |
text |
protected long |
timeout |
nodeSource| Constructor and Description |
|---|
OSQLCommandTask() |
OSQLCommandTask(OCommandRequestText iCommand,
Collection<String> iClusterNames) |
| Modifier and Type | Method and Description |
|---|---|
Object |
execute(ODistributedRequestId requestId,
OServer iServer,
ODistributedServerManager iManager,
ODatabaseDocumentTx database) |
long |
getDistributedTimeout() |
int |
getFactoryId() |
String |
getName() |
String |
getPayload() |
OCommandDistributedReplicateRequest.QUORUM_TYPE |
getQuorumType() |
ORemoteTask.RESULT_STRATEGY |
getResultStrategy() |
ORemoteTask |
getUndoTask(ODistributedRequestId reqId) |
void |
readExternal(ObjectInput in) |
void |
setResultStrategy(ORemoteTask.RESULT_STRATEGY resultStrategy) |
String |
toString() |
void |
writeExternal(ObjectOutput out) |
getFixTaskgetNodeSource, getPartitionKey, getSynchronousTimeout, getTotalTimeout, isIdempotent, isNodeOnlineRequired, setNodeSourcepublic static final int FACTORYID
protected String text
protected ORemoteTask.RESULT_STRATEGY resultStrategy
protected Collection<String> clusters
protected OCommandDistributedReplicateRequest.QUORUM_TYPE quorumType
protected long timeout
public OSQLCommandTask()
public OSQLCommandTask(OCommandRequestText iCommand, Collection<String> iClusterNames)
public Object execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentTx database) throws Exception
execute in interface ORemoteTaskexecute in class OAbstractRemoteTaskExceptionpublic OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()
getQuorumType in interface ORemoteTaskgetQuorumType in class OAbstractRemoteTaskpublic ORemoteTask.RESULT_STRATEGY getResultStrategy()
getResultStrategy in interface ORemoteTaskgetResultStrategy in class OAbstractCommandTaskpublic void setResultStrategy(ORemoteTask.RESULT_STRATEGY resultStrategy)
setResultStrategy in class OAbstractCommandTaskpublic long getDistributedTimeout()
getDistributedTimeout in interface ORemoteTaskgetDistributedTimeout in class OAbstractRemoteTaskpublic void writeExternal(ObjectOutput out) throws IOException
IOExceptionpublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionpublic String getName()
getName in interface ORemoteTaskgetName in class OAbstractRemoteTaskpublic String toString()
toString in class OAbstractRemoteTaskpublic String getPayload()
getPayload in class OAbstractReplicatedTaskpublic ORemoteTask getUndoTask(ODistributedRequestId reqId)
getUndoTask in class OAbstractReplicatedTaskpublic int getFactoryId()
Copyright © 2009–2016 Orient Technologies. All rights reserved.