public class ExceptionStream extends TupleStream
TupleStream.IgnoreExceptionMapWriter.EntryWriter| Constructor and Description |
|---|
ExceptionStream(TupleStream stream) |
| Modifier and Type | Method and Description |
|---|---|
List<TupleStream> |
children() |
void |
close() |
StreamComparator |
getStreamSort() |
void |
open() |
Tuple |
read() |
void |
setStreamContext(StreamContext context) |
Explanation |
toExplanation(StreamFactory factory) |
getCost, getShards, getShards, getStreamNodeId, writeMapclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr, _sizepublic ExceptionStream(TupleStream stream)
public List<TupleStream> children()
children in class TupleStreampublic void open()
open in class TupleStreampublic Tuple read()
read in class TupleStreampublic Explanation toExplanation(StreamFactory factory) throws IOException
toExplanation in class TupleStreamIOExceptionpublic StreamComparator getStreamSort()
getStreamSort in class TupleStreampublic void close()
throws IOException
close in interface Closeableclose in interface AutoCloseableclose in class TupleStreamIOExceptionpublic void setStreamContext(StreamContext context)
setStreamContext in class TupleStreamCopyright © 2000-2021 Apache Software Foundation. All Rights Reserved.