Package com.linkedin.alpini.router.api

Class Scatter<H,P extends ResourcePath<K>,K>

java.lang.Object

com.linkedin.alpini.router.api.Scatter<H,P,K>

public class Scatter<H,P extends ResourcePath<K>,K>
extends java.lang.Object

Collection of ScatterGatherRequests for a request to the router. An incoming request is broken up into one or more ScatterGatherRequest, each of which represents a request which will be sent to a single storage node. This class holds all of the ScatterGatherRequests for a single incoming request.

Constructor Summary

Constructors

Constructor	Description
Scatter(P path, ResourcePathParser<P,K> pathParser, java.lang.Object role)

Method Summary

Modifier and Type	Method	Description
void	addOfflineRequest(ScatterGatherRequest<H,K> request)
void	addOnlineRequest(ScatterGatherRequest<H,K> request)
int	getOfflineRequestCount()
java.util.Collection<ScatterGatherRequest<H,K>>	getOfflineRequests()
int	getOnlineRequestCount()
java.util.Collection<ScatterGatherRequest<H,K>>	getOnlineRequests()
P	getPath()
ResourcePathParser<P,K>	getPathParser()
<R> R	getRole()
P	pathFor(ScatterGatherRequest<H,K> request)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Scatter

public Scatter(@Nonnull
               P path,
               @Nonnull
               ResourcePathParser<P,K> pathParser,
               @Nonnull
               java.lang.Object role)

Method Detail

addOfflineRequest

public void addOfflineRequest(@Nonnull
                              ScatterGatherRequest<H,K> request)

addOnlineRequest

public void addOnlineRequest(@Nonnull
                             ScatterGatherRequest<H,K> request)

getOnlineRequests

@Nonnull
public java.util.Collection<ScatterGatherRequest<H,K>> getOnlineRequests()

getOnlineRequestCount

public int getOnlineRequestCount()

getOfflineRequests

@Nonnull
public java.util.Collection<ScatterGatherRequest<H,K>> getOfflineRequests()

getOfflineRequestCount

public int getOfflineRequestCount()

getPath

@Nonnull
public P getPath()

getRole

@Nonnull
public <R> R getRole()

getPathParser

@Nonnull
public ResourcePathParser<P,K> getPathParser()

pathFor

@Nonnull
public P pathFor(@Nonnull
                 ScatterGatherRequest<H,K> request)