Class MultiKeyOperationImpl
- java.lang.Object
-
- net.spy.memcached.compat.SpyObject
-
- net.spy.memcached.protocol.BaseOperationImpl
-
- net.spy.memcached.protocol.binary.OperationImpl
-
- net.spy.memcached.protocol.binary.MultiKeyOperationImpl
-
- All Implemented Interfaces:
KeyedOperation,Operation,VBucketAware
- Direct Known Subclasses:
MultiGetOperationImpl,OptimizedSetImpl
abstract class MultiKeyOperationImpl extends OperationImpl implements VBucketAware, KeyedOperation
Binary operations that contain multiple keys and are VBucket aware operations should extend this class.
-
-
Field Summary
Fields Modifier and Type Field Description protected java.util.Map<java.lang.String,java.lang.Short>vbmap-
Fields inherited from class net.spy.memcached.protocol.binary.OperationImpl
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
-
Fields inherited from class net.spy.memcached.protocol.BaseOperationImpl
callback, CANCELLED, notMyVbucketNodes, TIMED_OUT
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedMultiKeyOperationImpl(byte c, int o, OperationCallback cb)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddNotMyVbucketNode(MemcachedNode node)java.util.Collection<java.lang.String>getKeys()Get the keys requested in this GetOperation.java.util.Collection<MemcachedNode>getNotMyVbucketNodes()shortgetVBucket(java.lang.String k)voidsetNotMyVbucketNodes(java.util.Collection<MemcachedNode> nodes)voidsetVBucket(java.lang.String k, short vb)java.lang.StringtoString()-
Methods inherited from class net.spy.memcached.protocol.binary.OperationImpl
decodeByte, decodeInt, decodeLong, decodePayload, decodeShort, decodeUnsignedInt, finishedPayload, generateOpaque, getErrorMsg, getStatusForErrorCode, opaqueIsValid, prepareBuffer, readFromBuffer, resetInput
-
Methods inherited from class net.spy.memcached.protocol.BaseOperationImpl
addClone, cancel, getBuffer, getCallback, getCloneCount, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleError, handleRead, hasErrored, initialize, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, setBuffer, setCallback, setCloneCount, setHandlingNode, timeOut, transitionState, wasCancelled, writeComplete, writing
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface net.spy.memcached.ops.Operation
addClone, cancel, getBuffer, getCallback, getCloneCount, getErrorMsg, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleRead, hasErrored, initialize, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, readFromBuffer, setCloneCount, setHandlingNode, timeOut, writeComplete, writing
-
-
-
-
Constructor Detail
-
MultiKeyOperationImpl
protected MultiKeyOperationImpl(byte c, int o, OperationCallback cb)
-
-
Method Detail
-
getKeys
public java.util.Collection<java.lang.String> getKeys()
Description copied from interface:KeyedOperationGet the keys requested in this GetOperation.- Specified by:
getKeysin interfaceKeyedOperation
-
getNotMyVbucketNodes
public java.util.Collection<MemcachedNode> getNotMyVbucketNodes()
- Specified by:
getNotMyVbucketNodesin interfaceVBucketAware
-
addNotMyVbucketNode
public void addNotMyVbucketNode(MemcachedNode node)
- Specified by:
addNotMyVbucketNodein interfaceVBucketAware
-
setNotMyVbucketNodes
public void setNotMyVbucketNodes(java.util.Collection<MemcachedNode> nodes)
- Specified by:
setNotMyVbucketNodesin interfaceVBucketAware
-
setVBucket
public void setVBucket(java.lang.String k, short vb)- Specified by:
setVBucketin interfaceVBucketAware
-
getVBucket
public short getVBucket(java.lang.String k)
- Specified by:
getVBucketin interfaceVBucketAware
-
toString
public java.lang.String toString()
- Overrides:
toStringin classOperationImpl
-
-