Uses of Class
org.finra.datagenerator.consumer.DataConsumer

Packages that use DataConsumer

Package	Description
org.finra.datagenerator.consumer
org.finra.datagenerator.distributor
org.finra.datagenerator.distributor.multithreaded
org.finra.datagenerator.distributor.spark

Uses of DataConsumer in org.finra.datagenerator.consumer

Subclasses of DataConsumer in org.finra.datagenerator.consumer

Modifier and Type	Class and Description
class	RepeatingDataConsumer Consumer that repeat whole set necessary number of times

Methods in org.finra.datagenerator.consumer that return DataConsumer

Modifier and Type	Method and Description
DataConsumer	DataConsumer.addDataTransformer(DataTransformer dc) Adds a data transformer to the end of the data transformers list
DataConsumer	DataConsumer.addDataWriter(DataWriter ow) Adds a DataWriter to the end of the dataWriters list
DataConsumer	DataPipe.getDataConsumer()
DataConsumer	DataConsumer.setExitFlag(AtomicBoolean flag) Setter for exit flag
DataConsumer	DataConsumer.setMaxNumberOfLines(long maxNumberOfLines) A setter for maxNumberOfLines
DataConsumer	DataConsumer.setReportingHost(String reportingHost) A setter for the reporting host

Constructors in org.finra.datagenerator.consumer with parameters of type DataConsumer

Constructor and Description
DataPipe(DataConsumer dataConsumer) Constructor sets a user given DataConsumer

Uses of DataConsumer in org.finra.datagenerator.distributor

Methods in org.finra.datagenerator.distributor with parameters of type DataConsumer

Modifier and Type	Method and Description
SearchDistributor	SearchDistributor.setDataConsumer(DataConsumer dataConsumer) Sets the data consumer

Uses of DataConsumer in org.finra.datagenerator.distributor.multithreaded

Methods in org.finra.datagenerator.distributor.multithreaded with parameters of type DataConsumer

Modifier and Type	Method and Description
SearchDistributor	DefaultDistributor.setDataConsumer(DataConsumer dataConsumer)

Uses of DataConsumer in org.finra.datagenerator.distributor.spark

Methods in org.finra.datagenerator.distributor.spark with parameters of type DataConsumer

Modifier and Type	Method and Description
SparkDistributor	SparkDistributor.setDataConsumer(DataConsumer dataConsumer)