public static class StreamHandler.DaemonResponseStream extends TupleStream
TupleStream.IgnoreExceptionMapWriter.EntryWriter| Constructor and Description |
|---|
DaemonResponseStream(String message) |
| 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, _getStrpublic DaemonResponseStream(String message)
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-2020 Apache Software Foundation. All Rights Reserved.