Packages

package coders

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package instances

Type Members

  1. trait AnnotatedKryoRegistrar extends AnyRef

    Trait to be added to Kryo registrar class annotated with @KryoRegistrar.

  2. final case class Beam[T] extends Coder[T] with Product with Serializable
  3. sealed trait Coder[T] extends Serializable
    Annotations
    @implicitNotFound()
  4. sealed trait CoderGrammar extends AnyRef

    Coder Grammar is used to explicitly specify Coder derivation for types used in pipelines.

    Coder Grammar is used to explicitly specify Coder derivation for types used in pipelines.

    The CoderGrammar can be used as follows:

    • To find the Coder being implicitly derived by Scio. (Debugging)
    def c: Coder[MyType] = Coder[MyType]
    • To generate an implicit instance to be in scope for type T, use Coder.gen
    implicit def coderT: Coder[T] = Coder.gen[T]

    Note: Implicit Coders for all parameters of the constructor of type T should be in scope for Coder.gen to be able to derive the Coder.

    • To define a Coder of custom type, where the type can be mapped to some other type for which a Coder is known, use Coder.xmap
    • To explicitly use kryo Coder use Coder.kryo
  5. final case class Disjunction[T, Id] extends Coder[T] with Product with Serializable
  6. final case class Fallback[T] extends Coder[T] with Product with Serializable
  7. final case class KVCoder[K, V] extends Coder[KV[K, V]] with Product with Serializable
  8. macro class KryoRegistrar extends Annotation with StaticAnnotation

    Annotation for custom Kryo registrar classes.

    Annotation for custom Kryo registrar classes.

    Annotated class must extend IKryoRegistrar and has name that ends with "KryoRegistrar".

    Annotations
    @compileTimeOnly("enable macro paradise (2.12) or -Ymacro-annotations (2.13) to expand macro annotations")
  9. trait LowPriorityCoderDerivation extends AnyRef
  10. trait LowPriorityCoders extends LowPriorityCoderDerivation
  11. final case class RawBeam[T] extends Coder[T] with Product with Serializable
  12. final case class Record[T] extends Coder[T] with Product with Serializable
  13. final case class Transform[A, B] extends Coder[B] with Product with Serializable

Value Members

  1. object Coder extends CoderGrammar with TupleCoders with AvroCoders with ProtobufCoders with AlgebirdCoders with GuavaCoders with JodaCoders with BeamTypeCoders with LowPriorityCoders with Serializable
  2. object CoderMaterializer
  3. object ScioKryoRegistrar extends Serializable

Ungrouped