Package org.apache.spark.shuffle.api

Interface WritableByteChannelWrapper

All Superinterfaces:
AutoCloseable, Closeable
@Private public interface WritableByteChannelWrapper extends Closeable
:: Private :: A thin wrapper around a WritableByteChannel.

This is primarily provided for the local disk shuffle implementation to provide a FileChannel that keeps the channel open across partition writes.

Since:
3.0.0

  • Method Summary

    Modifier and Type
    Method
    Description
    WritableByteChannel
    channel()
    The underlying channel to write bytes into.

    Methods inherited from interface java.io.Closeable

    close

  • Method Details