public class ExportWriterStream extends TupleStream implements Expressible
Note: this class is made public only to allow access from ExportHandler
,
it should be treated as an internal detail of implementation.
TupleStream.IgnoreException
MapWriter.EntryWriter
Constructor and Description |
---|
ExportWriterStream(StreamExpression expression,
StreamFactory factory) |
Modifier and Type | Method and Description |
---|---|
List<TupleStream> |
children() |
void |
close() |
StreamComparator |
getStreamSort() |
void |
open() |
Tuple |
read() |
void |
setStreamContext(StreamContext context)
NOTE: this context must contain an instance of
ExportBuffers under the
ExportBuffers.EXPORT_BUFFERS_KEY key. |
Explanation |
toExplanation(StreamFactory factory) |
StreamExpressionParameter |
toExpression(StreamFactory factory) |
getCost, getShards, getShards, getStreamNodeId, writeMap
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr, _size
public ExportWriterStream(StreamExpression expression, StreamFactory factory) throws IOException
IOException
public void setStreamContext(StreamContext context)
ExportBuffers
under the
ExportBuffers.EXPORT_BUFFERS_KEY
key.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 interface Closeable
close
in interface AutoCloseable
close
in class TupleStream
IOException
public Tuple read() throws IOException
read
in class TupleStream
IOException
public StreamComparator getStreamSort()
getStreamSort
in class TupleStream
public StreamExpressionParameter toExpression(StreamFactory factory) throws IOException
toExpression
in interface Expressible
IOException
public Explanation toExplanation(StreamFactory factory) throws IOException
toExplanation
in interface Expressible
toExplanation
in class TupleStream
IOException
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.