Class SerializerHelper

Object
org.apache.spark.serializer.SerializerHelper

public class SerializerHelper extends Object
  • Constructor Details

    • SerializerHelper

      public SerializerHelper()
  • Method Details

    • serializeToChunkedBuffer

      public static <T> org.apache.spark.util.io.ChunkedByteBuffer serializeToChunkedBuffer(SerializerInstance serializerInstance, T objectToSerialize, long estimatedSize, scala.reflect.ClassTag<T> evidence$1)
      Parameters:
      serializerInstance - instance of SerializerInstance
      objectToSerialize - the object to serialize, of type T
      estimatedSize - estimated size of t, used as a hint to choose proper chunk size
      evidence$1 - (undocumented)
      Returns:
      (undocumented)
    • deserializeFromChunkedBuffer

      public static <T> T deserializeFromChunkedBuffer(SerializerInstance serializerInstance, org.apache.spark.util.io.ChunkedByteBuffer bytes, scala.reflect.ClassTag<T> evidence$2)
    • org$apache$spark$internal$Logging$$log_

      public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()
    • org$apache$spark$internal$Logging$$log__$eq

      public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
    • LogStringContext

      public static org.apache.spark.internal.Logging.LogStringContext LogStringContext(scala.StringContext sc)