com.orientechnologies.orient.server.distributed.task
Class OAbstractRemoteTask
public abstract class OAbstractRemoteTask extends Object implements ORemoteTask
ORemoteTask.RESULT_STRATEGY| Modifier and Type | Field and Description |
|---|---|
protected String |
nodeSource |
| Constructor and Description |
|---|
OAbstractRemoteTask()
Constructor used from unmarshalling.
|
| Modifier and Type | Method and Description |
|---|---|
abstract Object |
execute(ODistributedRequestId requestId,
OServer iServer,
ODistributedServerManager iManager,
ODatabaseDocumentTx database) |
long |
getDistributedTimeout() |
abstract String |
getName() |
String |
getNodeSource() |
int |
getPartitionKey() |
abstract OCommandDistributedReplicateRequest.QUORUM_TYPE |
getQuorumType() |
ORemoteTask.RESULT_STRATEGY |
getResultStrategy() |
long |
getSynchronousTimeout(int iSynchNodes) |
long |
getTotalTimeout(int iTotalNodes) |
boolean |
isIdempotent() |
boolean |
isNodeOnlineRequired() |
void |
setNodeSource(String nodeSource) |
String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetFactoryIdreadExternal, writeExternalprotected transient String nodeSource
public OAbstractRemoteTask()
public abstract String getName()
getName in interface ORemoteTaskpublic abstract OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()
getQuorumType in interface ORemoteTaskpublic abstract Object execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentTx database) throws Exception
execute in interface ORemoteTaskExceptionpublic int getPartitionKey()
getPartitionKey in interface ORemoteTaskpublic long getDistributedTimeout()
getDistributedTimeout in interface ORemoteTaskpublic long getSynchronousTimeout(int iSynchNodes)
getSynchronousTimeout in interface ORemoteTaskpublic long getTotalTimeout(int iTotalNodes)
getTotalTimeout in interface ORemoteTaskpublic ORemoteTask.RESULT_STRATEGY getResultStrategy()
getResultStrategy in interface ORemoteTaskpublic String getNodeSource()
getNodeSource in interface ORemoteTaskpublic void setNodeSource(String nodeSource)
setNodeSource in interface ORemoteTaskpublic boolean isIdempotent()
isIdempotent in interface ORemoteTaskpublic boolean isNodeOnlineRequired()
isNodeOnlineRequired in interface ORemoteTaskCopyright © 2009–2016 Orient Technologies. All rights reserved.