abstract class ShuffleWriter[K, V] {
def write(records: Iterator[Product2[K, V]]): Unit
def stop(success: Boolean): Option[MapStatus]
}
ShuffleWriter
Caution
|
FIXME |
ShuffleWriter
Contract
Note
|
ShuffleWriter is a private[spark] contract.
|
Method | Description |
---|---|
Writes a sequence of records (for a RDD partition) to a shuffle system when a |
|
Closes a Used when a |