Class OCopyDatabaseChunkTask
java.lang.Object
com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask
com.orientechnologies.orient.server.distributed.impl.task.OCopyDatabaseChunkTask
- All Implemented Interfaces:
ORemoteTask
Ask for a database chunk.
- 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
FieldsFields inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask
nodeSource -
Constructor Summary
ConstructorsConstructorDescriptionOCopyDatabaseChunkTask(String iFileName, int iChunkNum, long iOffset, boolean iCompressed) -
Method Summary
Modifier and TypeMethodDescriptionexecute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) voidfromStream(DataInput in, ORemoteTaskFactory factory) intlongintgetName()longbooleanbooleanvoidtoStream(DataOutput out) Methods inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask
getNodeSource, getResultStrategy, getSynchronousTimeout, getTotalTimeout, hasResponse, isIdempotent, isUsingDatabase, setNodeSource, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface com.orientechnologies.orient.server.distributed.task.ORemoteTask
finished, received
-
Field Details
-
FACTORYID
public static final int FACTORYID- See Also:
-
-
Constructor Details
-
OCopyDatabaseChunkTask
public OCopyDatabaseChunkTask() -
OCopyDatabaseChunkTask
-
-
Method Details
-
execute
public Object execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) throws Exception - Throws:
Exception
-
getDistributedTimeout
public long getDistributedTimeout()- Specified by:
getDistributedTimeoutin interfaceORemoteTask- Overrides:
getDistributedTimeoutin classOAbstractRemoteTask
-
getQuorumType
-
getName
-
toStream
- Specified by:
toStreamin interfaceORemoteTask- Overrides:
toStreamin classOAbstractRemoteTask- Throws:
IOException
-
fromStream
- Specified by:
fromStreamin interfaceORemoteTask- Overrides:
fromStreamin classOAbstractRemoteTask- Throws:
IOException
-
isNodeOnlineRequired
public boolean isNodeOnlineRequired()- Specified by:
isNodeOnlineRequiredin interfaceORemoteTask- Overrides:
isNodeOnlineRequiredin classOAbstractRemoteTask
-
getFactoryId
public int getFactoryId() -
getFileName
-
getChunkNum
public int getChunkNum() -
getOffset
public long getOffset() -
isCompressed
public boolean isCompressed()
-