org.apache.spark.storage.memory

Class SerializedValuesHolder<T>

Object

org.apache.spark.storage.memory.SerializedValuesHolder<T>

All Implemented Interfaces:

ValuesHolder<T>

public class SerializedValuesHolder<T>
extends Object
implements ValuesHolder<T>

A holder for storing the serialized values.

Constructor Summary

Constructors

Constructor and Description
SerializedValuesHolder(BlockId blockId, int chunkSize, scala.reflect.ClassTag<T> classTag, org.apache.spark.memory.MemoryMode memoryMode, org.apache.spark.serializer.SerializerManager serializerManager)

Method Summary

Modifier and Type	Method and Description
scala.Function1<Object,java.nio.ByteBuffer>	allocator()
org.apache.spark.util.io.ChunkedByteBufferOutputStream	bbos()
long	estimatedSize()
MemoryEntryBuilder<T>	getBuilder() Note: After this method is called, the ValuesHolder is invalid, we can't store data and get estimate size again.
org.apache.spark.storage.memory.RedirectableOutputStream	redirectableStream()
SerializationStream	serializationStream()
void	storeValue(T value)

Methods inherited from class Object

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

Constructor Detail

SerializedValuesHolder

public SerializedValuesHolder(BlockId blockId,
                              int chunkSize,
                              scala.reflect.ClassTag<T> classTag,
                              org.apache.spark.memory.MemoryMode memoryMode,
                              org.apache.spark.serializer.SerializerManager serializerManager)

Method Detail

allocator

public scala.Function1<Object,java.nio.ByteBuffer> allocator()

bbos

public org.apache.spark.util.io.ChunkedByteBufferOutputStream bbos()

estimatedSize

public long estimatedSize()

Specified by:

estimatedSize in interface ValuesHolder<T>

getBuilder

public MemoryEntryBuilder<T> getBuilder()

Description copied from interface: ValuesHolder

Note: After this method is called, the ValuesHolder is invalid, we can't store data and get estimate size again.

Specified by:

getBuilder in interface ValuesHolder<T>

Returns:

a MemoryEntryBuilder which is used to build a memory entry and get the stored data size.

redirectableStream

public org.apache.spark.storage.memory.RedirectableOutputStream redirectableStream()

serializationStream

public SerializationStream serializationStream()

storeValue

public void storeValue(T value)

Specified by:

storeValue in interface ValuesHolder<T>