com.orientechnologies.orient.server.distributed.impl.task
Class OCopyDatabaseChunkTask
public class OCopyDatabaseChunkTask extends OAbstractReplicatedTask
ORemoteTask.RESULT_STRATEGY| Modifier and Type | Field and Description |
|---|---|
static int |
FACTORYID |
nodeSource| Constructor and Description |
|---|
OCopyDatabaseChunkTask() |
OCopyDatabaseChunkTask(String iFileName,
int iChunkNum,
long iOffset,
boolean iCompressed) |
| 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() |
boolean |
isNodeOnlineRequired() |
void |
readExternal(ObjectInput in) |
void |
writeExternal(ObjectOutput out) |
getFixTask, getUndoTaskgetNodeSource, getPartitionKey, getSynchronousTimeout, getTotalTimeout, isIdempotent, setNodeSource, toStringpublic static final int FACTORYID
public OCopyDatabaseChunkTask()
public OCopyDatabaseChunkTask(String iFileName, int iChunkNum, long iOffset, boolean iCompressed)
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 long getDistributedTimeout()
getDistributedTimeout in interface ORemoteTaskgetDistributedTimeout in class OAbstractRemoteTaskpublic OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()
getQuorumType in interface ORemoteTaskgetQuorumType 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 boolean isNodeOnlineRequired()
isNodeOnlineRequired in interface ORemoteTaskisNodeOnlineRequired in class OAbstractRemoteTaskpublic int getFactoryId()
Copyright © 2009–2016 Orient Technologies. All rights reserved.