org.apache.spark.storage

Interface BlockData

All Known Implementing Classes:

DiskBlockData

public interface BlockData

Abstracts away how blocks are stored and provides different ways to read the underlying block data. Callers should call dispose() when they're done with the block.

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.

Method Detail

dispose

void dispose()

size

long size()

toByteBuffer

java.nio.ByteBuffer toByteBuffer()

toChunkedByteBuffer

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

toInputStream

java.io.InputStream toInputStream()

toNetty

Object toNetty()

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

Please see ManagedBuffer.convertToNetty() for more details.

Returns:

(undocumented)