Packages

object HSerializer extends Serializable

Linear Supertypes
Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. HSerializer
  2. Serializable
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def apply[T](implicit ev: HSerializer[T]): HSerializer[T]
  5. implicit def arraySerializer[T, C[_]](implicit arg0: HSerializer[T], arg1: ClassTag[T], arg2: (C[T]) ⇒ Seq[T]): HSerializer[C[T]]
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. implicit def binarySerializer[C[_]](implicit ev: (C[Byte]) ⇒ Seq[Byte]): HSerializer[C[Byte]]

    Array of bytes is handled differently in between Spark / Hive comparing to the other Array types.

    Array of bytes is handled differently in between Spark / Hive comparing to the other Array types. The Spark DataType in this case corresponds to BinaryType, and no serialization is needed.

  8. implicit val booleanSerializer: HSerializer[Boolean]
  9. implicit val byteSerializer: HSerializer[Byte]
  10. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  11. implicit val doubleSerializer: HSerializer[Double]
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  14. def expressionEncoderSerializer[T](implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[T], enc: ExpressionEncoder[T]): HSerializer[T]

    Derive HSerializer from ExpressionEncoder.

    Derive HSerializer from ExpressionEncoder. Intentionally not used for instances implementation, causes the following failure on DataBricks; TypeTags are not Kryo serializable by default: org.apache.spark.SparkException: Job aborted due to stage failure: Task serialization failed: com.esotericsoftware.kryo.KryoException: java.util.ConcurrentModificationException Serialization trace: classes (sun.misc.Launcher$AppClassLoader) classloader (java.security.ProtectionDomain) context (java.security.AccessControlContext) acc (com.databricks.backend.daemon.driver.ClassLoaders$LibraryClassLoader) classLoader (scala.reflect.runtime.JavaMirrors$JavaMirror) mirror (scala.reflect.api.TypeTags$TypeTagImpl) tg$1 (com.azavea.hiveless.serializers.HSerializer$$anon$2)

  15. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  16. implicit val floatSerializer: HSerializer[Float]
  17. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  18. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  19. def instance[T](dt: DataType, s: (T) ⇒ Any): HSerializer[T]

    Intentionally not used for instances implementation, causes the following failure on DataBricks: Unable to find class: com.azavea.hiveless.serializers.HSerializer$$$Lambda$5659/1670981434 Serialization trace: s$1 (com.azavea.hiveless.serializers.HSerializer$$anon$1)

  20. implicit val integerSerializer: HSerializer[Int]
  21. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  22. implicit val jlBooleanSerializer: HSerializer[Boolean]
  23. implicit val jlByteSerializer: HSerializer[Byte]
  24. implicit val jlDoubleSerializer: HSerializer[Double]
  25. implicit val jlFloatSerializer: HSerializer[Float]
  26. implicit val jlIntegerSerializer: HSerializer[Integer]
  27. implicit val jlLongSerializer: HSerializer[Long]
  28. implicit val jlShortSerializer: HSerializer[Short]
  29. implicit val longSerializer: HSerializer[Long]
  30. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  31. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  32. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  33. implicit val shortSerializer: HSerializer[Short]
  34. implicit val stringSerializer: HSerializer[String]
  35. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  36. def toString(): String
    Definition Classes
    AnyRef → Any
  37. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  38. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  39. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped