org.apache.spark.storage

Class DiskBlockData

Object

org.apache.spark.storage.DiskBlockData

public class DiskBlockData
extends Object

Constructor Summary

Constructors

Constructor and Description
DiskBlockData(long minMemoryMapBytes, long maxMemoryMapBytes, java.io.File file, long blockSize)

Method Summary

Modifier and Type	Method and Description
void	dispose()
long	size()
java.nio.ByteBuffer	toByteBuffer()
org.apache.spark.util.io.ChunkedByteBuffer	toChunkedByteBuffer(scala.Function1<Object,java.nio.ByteBuffer> allocator)
java.io.InputStream	toInputStream()
Object	toNetty() Returns a Netty-friendly wrapper for the block's data.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DiskBlockData

public DiskBlockData(long minMemoryMapBytes,
                     long maxMemoryMapBytes,
                     java.io.File file,
                     long blockSize)

Method Detail

dispose

public void dispose()

size

public long size()

toByteBuffer

public java.nio.ByteBuffer toByteBuffer()

toChunkedByteBuffer

public org.apache.spark.util.io.ChunkedByteBuffer toChunkedByteBuffer(scala.Function1<Object,java.nio.ByteBuffer> allocator)

toInputStream

public java.io.InputStream toInputStream()

toNetty

public Object toNetty()

Returns a Netty-friendly wrapper for the block's data.

Please see ManagedBuffer.convertToNetty() for more details.

Returns:

(undocumented)