Modifier and Type | Class and Description |
---|---|
class |
FileChannelOutputView
A
DataOutputView that is backed by a BlockChannelWriter , making it effectively a data output
stream. |
class |
RandomAccessOutputView |
class |
SimpleCollectingOutputView
The list with the full segments contains at any point all completely full segments, plus the segment that is
currently filled.
|
class |
SpillingBuffer
An output view that buffers written data in memory pages and spills them when they are full.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractChannelWriterOutputView
A
DataOutputView that is backed by a FileIOChannel ,
making it effectively a data output stream. |
class |
ChannelWriterOutputView
A
DataOutputView that is backed by a
BlockChannelWriter , making it effectively a data output
stream. |
Modifier and Type | Class and Description |
---|---|
class |
SerializedUpdateBuffer
AbstractPagedOutputView used by the BlockingBackChannel for
transmitting superstep results. |
Modifier and Type | Class and Description |
---|---|
protected static class |
HashPartition.BuildSideBuffer |
Modifier and Type | Class and Description |
---|---|
protected static class |
BinaryHashPartition.BuildSideBuffer
Build side buffer.
|
Modifier and Type | Class and Description |
---|---|
class |
CompressedHeaderlessChannelWriterOutputView
A
DataOutputView that is backed by a FileIOChannel ,
making it effectively a data output stream. |
class |
HeaderlessChannelWriterOutputView
A
DataOutputView that is backed by a
BlockChannelWriter , making it effectively a data output stream. |
Modifier and Type | Method and Description |
---|---|
protected void |
BinaryExternalMerger.writeMergingOutput(MutableObjectIterator<BinaryRow> mergeIterator,
AbstractPagedOutputView output) |
protected abstract void |
AbstractBinaryExternalMerger.writeMergingOutput(MutableObjectIterator<Entry> mergeIterator,
AbstractPagedOutputView output)
read the merged stream and write the data back.
|
protected void |
BinaryKVExternalMerger.writeMergingOutput(MutableObjectIterator<Tuple2<BinaryRow,BinaryRow>> mergeIterator,
AbstractPagedOutputView output) |
void |
BinaryIndexedSortable.writeToOutput(AbstractPagedOutputView output)
Spill: Write all records to a
AbstractPagedOutputView . |
void |
BinaryKVInMemorySortBuffer.writeToOutput(AbstractPagedOutputView output) |
Modifier and Type | Method and Description |
---|---|
int |
BaseRowSerializer.serializeToPages(BaseRow row,
AbstractPagedOutputView target) |
int |
BinaryRowSerializer.serializeToPages(BinaryRow record,
AbstractPagedOutputView headerLessView) |
abstract int |
AbstractRowSerializer.serializeToPages(T record,
AbstractPagedOutputView target)
Serializes the given record to the given target paged output view.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.