object SerializersCache
Source: https://github.com/locationtech/rasterframes/blob/0.10.1/core/src/main/scala/org/locationtech/rasterframes/encoders/SerializersCache.scala
- Alphabetic
- By Inheritance
- SerializersCache
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
-
case class
SerializerSafe[T](underlying: Serializer[T]) extends Product with Serializable
SerializerSafe ensures that all Serializers from the pool call copy after application.
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
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clean(): Unit
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- def deserializer[T](implicit tag: scala.reflect.api.JavaUniverse.TypeTag[T], encoder: ExpressionEncoder[T]): Deserializer[T]
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
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()
-
def
rowDeserialize[T](implicit tag: scala.reflect.api.JavaUniverse.TypeTag[T], encoder: ExpressionEncoder[T]): (Row) ⇒ T
https://jaceklaskowski.gitbooks.io/mastering-spark-sql/content/spark-sql-RowEncoder.html https://github.com/apache/spark/blob/93cec49212fe82816fcadf69f429cebaec60e058/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala#L75-L86
- def rowDeserializer[T](implicit tag: scala.reflect.api.JavaUniverse.TypeTag[T], encoder: ExpressionEncoder[T]): Deserializer[Row]
- def rowSerialize[T](implicit tag: scala.reflect.api.JavaUniverse.TypeTag[T], encoder: ExpressionEncoder[T]): (T) ⇒ Row
- def rowSerializer[T](implicit tag: scala.reflect.api.JavaUniverse.TypeTag[T], encoder: ExpressionEncoder[T]): SerializerSafe[Row]
- def serializer[T](implicit tag: scala.reflect.api.JavaUniverse.TypeTag[T], encoder: ExpressionEncoder[T]): SerializerSafe[T]
-
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()