public abstract class TupleStream extends Object implements Closeable, Serializable, MapWriter
Modifier and Type | Class and Description |
---|---|
static class |
TupleStream.IgnoreException |
MapWriter.EntryWriter
Constructor and Description |
---|
TupleStream() |
Modifier and Type | Method and Description |
---|---|
abstract List<TupleStream> |
children() |
abstract void |
close() |
int |
getCost() |
static List<String> |
getShards(String zkHost,
String collection,
StreamContext streamContext) |
UUID |
getStreamNodeId() |
abstract StreamComparator |
getStreamSort() |
abstract void |
open() |
abstract Tuple |
read() |
abstract void |
setStreamContext(StreamContext context) |
abstract Explanation |
toExplanation(StreamFactory factory) |
void |
writeMap(MapWriter.EntryWriter ew) |
public abstract void setStreamContext(StreamContext context)
public abstract List<TupleStream> children()
public abstract void open() throws IOException
IOException
public abstract void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public abstract Tuple read() throws IOException
IOException
public abstract StreamComparator getStreamSort()
public abstract Explanation toExplanation(StreamFactory factory) throws IOException
IOException
public int getCost()
public void writeMap(MapWriter.EntryWriter ew) throws IOException
writeMap
in interface MapWriter
IOException
public UUID getStreamNodeId()
public static List<String> getShards(String zkHost, String collection, StreamContext streamContext) throws IOException
IOException
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.