org.apache.spark.storage.memory

Class DeserializedValuesHolder<T>

Object

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

All Implemented Interfaces:

ValuesHolder<T>

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

A holder for storing the deserialized values.

Constructor Summary

Constructors

Constructor and Description
DeserializedValuesHolder(scala.reflect.ClassTag<T> classTag, org.apache.spark.memory.MemoryMode memoryMode)

Method Summary

Modifier and Type	Method and Description
Object	arrayValues()
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.
void	storeValue(T value)
org.apache.spark.util.collection.SizeTrackingVector<T>	vector()

Methods inherited from class Object

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

Constructor Detail

DeserializedValuesHolder

public DeserializedValuesHolder(scala.reflect.ClassTag<T> classTag,
                                org.apache.spark.memory.MemoryMode memoryMode)

Method Detail

arrayValues

public Object arrayValues()

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.

storeValue

public void storeValue(T value)

Specified by:

storeValue in interface ValuesHolder<T>

vector

public org.apache.spark.util.collection.SizeTrackingVector<T> vector()