Class MultiGetOperationImpl

    • Field Detail

      • keys

        private final java.util.Map<java.lang.Integer,​java.lang.String> keys
      • bkeys

        private final java.util.Map<java.lang.Integer,​byte[]> bkeys
      • rkeys

        private final java.util.Map<java.lang.String,​java.lang.Integer> rkeys
      • terminalOpaque

        private final int terminalOpaque
      • retryKeys

        private final java.util.List<java.lang.String> retryKeys
    • Constructor Detail

      • MultiGetOperationImpl

        public MultiGetOperationImpl​(java.util.Collection<java.lang.String> k,
                                     OperationCallback cb)
    • Method Detail

      • addKey

        protected int addKey​(java.lang.String k)
        Add a key (and return its new opaque value).
      • finishedPayload

        protected void finishedPayload​(byte[] pl)
                                throws java.io.IOException
        Overrides:
        finishedPayload in class OperationImpl
        Throws:
        java.io.IOException
      • opaqueIsValid

        protected boolean opaqueIsValid()
        Description copied from class: OperationImpl
        Validate an opaque value from the header. This may be overridden from a subclass where the opaque isn't expected to always be the same as the request opaque.
        Overrides:
        opaqueIsValid in class OperationImpl
      • getRetryKeys

        public java.util.List<java.lang.String> getRetryKeys()
        Returns the keys to redistribute.
        Returns:
        the keys to retry.