org.finra.datagenerator.consumer

Class DataPipe

java.lang.Object

org.finra.datagenerator.consumer.DataPipe

public class DataPipe
extends Object

Created by RobbinBr on 5/18/2014.

Constructor Summary

Constructors

Constructor and Description
DataPipe() Default constructor.
DataPipe(DataConsumer dataConsumer) Constructor sets a user given DataConsumer
DataPipe(long maxNumberOfLines, AtomicBoolean flag) Constructor sets a max number of lines and shares an exit flag with the DataPipe

Method Summary

Methods

Modifier and Type	Method and Description
DataConsumer	getDataConsumer()
Map<String,String>	getDataMap()
String	getPipeDelimited(String[] outTemplate) Given an array of variable names, returns a pipe delimited String of values.

Methods inherited from class java.lang.Object

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

Constructor Detail

DataPipe

public DataPipe()

Default constructor. Initializes the dataConsumer to DataConsumer

DataPipe

public DataPipe(DataConsumer dataConsumer)

Constructor sets a user given DataConsumer

Parameters:

dataConsumer - a reference to DataConsumer

DataPipe

public DataPipe(long maxNumberOfLines,
        AtomicBoolean flag)

Constructor sets a max number of lines and shares an exit flag with the DataPipe

Parameters:

maxNumberOfLines - a long containing the maximum number of lines expected to flow through this pipe

flag - an AtomicBoolean exit flag

Method Detail

getDataConsumer

public DataConsumer getDataConsumer()

getDataMap

public Map<String,String> getDataMap()

getPipeDelimited

public String getPipeDelimited(String[] outTemplate)

Given an array of variable names, returns a pipe delimited String of values.

Parameters:

outTemplate - an array of Strings containing the variable names.

Returns:

a pipe delimited String of values