public class DataPipe extends Object
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
|
Modifier and Type | Method and Description |
---|---|
DataConsumer |
getDataConsumer() |
Map<String,String> |
getDataMap() |
String |
getDelimited(String[] outTemplate,
String separator)
Given an array of variable names, returns a delimited
String
of values. |
String |
getPipeDelimited(String[] outTemplate)
Given an array of variable names, returns a pipe delimited
String
of values. |
public DataPipe()
DataConsumer
public DataPipe(DataConsumer dataConsumer)
DataConsumer
dataConsumer
- a reference to DataConsumer
public DataPipe(long maxNumberOfLines, AtomicBoolean flag)
maxNumberOfLines
- a long containing the maximum number of lines
expected to flow through this pipeflag
- an AtomicBoolean exit flagpublic DataConsumer getDataConsumer()
public String getPipeDelimited(String[] outTemplate)
String
of values.Copyright © 2016. All rights reserved.