Package com.linkedin.alpini.router.api

Class BroadcastScatterGatherRequest<H,K>

java.lang.Object

com.linkedin.alpini.router.api.ScatterGatherRequest<H,K>

com.linkedin.alpini.router.api.BroadcastScatterGatherRequest<H,K>

public class BroadcastScatterGatherRequest<H,K>
extends ScatterGatherRequest<H,K>

This type of specialized ScatterGatherRequest does not use keys for routing, and carry some extra state. We have a separate subclass for it to avoid carrying extra overhead in all ScatterGatherRequest instances.

Constructor Summary

Constructors

Constructor	Description
BroadcastScatterGatherRequest(List host)

Method Summary

Modifier and Type	Method	Description
void	addPartitionNameToQuery(String partitionName)
Set<String>	getPartitionNamesToQuery()	For table level query requests, return the list of partitions that should be queried for this request.

Methods inherited from class com.linkedin.alpini.router.api.ScatterGatherRequest

equals, getHosts, getPartitionKeys, hashCode, removeHost, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

BroadcastScatterGatherRequest

public BroadcastScatterGatherRequest(List host)

Method Details

addPartitionNameToQuery

public void addPartitionNameToQuery(String partitionName)

getPartitionNamesToQuery

public Set<String> getPartitionNamesToQuery()

For table level query requests, return the list of partitions that should be queried for this request.

Overrides:

getPartitionNamesToQuery in class ScatterGatherRequest<H,K>