Package 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 Details

    • DeserializedValuesHolder

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

  • Method Details

    • 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()