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 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, Object role)

Method Summary

Modifier and Type	Method	Description
void	addOfflineRequest(ScatterGatherRequest<H,K> request)
void	addOnlineRequest(ScatterGatherRequest<H,K> request)
int	getOfflineRequestCount()
Collection<ScatterGatherRequest<H,K>>	getOfflineRequests()
int	getOnlineRequestCount()
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 Details

Scatter

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

Method Details

addOfflineRequest

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

addOnlineRequest

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

getOnlineRequests

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

getOnlineRequestCount

public int getOnlineRequestCount()

getOfflineRequests

@Nonnull
public 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)