public class ScoreNodesStream extends TupleStream implements Expressible
| Constructor and Description |
|---|
ScoreNodesStream(StreamExpression expression,
StreamFactory factory) |
ScoreNodesStream(TupleStream tupleStream,
String nodeFreqField) |
| Modifier and Type | Method and Description |
|---|---|
List<TupleStream> |
children() |
void |
close() |
StreamComparator |
getComparator() |
int |
getCost() |
StreamComparator |
getStreamSort() |
void |
open() |
Tuple |
read() |
void |
setStreamContext(StreamContext context) |
Explanation |
toExplanation(StreamFactory factory)
Returns an explanation about the stream object
|
StreamExpression |
toExpression(StreamFactory factory) |
getStreamNodeId, writeStreamClose, writeStreamOpenprotected String zkHost
public ScoreNodesStream(TupleStream tupleStream, String nodeFreqField) throws IOException
IOExceptionpublic ScoreNodesStream(StreamExpression expression, StreamFactory factory) throws IOException
IOExceptionpublic StreamExpression toExpression(StreamFactory factory) throws IOException
toExpression in interface ExpressibleIOExceptionpublic Explanation toExplanation(StreamFactory factory) throws IOException
ExpressibletoExplanation in interface ExpressibletoExplanation in class TupleStreamfactory - Stream factory for this, contains information about the function nameIOException - throw on any errorpublic 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 StreamComparator getComparator()
public Tuple read() throws IOException
read in class TupleStreamIOExceptionpublic StreamComparator getStreamSort()
getStreamSort in class TupleStreampublic int getCost()
getCost in class TupleStreamCopyright © 2000-2016 Apache Software Foundation. All Rights Reserved.