public class RankStream extends TupleStream
Constructor and Description |
---|
RankStream(TupleStream tupleStream,
int size,
Comparator<Tuple> comp) |
Modifier and Type | Method and Description |
---|---|
List<TupleStream> |
children() |
void |
close() |
int |
getCost() |
void |
open() |
Tuple |
read() |
void |
setStreamContext(StreamContext context) |
public RankStream(TupleStream tupleStream, int size, Comparator<Tuple> comp)
public void setStreamContext(StreamContext context)
setStreamContext
in class TupleStream
public List<TupleStream> children()
children
in class TupleStream
public void open() throws IOException
open
in class TupleStream
IOException
public void close() throws IOException
close
in class TupleStream
IOException
public Tuple read() throws IOException
read
in class TupleStream
IOException
public int getCost()
getCost
in class TupleStream
Copyright © 2000-2015 Apache Software Foundation. All Rights Reserved.