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<BinaryRowData> 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<BinaryRowData,BinaryRowData>> 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 |
BinaryRowDataSerializer.serializeToPages(BinaryRowData record,
AbstractPagedOutputView headerLessView) |
int |
RowDataSerializer.serializeToPages(RowData row,
AbstractPagedOutputView target) |
abstract int |
PagedTypeSerializer.serializeToPages(T record,
AbstractPagedOutputView target)
Serializes the given record to the given target paged output view.
|
int |
WindowKeySerializer.serializeToPages(WindowKey record,
AbstractPagedOutputView target)
Actually, the return value is just for saving checkSkipReadForFixLengthPart in the
mapFromPages, the cost is very small.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.