public class TsvStream extends CsvStream implements Expressible
TupleStream.IgnoreException
MapWriter.EntryWriter
originalStream
Constructor and Description |
---|
TsvStream(StreamExpression expression,
StreamFactory factory) |
Modifier and Type | Method and Description |
---|---|
protected String[] |
split(String line) |
Explanation |
toExplanation(StreamFactory factory)
Returns an explanation about the stream object
|
StreamExpression |
toExpression(StreamFactory factory) |
children, close, getCost, getStreamSort, open, read, setStreamContext
getShards, getStreamNodeId, writeMap
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr
public TsvStream(StreamExpression expression, StreamFactory factory) throws IOException
IOException
public StreamExpression toExpression(StreamFactory factory) throws IOException
toExpression
in interface Expressible
toExpression
in class CsvStream
IOException
public Explanation toExplanation(StreamFactory factory) throws IOException
Expressible
toExplanation
in interface Expressible
toExplanation
in class CsvStream
factory
- Stream factory for this, contains information about the function nameIOException
- throw on any errorCopyright © 2000-2019 Apache Software Foundation. All Rights Reserved.