public static class StreamHandler.DummyErrorStream extends TupleStream
TupleStream.IgnoreExceptionMapWriter.EntryWriter| Constructor and Description |
|---|
DummyErrorStream(Exception e) |
| 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 DummyErrorStream(Exception e)
public StreamComparator getStreamSort()
getStreamSort in class TupleStreampublic void close()
close in interface Closeableclose in interface AutoCloseableclose in class TupleStreampublic void open()
open in class TupleStreampublic void setStreamContext(StreamContext context)
setStreamContext in class TupleStreampublic List<TupleStream> children()
children in class TupleStreampublic Explanation toExplanation(StreamFactory factory) throws IOException
toExplanation in class TupleStreamIOExceptionpublic Tuple read()
read in class TupleStreamCopyright © 2000-2021 Apache Software Foundation. All Rights Reserved.