Package org.apache.spark.storage

Class DiskBlockData

Object
org.apache.spark.storage.DiskBlockData
All Implemented Interfaces:
BlockData
public class DiskBlockData extends Object implements BlockData

  • Constructor Details

    • DiskBlockData

      public DiskBlockData(long minMemoryMapBytes, long maxMemoryMapBytes, File file, long blockSize)

  • Method Details

    • dispose

      public void dispose()
      Specified by:
      dispose in interface BlockData

    • size

      public long size()
      Specified by:
      size in interface BlockData

    • toByteBuffer

      public ByteBuffer toByteBuffer()
      Specified by:
      toByteBuffer in interface BlockData

    • toChunkedByteBuffer

      public org.apache.spark.util.io.ChunkedByteBuffer toChunkedByteBuffer(scala.Function1<Object,ByteBuffer> allocator)
      Specified by:
      toChunkedByteBuffer in interface BlockData

    • toInputStream

      public InputStream toInputStream()
      Specified by:
      toInputStream in interface BlockData

    • toNetty

      public Object toNetty()
      Returns a Netty-friendly wrapper for the block's data.

      Please see ManagedBuffer.convertToNetty() for more details.

      Specified by:
      toNetty in interface BlockData
      Returns:
      (undocumented)

    • toNettyForSsl

      public Object toNettyForSsl()
      Returns a Netty-friendly wrapper for the block's data.

      Please see ManagedBuffer.convertToNettyForSsl() for more details.

      Specified by:
      toNettyForSsl in interface BlockData
      Returns:
      (undocumented)