Package com.linkedin.alpini.router.api

Class ScatterGatherRequest<H,​K>

  • Direct Known Subclasses:
    BroadcastScatterGatherRequest
    public class ScatterGatherRequest<H,​K>
extends java.lang.Object
    Routing information for part of a request which the router has mapped to a single storage node. The ScatterGatherRequest holds a storage node hostname, plus keys and partitions which have been mapped to that host. A single request to the router may be split into multiple ScatterGatherRequest objects, one for each host involved in servicing the request.

    • Constructor Detail

      • ScatterGatherRequest

        public ScatterGatherRequest​(java.util.List<H> host,
                            java.util.Set<K> partitionKeys)

    • Method Detail

      • getHosts

        public java.util.List<H> getHosts()

      • removeHost

        public void removeHost​(@Nonnull
                       H host)

      • getPartitionKeys

        public java.util.Set<K> getPartitionKeys()

      • getPartitionNamesToQuery

        public java.util.Set<java.lang.String> getPartitionNamesToQuery()
        Only used by broadcast queries. See BroadcastScatterGatherRequest.

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object

      • equals

        public boolean equals​(java.lang.Object obj)
        Overrides:
        equals in class java.lang.Object

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object