public static class GraphHandler.TimerStream extends TupleStream
TupleStream.IgnoreExceptionMapWriter.EntryWriter| Constructor and Description |
|---|
TimerStream(TupleStream tupleStream) |
| 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, getStreamNodeId, writeMapclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStrpublic TimerStream(TupleStream tupleStream)
public StreamComparator getStreamSort()
getStreamSort in class TupleStreampublic void close()
throws IOException
close in interface Closeableclose in interface AutoCloseableclose in class TupleStreamIOExceptionpublic void open()
throws IOException
open in class TupleStreamIOExceptionpublic 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() throws IOException
read in class TupleStreamIOExceptionCopyright © 2000-2020 Apache Software Foundation. All Rights Reserved.