| Interface | Description |
|---|---|
| ShuffleDataIO |
:: Private ::
An interface for plugging in modules for storing and reading temporary shuffle data.
|
| ShuffleDriverComponents |
:: Private ::
An interface for building shuffle support modules for the Driver.
|
| ShuffleExecutorComponents |
:: Private ::
An interface for building shuffle support for Executors.
|
| ShuffleMapOutputWriter |
:: Private ::
A top-level writer that returns child writers for persisting the output of a map task,
and then commits all of the writes as one atomic operation.
|
| ShufflePartitionWriter |
:: Private ::
An interface for opening streams to persist partition bytes to a backing data store.
|
| SingleSpillShuffleMapOutputWriter |
Optional extension for partition writing that is optimized for transferring a single
file to the backing store.
|
| WritableByteChannelWrapper |
:: Private ::
A thin wrapper around a
WritableByteChannel. |