public static class GraphHandler.TimerStream extends TupleStream
TupleStream.IgnoreException
MapWriter.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, writeMap
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr
public TimerStream(TupleStream tupleStream)
public StreamComparator getStreamSort()
getStreamSort
in class TupleStream
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class TupleStream
IOException
public void open() throws IOException
open
in class TupleStream
IOException
public void setStreamContext(StreamContext context)
setStreamContext
in class TupleStream
public List<TupleStream> children()
children
in class TupleStream
public Explanation toExplanation(StreamFactory factory) throws IOException
toExplanation
in class TupleStream
IOException
public Tuple read() throws IOException
read
in class TupleStream
IOException
Copyright © 2000-2019 Apache Software Foundation. All Rights Reserved.