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 Summary

Constructors

Constructor	Description
DiskBlockData(long minMemoryMapBytes, long maxMemoryMapBytes, File file, long blockSize)

Method Summary

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

Methods inherited from class java.lang.Object

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

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)