protected class TextLogitStream.TermsStream extends TupleStream
MapWriter.EntryWriter| Constructor and Description |
|---|
TermsStream(List<String> terms) |
| 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, getSlices, getStreamNodeId, writeMappublic void setStreamContext(StreamContext context)
setStreamContext in class TupleStreampublic List<TupleStream> children()
children in class TupleStreampublic void open()
throws IOException
open in class TupleStreamIOExceptionpublic void close()
throws IOException
close in interface Closeableclose in interface AutoCloseableclose in class TupleStreamIOExceptionpublic Tuple read() throws IOException
read in class TupleStreamIOExceptionpublic StreamComparator getStreamSort()
getStreamSort in class TupleStreampublic Explanation toExplanation(StreamFactory factory) throws IOException
toExplanation in class TupleStreamIOExceptionCopyright © 2000-2017 Apache Software Foundation. All Rights Reserved.