object HSerializer extends Serializable
- Alphabetic
- By Inheritance
- HSerializer
- Serializable
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def apply[T](implicit ev: HSerializer[T]): HSerializer[T]
- implicit def arraySerializer[T, C[_]](implicit arg0: HSerializer[T], arg1: ClassTag[T], arg2: (C[T]) ⇒ Seq[T]): HSerializer[C[T]]
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
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.
- implicit val booleanSerializer: HSerializer[Boolean]
- implicit val byteSerializer: HSerializer[Byte]
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- implicit val doubleSerializer: HSerializer[Double]
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
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)
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- implicit val floatSerializer: HSerializer[Float]
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
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)
- implicit val integerSerializer: HSerializer[Int]
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- implicit val jlBooleanSerializer: HSerializer[Boolean]
- implicit val jlByteSerializer: HSerializer[Byte]
- implicit val jlDoubleSerializer: HSerializer[Double]
- implicit val jlFloatSerializer: HSerializer[Float]
- implicit val jlIntegerSerializer: HSerializer[Integer]
- implicit val jlLongSerializer: HSerializer[Long]
- implicit val jlShortSerializer: HSerializer[Short]
- implicit val longSerializer: HSerializer[Long]
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- implicit val shortSerializer: HSerializer[Short]
- implicit val stringSerializer: HSerializer[String]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()