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 aggregate[T](implicit arg0: Coder[T]): Coder[Iterable[T]]

   Definition Classes

   CoderGrammar

5.  implicit def arrayBufferCoder[T](implicit arg0: Coder[T]): Coder[ArrayBuffer[T]]
6.  implicit def arrayByteCoder: Coder[Array[Byte]]
7.  implicit def arrayCoder[T](implicit arg0: Coder[T], arg1: ClassTag[T]): Coder[Array[T]]
8.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

9.  def beam[T](beam: org.apache.beam.sdk.coders.Coder[T]): Coder[T]

   Definition Classes

   CoderGrammar

10.  implicit lazy val bigDecimalCoder: Coder[BigDecimal]
11.  implicit lazy val bigIntCoder: Coder[BigInt]
12.  implicit lazy val bitSetCoder: Coder[BitSet]
13.  implicit lazy val booleanCoder: Coder[Boolean]
14.  implicit def bufferCoder[T](implicit arg0: Coder[T]): Coder[Buffer[T]]
15.  implicit lazy val byteCoder: Coder[Byte]
16.  implicit lazy val charCoder: Coder[Char]
17.  def clone(): AnyRef

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.CloneNotSupportedException]) @native()

18.  def disjunction[T, Id](typeName: String, coder: Map[Id, Coder[T]])(id: (T) => Id)(implicit arg0: Coder[Id]): Coder[T]

    Definition Classes

    CoderGrammar

19.  implicit lazy val doubleCoder: Coder[Double]
20.  implicit def eitherCoder[A, B](implicit arg0: Coder[A], arg1: Coder[B]): Coder[Either[A, B]]
21.  implicit def enumerationCoder[E <: Enumeration](implicit arg0: ClassTag[E]): Coder[enumerationCoder.E.Value]
22.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

23.  def equals(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef → Any

24.  implicit def failureCoder[T]: Coder[Failure[T]]
25.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.Throwable])

26.  implicit lazy val floatCoder: Coder[Float]
27.  macro def gen[T]: Coder[T]

    Derive a Coder for a type T given implicit coders of all parameters in the constructor of type T is in scope.

    Derive a Coder for a type T given implicit coders of all parameters in the constructor of type T is in scope. For sealed trait, implicit coders of parameters of the constructors of all sub-types should be in scope.

    Definition Classes

    CoderDerivation

28.  final def getClass(): Class[_ <: AnyRef]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

29.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

30.  implicit lazy val intCoder: Coder[Int]
31.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

32.  implicit def iterableCoder[T](implicit arg0: Coder[T]): Coder[Iterable[T]]
33.  implicit def iterableOnceCoder[T](implicit arg0: Coder[T]): Coder[IterableOnce[T]]
34.  def join[T](ctx: CaseClass[Coder, T])(implicit arg0: ClassTag[T]): Coder[T]

    Definition Classes

    CoderDerivation

35.  def kryo[T](implicit ct: ClassTag[T]): Coder[T]

    Create an instance of Kryo Coder for a given Type.

    Create an instance of Kryo Coder for a given Type.

    Eg: A kryo Coder for org.joda.time.Interval would look like:

    implicit def jiKryo: Coder[Interval] = Coder.kryo[Interval]

    Definition Classes

    CoderGrammar

36.  def kv[K, V](koder: Coder[K], voder: Coder[V]): Coder[KV[K, V]]

    Definition Classes

    CoderGrammar

37.  implicit def leftCoder[A, B](implicit arg0: Coder[A]): Coder[Left[A, B]]
38.  implicit def listBufferCoder[T](implicit arg0: Coder[T]): Coder[ListBuffer[T]]
39.  implicit def listCoder[T](implicit arg0: Coder[T]): Coder[List[T]]
40.  implicit lazy val longCoder: Coder[Long]
41.  implicit def mapCoder[K, V](implicit arg0: Coder[K], arg1: Coder[V]): Coder[Map[K, V]]
42.  implicit def mutableMapCoder[K, V](implicit arg0: Coder[K], arg1: Coder[V]): Coder[Map[K, V]]
43.  implicit def mutableSetCoder[T](implicit arg0: Coder[T]): Coder[Set[T]]
44.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

45.  implicit lazy val noneCoder: Coder[None.type]
46.  implicit lazy val nothingCoder: Coder[Nothing]
47.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

48.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

49.  implicit def optionCoder[T](implicit arg0: Coder[T]): Coder[Option[T]]
50.  def raw[T](beam: org.apache.beam.sdk.coders.Coder[T]): Coder[T]

    Create a ScioCoder from a Beam Coder

    Create a ScioCoder from a Beam Coder

    Definition Classes

    CoderGrammar

51.  implicit def rightCoder[A, B](implicit arg0: Coder[B]): Coder[Right[A, B]]
52.  implicit def seqCoder[T](implicit arg0: Coder[T]): Coder[Seq[T]]
53.  implicit def setCoder[T](implicit arg0: Coder[T]): Coder[Set[T]]
54.  implicit lazy val shortCoder: Coder[Short]
55.  implicit def someCoder[T](implicit arg0: Coder[T]): Coder[Some[T]]
56.  implicit def sortedSetCoder[T](implicit arg0: Coder[T], arg1: Ordering[T]): Coder[SortedSet[T]]
57.  def split[T](sealedTrait: SealedTrait[Coder, T]): Coder[T]

    Definition Classes

    CoderDerivation

58.  implicit lazy val stringCoder: Coder[String]
59.  implicit def successCoder[T](implicit arg0: Coder[T]): Coder[Success[T]]
60.  final def synchronized[T0](arg0: => T0): T0

    Definition Classes

    AnyRef

61.  implicit def throwableCoder[T <: Throwable](implicit arg0: ClassTag[T]): Coder[T]
62.  def toString(): String

    Definition Classes

    AnyRef → Any

63.  def transform[U, T](c: Coder[U])(f: (org.apache.beam.sdk.coders.Coder[U]) => Coder[T])(implicit ct: ClassTag[T]): Coder[T]

    Definition Classes

    CoderGrammar

64.  implicit def tryCoder[T](implicit arg0: Coder[T]): Coder[Try[T]]
65.  implicit lazy val unitCoder: Coder[Unit]
66.  implicit def vectorCoder[T](implicit arg0: Coder[T]): Coder[Vector[T]]
67.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

68.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

69.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException]) @native()

70.  implicit def wrappedArrayCoder[T](implicit arg0: Coder[T], arg1: ClassTag[T], wrap: (Array[T]) => WrappedArray[T]): Coder[WrappedArray[T]]
71.  def xmap[U, T](c: Coder[U])(f: (U) => T, t: (T) => U)(implicit ct: ClassTag[T]): Coder[T]

    Given a Coder[A], create a Coder[B] by defining two functions A => B and B => A.

    Given a Coder[A], create a Coder[B] by defining two functions A => B and B => A. The Coder[A] can be resolved implicitly by calling Coder[A]

    Eg: Coder for org.joda.time.Interval can be defined by having the following implicit in scope. Without this implicit in scope Coder derivation falls back to Kryo.

    implicit def jiCoder: Coder[Interval] =
      Coder.xmap(Coder[(Long, Long)])(t => new Interval(t._1, t._2),
          i => (i.getStartMillis, i.getEndMillis))

    In the above example we implicitly derive Coder[(Long, Long)] and we define two functions, one to convert a tuple (Long, Long) to Interval, and a second one to convert an Interval to a tuple of (Long, Long)

    Definition Classes

    CoderGrammar