Constructor and Description |
---|
ChannelReaderInputViewIterator(AbstractChannelReaderInputView inView,
List<MemorySegment> freeMemTarget,
TypeSerializer<E> accessors) |
Modifier and Type | Class and Description |
---|---|
class |
ChannelReaderInputView
A
DataInputView that is backed by a
BlockChannelReader , making it effectively a data input
stream. |
class |
HeaderlessChannelReaderInputView
A
DataInputView that is backed by a
BlockChannelReader , making it effectively a data input
stream. |
Modifier and Type | Field and Description |
---|---|
protected AbstractChannelReaderInputView |
BaseHybridHashTable.currentSpilledProbeSide
The reader for the spilled-file of the probe partition that is currently read.
|
Modifier and Type | Class and Description |
---|---|
class |
CompressedHeaderlessChannelReaderInputView
A
DataInputView that is backed by a
BufferFileReader , making it effectively a data input stream. |
Modifier and Type | Method and Description |
---|---|
protected MutableObjectIterator<BinaryRow> |
BinaryExternalMerger.channelReaderInputViewIterator(AbstractChannelReaderInputView inView) |
protected MutableObjectIterator<Tuple2<BinaryRow,BinaryRow>> |
BinaryKVExternalMerger.channelReaderInputViewIterator(AbstractChannelReaderInputView inView) |
protected abstract MutableObjectIterator<Entry> |
AbstractBinaryExternalMerger.channelReaderInputViewIterator(AbstractChannelReaderInputView inView) |
Constructor and Description |
---|
ChannelReaderKVInputViewIterator(AbstractChannelReaderInputView inView,
List<MemorySegment> freeMemTarget,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer) |
Modifier and Type | Method and Description |
---|---|
static AbstractChannelReaderInputView |
FileChannelUtil.createInputView(IOManager ioManager,
ChannelWithMeta channel,
List<FileIOChannel> channels,
boolean compressionEnable,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize,
int segmentSize) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.