Modifier and Type | Method and Description |
---|---|
ResultSubpartitionView |
ResultPartitionWriter.createSubpartitionView(int index,
BufferAvailabilityListener availabilityListener)
Returns a reader for the subpartition with the given index.
|
Modifier and Type | Method and Description |
---|---|
abstract ResultSubpartitionView |
ResultSubpartition.createReadView(BufferAvailabilityListener availabilityListener) |
PipelinedSubpartitionView |
PipelinedSubpartition.createReadView(BufferAvailabilityListener availabilityListener) |
PipelinedSubpartitionView |
PipelinedApproximateSubpartition.createReadView(BufferAvailabilityListener availabilityListener)
To simply the view releasing threading model,
PipelinedApproximateSubpartition.releaseView() is called only before creating a new view. |
ResultSubpartitionView |
BufferWritingResultPartition.createSubpartitionView(int subpartitionIndex,
BufferAvailabilityListener availabilityListener) |
ResultSubpartitionView |
SortMergeResultPartition.createSubpartitionView(int subpartitionIndex,
BufferAvailabilityListener availabilityListener) |
ResultSubpartitionView |
ResultPartitionProvider.createSubpartitionView(ResultPartitionID partitionId,
int index,
BufferAvailabilityListener availabilityListener)
Returns the requested intermediate result partition input view.
|
ResultSubpartitionView |
ResultPartitionManager.createSubpartitionView(ResultPartitionID partitionId,
int subpartitionIndex,
BufferAvailabilityListener availabilityListener) |
Constructor and Description |
---|
PipelinedSubpartitionView(PipelinedSubpartition parent,
BufferAvailabilityListener listener) |
Modifier and Type | Class and Description |
---|---|
class |
LocalInputChannel
An input channel, which requests a local subpartition.
|
Modifier and Type | Method and Description |
---|---|
ResultSubpartitionView |
HsResultPartition.createSubpartitionView(int subpartitionId,
BufferAvailabilityListener availabilityListener) |
Constructor and Description |
---|
HsSubpartitionView(BufferAvailabilityListener availabilityListener) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.