Package | Description |
---|---|
org.apache.flink.runtime.io.network.partition.hybrid |
Class and Description |
---|
BufferIndexAndChannel
Integrate the buffer index and the channel id which it belongs.
|
BufferWithIdentity
Integrate the buffer with index and the channel information to which it belongs.
|
HsDataView
A view for
HsSubpartitionView to find out what data exists in memory or disk and polling
the data. |
HsFileDataIndex
Index of spilled data.
|
HsFileDataIndex.ReadableRegion
Represents a series of physically continuous buffers in the file, which are readable, from
the same subpartition, and has sequential buffer index.
|
HsFileDataIndex.SpilledBuffer
Represents a spilled buffer.
|
HsMemoryDataManagerOperation
This interface is used by
HsSubpartitionMemoryDataManager to operate HsMemoryDataManager . |
HsOutputMetrics
All metrics that
HsResultPartition needs to count, except numBytesProduced. |
HsSpillingInfoProvider
This component is responsible for providing some information needed for the spill decision.
|
HsSpillingInfoProvider.ConsumeStatus
This enum represents buffer status of consume in hybrid shuffle mode.
|
HsSpillingInfoProvider.SpillStatus
This enum represents buffer status of spill in hybrid shuffle mode.
|
HsSpillingStrategy
Spilling strategy for hybrid shuffle mode.
|
HsSpillingStrategy.Decision
This class represents the spill and release decision made by
HsSpillingStrategy , in
other words, which data is to be spilled and which data is to be released. |
HsSubpartitionFileReader
This component is responsible for reading data from disk for a specific subpartition.
|
HsSubpartitionFileReader.Factory
Factory to create
HsSubpartitionFileReader . |
HsSubpartitionFileReaderImpl.BufferIndexOrError
Indicates a buffer with index or an error.
|
HsSubpartitionFileReaderImpl.Factory
Factory of
HsSubpartitionFileReader . |
HsSubpartitionViewInternalOperations
Operations provided by HsSubpartitionView that are used by other internal components of hybrid
result partition.
|
HybridShuffleConfiguration
Configuration for hybrid shuffle mode.
|
HybridShuffleConfiguration.Builder
Builder for
HybridShuffleConfiguration . |
HybridShuffleConfiguration.SpillingStrategyType
Type of
HsSpillingStrategy . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.