org.apache.spark.storage

Class EncryptedBlockData

Object

org.apache.spark.storage.EncryptedBlockData

public class EncryptedBlockData
extends Object

Constructor Summary

Constructors

Constructor and Description
EncryptedBlockData(java.io.File file, long blockSize, SparkConf conf, byte[] key)

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

EncryptedBlockData

public EncryptedBlockData(java.io.File file,
                          long blockSize,
                          SparkConf conf,
                          byte[] key)

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)