public class TapBackfillOperationImpl extends TapOperationImpl implements TapOperation
TapOperation.Callback
DUMMY_OPCODE, EMPTY_BYTES, ERR_2BIG, ERR_BUSY, ERR_DELTA_BADVAL, ERR_EXISTS, ERR_INTERNAL, ERR_INVAL, ERR_NO_MEM, ERR_NOT_FOUND, ERR_NOT_MY_VBUCKET, ERR_NOT_STORED, ERR_NOT_SUPPORTED, ERR_TEMP_FAIL, ERR_UNKNOWN_COMMAND, errorCode, keyLen, MIN_RECV_PACKET, opaque, REQ_MAGIC, RES_MAGIC, responseCas, responseCmd, responseOpaque, STATUS_OK, SUCCESS, vbucket
callback, CANCELLED, notMyVbucketNodes, TIMED_OUT
Modifier and Type | Method and Description |
---|---|
void |
initialize()
Initialize this operation.
|
void |
streamClosed(OperationState state) |
String |
toString() |
readFromBuffer
decodePayload, finishedPayload, getErrorMsg, getStatusForErrorCode, opaqueIsValid, prepareBuffer, resetInput
addClone, cancel, getBuffer, getCallback, getCloneCount, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleError, handleRead, hasErrored, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, setBuffer, setCallback, setCloneCount, setHandlingNode, timeOut, transitionState, wasCancelled, writeComplete, writing
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addClone, cancel, getBuffer, getCallback, getCloneCount, getErrorMsg, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleRead, hasErrored, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, readFromBuffer, setCloneCount, setHandlingNode, timeOut, writeComplete, writing
public void initialize()
Operation
initialize
in interface Operation
initialize
in class TapOperationImpl
public void streamClosed(OperationState state)
streamClosed
in interface TapOperation
public String toString()
toString
in class OperationImpl
Copyright © 2018. All rights reserved.