package coders
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- trait AnnotatedKryoRegistrar extends AnyRef
Trait to be added to Kryo registrar class annotated with
@KryoRegistrar. - final case class Beam[T] extends Coder[T] with Product with Serializable
- sealed trait Coder[T] extends Serializable
- Annotations
- @implicitNotFound()
- 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
- final case class CoderTransform[T, U] extends Coder[T] with Product with Serializable
- final case class Disjunction[T, Id] extends Coder[T] with Product with Serializable
- final case class Fallback[T] extends Coder[T] with Product with Serializable
- final case class KVCoder[K, V] extends Coder[KV[K, V]] with Product with Serializable
- macro class KryoRegistrar extends Annotation with StaticAnnotation
Annotation for custom Kryo registrar classes.
Annotation for custom Kryo registrar classes.
Annotated class must extend
IKryoRegistrarand has name that ends with "KryoRegistrar".- Annotations
- @compileTimeOnly("enable macro paradise (2.12) or -Ymacro-annotations (2.13) to expand macro annotations")
- trait LowPriorityCoderDerivation extends AnyRef
- trait LowPriorityCoders extends LowPriorityCoderDerivation
- final case class RawBeam[T] extends Coder[T] with Product with Serializable
- final case class Record[T] extends Coder[T] with Product with Serializable
- final case class Transform[T, U] extends Coder[T] with Product with Serializable
Value Members
- object Coder extends CoderGrammar with TupleCoders with AvroCoders with ProtobufCoders with AlgebirdCoders with GuavaCoders with JodaCoders with BeamTypeCoders with LowPriorityCoders with Serializable
- object CoderMaterializer
- object LowPriorityCoderDerivation
- object ScioKryoRegistrar extends Serializable