com.orientechnologies.orient.server.distributed.impl.task
Class OSyncClusterTask
public class OSyncClusterTask extends OAbstractReplicatedTask
| Modifier and Type | Class and Description |
|---|---|
static class |
OSyncClusterTask.MODE |
ORemoteTask.RESULT_STRATEGY| Modifier and Type | Field and Description |
|---|---|
static int |
CHUNK_MAX_SIZE |
protected String |
clusterName |
static String |
DEPLOYCLUSTER |
static int |
FACTORYID |
protected OSyncClusterTask.MODE |
mode |
protected long |
random |
nodeSource| Constructor and Description |
|---|
OSyncClusterTask() |
OSyncClusterTask(String iClusterName) |
| 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() |
void |
readExternal(ObjectInput in) |
void |
writeExternal(ObjectOutput out) |
getFixTask, getUndoTaskgetNodeSource, getPartitionKey, getSynchronousTimeout, getTotalTimeout, isIdempotent, isNodeOnlineRequired, setNodeSource, toStringpublic static final int CHUNK_MAX_SIZE
public static final String DEPLOYCLUSTER
public static final int FACTORYID
protected OSyncClusterTask.MODE mode
protected long random
protected String clusterName
public OSyncClusterTask()
public OSyncClusterTask(String iClusterName)
public Object execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentTx database) throws Exception
execute in interface ORemoteTaskexecute in class OAbstractRemoteTaskExceptionpublic ORemoteTask.RESULT_STRATEGY getResultStrategy()
getResultStrategy in interface ORemoteTaskgetResultStrategy in class OAbstractRemoteTaskpublic OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()
getQuorumType in interface ORemoteTaskgetQuorumType in class OAbstractRemoteTaskpublic long getDistributedTimeout()
getDistributedTimeout in interface ORemoteTaskgetDistributedTimeout in class OAbstractRemoteTaskpublic String getPayload()
getPayload in class OAbstractReplicatedTaskpublic String getName()
getName in interface ORemoteTaskgetName in class OAbstractRemoteTaskpublic void writeExternal(ObjectOutput out) throws IOException
IOExceptionpublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionpublic int getFactoryId()
Copyright © 2009–2016 Orient Technologies. All rights reserved.