Packages

object Coder extends CoderGrammar with TupleCoders with AvroCoders with ProtobufCoders with AlgebirdCoders with GuavaCoders with JodaCoders with BeamTypeCoders with LowPriorityCoders with Serializable

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Coder
  2. Serializable
  3. LowPriorityCoders
  4. LowPriorityCoderDerivation
  5. BeamTypeCoders
  6. JodaCoders
  7. GuavaCoders
  8. AlgebirdCoders
  9. ProtobufCoders
  10. AvroCoders
  11. TupleCoders
  12. CoderGrammar
  13. AnyRef
  14. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. type Typeclass[T] = Coder[T]
    Definition Classes
    LowPriorityCoderDerivation

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. final def apply[T](implicit c: Coder[T]): Coder[T]
    Annotations
    @inline()
  5. implicit def arrayBufferCoder[T](implicit arg0: Coder[T]): Coder[ArrayBuffer[T]]
  6. implicit val 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 avroGenericRecordCoder: Coder[GenericRecord]
    Definition Classes
    AvroCoders
  10. def avroGenericRecordCoder(schema: Schema): Coder[GenericRecord]

    Create a Coder for Avro GenericRecord given the schema of the GenericRecord.

    Create a Coder for Avro GenericRecord given the schema of the GenericRecord.

    schema

    AvroSchema for the Coder.

    returns

    Coder[GenericRecord]

    Definition Classes
    AvroCoders
  11. implicit def avroSpecificFixedCoder[T <: SpecificFixed](implicit arg0: ClassTag[T]): Coder[T]
    Definition Classes
    AvroCoders
  12. implicit def batchedCoder[U]: Coder[Batched[U]]
    Definition Classes
    AlgebirdCoders
  13. def beam[T](beam: org.apache.beam.sdk.coders.Coder[T]): Coder[T]
    Definition Classes
    CoderGrammar
  14. implicit def beamKVCoder[K, V](implicit arg0: Coder[K], arg1: Coder[V]): Coder[KV[K, V]]
    Definition Classes
    BeamTypeCoders
  15. implicit def bfCoder[K]: Coder[BF[K]]
    Definition Classes
    AlgebirdCoders
  16. implicit val bigDecimalCoder: Coder[BigDecimal]
  17. implicit val bigIntCoder: Coder[BigInt]
  18. implicit val bitSetCoder: Coder[BitSet]
  19. implicit val booleanCoder: Coder[Boolean]
  20. implicit def boundedWindowCoder: Coder[BoundedWindow]
    Definition Classes
    BeamTypeCoders
  21. implicit def bufferCoder[T](implicit arg0: Coder[T]): Coder[Buffer[T]]
  22. implicit val byteCoder: Coder[Byte]
  23. implicit def bytestringCoder: Coder[ByteString]
    Definition Classes
    ProtobufCoders
  24. implicit val charCoder: Coder[Char]
  25. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  26. implicit def cmsCoder[K]: Coder[CMS[K]]
    Definition Classes
    AlgebirdCoders
  27. implicit def coderJEnum[E <: Enum[E]](implicit arg0: ClassTag[E]): Coder[E]
  28. def combine[T](ctx: CaseClass[Coder, T]): Coder[T]
    Definition Classes
    LowPriorityCoderDerivation
  29. def disjunction[T, Id](typeName: String, coder: Map[Id, Coder[T]])(id: (T) => Id)(implicit arg0: Coder[Id]): Coder[T]
    Definition Classes
    CoderGrammar
  30. def dispatch[T](sealedTrait: SealedTrait[Coder, T]): Coder[T]
    Definition Classes
    LowPriorityCoderDerivation
  31. implicit val doubleCoder: Coder[Double]
  32. implicit def eitherCoder[A, B](implicit arg0: Coder[A], arg1: Coder[B]): Coder[Either[A, B]]
  33. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  34. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  35. macro def fallback[T](implicit lp: LowPriority): Coder[T]
  36. implicit val floatCoder: Coder[Float]
  37. implicit 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.

    In case of a missing shapeless.LowPriority implicit error when calling this method as , it means that Scio is unable to derive a BeamCoder for some parameter [P] in the constructor of Type. This happens when no implicit Coder instance for type P is in scope. This is fixed by placing an implicit Coder of type P in scope, using or defining the Coder manually (see also Coder.xmap)

    Definition Classes
    LowPriorityCoderDerivation
  38. implicit macro def genAvro[T <: SpecificRecordBase]: Coder[T]
    Definition Classes
    AvroCoders
  39. implicit def genericJsonCoder[T <: GenericJson](implicit arg0: ClassTag[T]): Coder[T]
    Definition Classes
    BeamTypeCoders
  40. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  41. implicit def guavaBFCoder[T](implicit x: Funnel[T]): Coder[BloomFilter[T]]
    Definition Classes
    GuavaCoders
  42. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  43. implicit def instantCoder: Coder[Instant]
    Definition Classes
    JodaCoders
  44. implicit val intCoder: Coder[Int]
  45. implicit def intervalWindowCoder: Coder[IntervalWindow]
    Definition Classes
    BeamTypeCoders
  46. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  47. implicit def iterableCoder[T](implicit arg0: Coder[T]): Coder[Iterable[T]]
  48. implicit def iterableOnceCoder[T](implicit arg0: Coder[T]): Coder[IterableOnce[T]]
  49. implicit def jArrayListCoder[T](implicit arg0: Coder[T]): Coder[ArrayList[T]]
  50. implicit val jBigDecimalCoder: Coder[BigDecimal]
  51. implicit val jBigIntegerCoder: Coder[BigInteger]
  52. implicit val jBitSetCoder: Coder[BitSet]
  53. implicit val jBooleanCoder: Coder[Boolean]
  54. implicit val jByteCoder: Coder[Byte]
  55. implicit val jDoubleCoder: Coder[Double]
  56. implicit val jDurationCoder: Coder[Duration]
  57. implicit val jFloatCoder: Coder[Float]
  58. implicit val jInstantCoder: Coder[Instant]
  59. implicit val jIntegerCoder: Coder[Integer]
  60. implicit def jIterableCoder[T](implicit arg0: Coder[T]): Coder[Iterable[T]]
  61. implicit val jLocalDateCoder: Coder[LocalDate]
  62. implicit val jLocalDateTimeCoder: Coder[LocalDateTime]
  63. implicit val jLocalTimeCoder: Coder[LocalTime]
  64. implicit val jLongCoder: Coder[Long]
  65. implicit def jMapCoder[K, V](implicit arg0: Coder[K], arg1: Coder[V]): Coder[Map[K, V]]
  66. implicit val jPeriodCoder: Coder[Period]
  67. implicit val jShortCoder: Coder[Short]
  68. implicit val jSqlTimestamp: Coder[Timestamp]
  69. implicit def jTryCoder[A](implicit c: Coder[Try[A]]): Coder[Try[A]]
  70. implicit def javaBeanCoder[T](implicit arg0: IsJavaBean[T], arg1: ClassTag[T]): Coder[T]
    Definition Classes
    LowPriorityCoders
  71. implicit def jlistCoder[T](implicit arg0: Coder[T]): Coder[List[T]]
  72. implicit def jodaDateTimeCoder: Coder[DateTime]
    Definition Classes
    JodaCoders
  73. implicit def jodaDurationCoder: Coder[Duration]
    Definition Classes
    JodaCoders
  74. implicit def jodaLocalDateCoder: Coder[LocalDate]
    Definition Classes
    JodaCoders
  75. implicit def jodaLocalDateTimeCoder: Coder[LocalDateTime]
    Definition Classes
    JodaCoders
  76. implicit def jodaLocalTimeCoder: Coder[LocalTime]
    Definition Classes
    JodaCoders
  77. 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
  78. def kv[K, V](koder: Coder[K], voder: Coder[V]): Coder[KV[K, V]]
    Definition Classes
    CoderGrammar
  79. implicit def listBufferCoder[T](implicit arg0: Coder[T]): Coder[ListBuffer[T]]
  80. implicit def listCoder[T](implicit arg0: Coder[T]): Coder[List[T]]
  81. implicit val longCoder: Coder[Long]
  82. implicit def mapCoder[K, V](implicit arg0: Coder[K], arg1: Coder[V]): Coder[Map[K, V]]
  83. implicit def matchResultMetadataCoder: Coder[Metadata]
    Definition Classes
    BeamTypeCoders
  84. implicit def mutableMapCoder[K, V](implicit arg0: Coder[K], arg1: Coder[V]): Coder[Map[K, V]]
  85. implicit def mutableSetCoder[T](implicit arg0: Coder[T]): Coder[Set[T]]
  86. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  87. implicit val noneCoder: Coder[None.type]
  88. implicit val nothingCoder: Coder[Nothing]
  89. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  90. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  91. implicit def optionCoder[T, S[_] <: Option[_]](implicit arg0: Coder[T]): Coder[S[T]]
  92. implicit def paneInfoCoder: Coder[PaneInfo]
    Definition Classes
    BeamTypeCoders
  93. implicit val pathCoder: Coder[Path]
  94. implicit def protoMessageCoder[T <: Message](implicit arg0: ClassTag[T]): Coder[T]
    Definition Classes
    ProtobufCoders
  95. 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
  96. implicit def readableFileCoder: Coder[ReadableFile]
    Definition Classes
    BeamTypeCoders
  97. def row(schema: Schema): Coder[Row]
    Definition Classes
    BeamTypeCoders
  98. implicit def seqCoder[T](implicit arg0: Coder[T]): Coder[Seq[T]]
  99. implicit val serializableCoder: Coder[Serializable]
  100. implicit def setCoder[T](implicit arg0: Coder[T]): Coder[Set[T]]
  101. implicit val shortCoder: Coder[Short]
  102. implicit def sortedSetCoder[T](implicit arg0: Coder[T], arg1: Ordering[T]): Coder[SortedSet[T]]
  103. implicit val stringCoder: Coder[String]
  104. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  105. implicit def throwableCoder[T <: Throwable](implicit arg0: ClassTag[T]): Coder[T]
  106. def toString(): String
    Definition Classes
    AnyRef → Any
  107. implicit def topKCoder[K]: Coder[TopK[K]]
    Definition Classes
    AlgebirdCoders
  108. def transform[A, B](c: Coder[A])(f: (org.apache.beam.sdk.coders.Coder[A]) => Coder[B]): Coder[B]
    Definition Classes
    CoderGrammar
  109. implicit def tryCoder[A](implicit arg0: Coder[A]): Coder[Try[A]]
  110. implicit def tuple10Coder[A, B, C, D, E, G, H, I, J, K](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I], CJ: Coder[J], CK: Coder[K]): Coder[(A, B, C, D, E, G, H, I, J, K)]
    Definition Classes
    TupleCoders
  111. implicit def tuple11Coder[A, B, C, D, E, G, H, I, J, K, L](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I], CJ: Coder[J], CK: Coder[K], CL: Coder[L]): Coder[(A, B, C, D, E, G, H, I, J, K, L)]
    Definition Classes
    TupleCoders
  112. implicit def tuple12Coder[A, B, C, D, E, G, H, I, J, K, L, M](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I], CJ: Coder[J], CK: Coder[K], CL: Coder[L], CM: Coder[M]): Coder[(A, B, C, D, E, G, H, I, J, K, L, M)]
    Definition Classes
    TupleCoders
  113. implicit def tuple13Coder[A, B, C, D, E, G, H, I, J, K, L, M, N](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I], CJ: Coder[J], CK: Coder[K], CL: Coder[L], CM: Coder[M], CN: Coder[N]): Coder[(A, B, C, D, E, G, H, I, J, K, L, M, N)]
    Definition Classes
    TupleCoders
  114. implicit def tuple14Coder[A, B, C, D, E, G, H, I, J, K, L, M, N, O](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I], CJ: Coder[J], CK: Coder[K], CL: Coder[L], CM: Coder[M], CN: Coder[N], CO: Coder[O]): Coder[(A, B, C, D, E, G, H, I, J, K, L, M, N, O)]
    Definition Classes
    TupleCoders
  115. implicit def tuple15Coder[A, B, C, D, E, G, H, I, J, K, L, M, N, O, P](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I], CJ: Coder[J], CK: Coder[K], CL: Coder[L], CM: Coder[M], CN: Coder[N], CO: Coder[O], CP: Coder[P]): Coder[(A, B, C, D, E, G, H, I, J, K, L, M, N, O, P)]
    Definition Classes
    TupleCoders
  116. implicit def tuple16Coder[A, B, C, D, E, G, H, I, J, K, L, M, N, O, P, Q](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I], CJ: Coder[J], CK: Coder[K], CL: Coder[L], CM: Coder[M], CN: Coder[N], CO: Coder[O], CP: Coder[P], CQ: Coder[Q]): Coder[(A, B, C, D, E, G, H, I, J, K, L, M, N, O, P, Q)]
    Definition Classes
    TupleCoders
  117. implicit def tuple17Coder[A, B, C, D, E, G, H, I, J, K, L, M, N, O, P, Q, R](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I], CJ: Coder[J], CK: Coder[K], CL: Coder[L], CM: Coder[M], CN: Coder[N], CO: Coder[O], CP: Coder[P], CQ: Coder[Q], CR: Coder[R]): Coder[(A, B, C, D, E, G, H, I, J, K, L, M, N, O, P, Q, R)]
    Definition Classes
    TupleCoders
  118. implicit def tuple18Coder[A, B, C, D, E, G, H, I, J, K, L, M, N, O, P, Q, R, S](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I], CJ: Coder[J], CK: Coder[K], CL: Coder[L], CM: Coder[M], CN: Coder[N], CO: Coder[O], CP: Coder[P], CQ: Coder[Q], CR: Coder[R], CS: Coder[S]): Coder[(A, B, C, D, E, G, H, I, J, K, L, M, N, O, P, Q, R, S)]
    Definition Classes
    TupleCoders
  119. implicit def tuple19Coder[A, B, C, D, E, G, H, I, J, K, L, M, N, O, P, Q, R, S, T](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I], CJ: Coder[J], CK: Coder[K], CL: Coder[L], CM: Coder[M], CN: Coder[N], CO: Coder[O], CP: Coder[P], CQ: Coder[Q], CR: Coder[R], CS: Coder[S], CT: Coder[T]): Coder[(A, B, C, D, E, G, H, I, J, K, L, M, N, O, P, Q, R, S, T)]
    Definition Classes
    TupleCoders
  120. implicit def tuple20Coder[A, B, C, D, E, G, H, I, J, K, L, M, N, O, P, Q, R, S, T, U](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I], CJ: Coder[J], CK: Coder[K], CL: Coder[L], CM: Coder[M], CN: Coder[N], CO: Coder[O], CP: Coder[P], CQ: Coder[Q], CR: Coder[R], CS: Coder[S], CT: Coder[T], CU: Coder[U]): Coder[(A, B, C, D, E, G, H, I, J, K, L, M, N, O, P, Q, R, S, T, U)]
    Definition Classes
    TupleCoders
  121. implicit def tuple21Coder[A, B, C, D, E, G, H, I, J, K, L, M, N, O, P, Q, R, S, T, U, V](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I], CJ: Coder[J], CK: Coder[K], CL: Coder[L], CM: Coder[M], CN: Coder[N], CO: Coder[O], CP: Coder[P], CQ: Coder[Q], CR: Coder[R], CS: Coder[S], CT: Coder[T], CU: Coder[U], CV: Coder[V]): Coder[(A, B, C, D, E, G, H, I, J, K, L, M, N, O, P, Q, R, S, T, U, V)]
    Definition Classes
    TupleCoders
  122. implicit def tuple22Coder[A, B, C, D, E, G, H, I, J, K, L, M, N, O, P, Q, R, S, T, U, V, W](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I], CJ: Coder[J], CK: Coder[K], CL: Coder[L], CM: Coder[M], CN: Coder[N], CO: Coder[O], CP: Coder[P], CQ: Coder[Q], CR: Coder[R], CS: Coder[S], CT: Coder[T], CU: Coder[U], CV: Coder[V], CW: Coder[W]): Coder[(A, B, C, D, E, G, H, I, J, K, L, M, N, O, P, Q, R, S, T, U, V, W)]
    Definition Classes
    TupleCoders
  123. implicit def tuple2Coder[A, B](implicit CA: Coder[A], CB: Coder[B]): Coder[(A, B)]
    Definition Classes
    TupleCoders
  124. implicit def tuple3Coder[A, B, C](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C]): Coder[(A, B, C)]
    Definition Classes
    TupleCoders
  125. implicit def tuple4Coder[A, B, C, D](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D]): Coder[(A, B, C, D)]
    Definition Classes
    TupleCoders
  126. implicit def tuple5Coder[A, B, C, D, E](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E]): Coder[(A, B, C, D, E)]
    Definition Classes
    TupleCoders
  127. implicit def tuple6Coder[A, B, C, D, E, G](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G]): Coder[(A, B, C, D, E, G)]
    Definition Classes
    TupleCoders
  128. implicit def tuple7Coder[A, B, C, D, E, G, H](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H]): Coder[(A, B, C, D, E, G, H)]
    Definition Classes
    TupleCoders
  129. implicit def tuple8Coder[A, B, C, D, E, G, H, I](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I]): Coder[(A, B, C, D, E, G, H, I)]
    Definition Classes
    TupleCoders
  130. implicit def tuple9Coder[A, B, C, D, E, G, H, I, J](implicit CA: Coder[A], CB: Coder[B], CC: Coder[C], CD: Coder[D], CE: Coder[E], CG: Coder[G], CH: Coder[H], CI: Coder[I], CJ: Coder[J]): Coder[(A, B, C, D, E, G, H, I, J)]
    Definition Classes
    TupleCoders
  131. implicit val unitCoder: Coder[Unit]
  132. implicit val uriCoder: Coder[URI]
  133. implicit def vectorCoder[T](implicit arg0: Coder[T]): Coder[Vector[T]]
  134. implicit val voidCoder: Coder[Void]
  135. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  136. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  137. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  138. implicit def wrappedArrayCoder[T](implicit arg0: Coder[T], arg1: ClassTag[T], wrap: (Array[T]) => WrappedArray[T]): Coder[WrappedArray[T]]
  139. def xmap[A, B](c: Coder[A])(f: (A) => B, t: (B) => A): Coder[B]

    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

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

Inherited from Serializable

Inherited from LowPriorityCoders

Inherited from BeamTypeCoders

Inherited from JodaCoders

Inherited from GuavaCoders

Inherited from AlgebirdCoders

Inherited from ProtobufCoders

Inherited from AvroCoders

Inherited from TupleCoders

Inherited from CoderGrammar

Inherited from AnyRef

Inherited from Any

Ungrouped