org.finra.datagenerator.distributor

Interface SearchDistributor

All Known Implementing Classes:

DefaultDistributor, SparkDistributor

public interface SearchDistributor

Takes Frontiers produced by an Engine and completes the search on each Frontier, giving the results to a DataConsumer for post-processing and outputting.

Method Summary

Methods

Modifier and Type	Method and Description
void	distribute(List<Frontier> frontierList) Distributes the list of the problems
SearchDistributor	setDataConsumer(DataConsumer dataConsumer) Sets the data consumer

Method Detail

setDataConsumer

SearchDistributor setDataConsumer(DataConsumer dataConsumer)

Sets the data consumer

Parameters:

dataConsumer - the DataConsumer

Returns:

a reference to the current SearchDistributor

distribute

void distribute(List<Frontier> frontierList)

Distributes the list of the problems

Parameters:

frontierList - a list containing the search problems to distribute