org.apache.spark.storage

Class DiskBlockData

Object

org.apache.spark.storage.DiskBlockData

All Implemented Interfaces:

BlockData

public class DiskBlockData
extends Object
implements BlockData

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()

Specified by:

dispose in interface BlockData

size

public long size()

Specified by:

size in interface BlockData

toByteBuffer

public java.nio.ByteBuffer toByteBuffer()

Specified by:

toByteBuffer in interface BlockData

toChunkedByteBuffer

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

Specified by:

toChunkedByteBuffer in interface BlockData

toInputStream

public java.io.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)