object CommittableOffsetBatch

Source
CommittableOffsetBatch.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CommittableOffsetBatch
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

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 asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. implicit def committableOffsetBatchShow[F[_]]: Show[CommittableOffsetBatch[F]]
  7. def empty[F[_]](implicit F: Applicative[F]): CommittableOffsetBatch[F]

    An empty CommittableOffsetBatch which does not include any offsets and commit will not commit offsets.

    An empty CommittableOffsetBatch which does not include any offsets and commit will not commit offsets. This can be used together with updated to create a batch from some offsets.

    See also

    CommittableOffsetBatch#fromFoldable

    CommittableOffsetBatch#fromFoldableOption

  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  10. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  11. def fromFoldable[F[_], G[_]](offsets: G[CommittableOffset[F]])(implicit F: ApplicativeError[F, Throwable], G: Foldable[G]): CommittableOffsetBatch[F]

    Creates a CommittableOffsetBatch from some CommittableOffsets, where the containing type has a Foldable instance.

    Creates a CommittableOffsetBatch from some CommittableOffsets, where the containing type has a Foldable instance. Guaranteed to be equivalent to the following, but implemented more efficiently.

    offsets.foldLeft(CommittableOffsetBatch.empty[F])(_ updated _)

    Note that just like for updated, offsets have to be in order per topic-partition.

    See also

    CommittableOffsetBatch#fromFoldableMap

    CommittableOffsetBatch#fromFoldableOption

  12. def fromFoldableMap[F[_], G[_], A](ga: G[A])(f: (A) => CommittableOffset[F])(implicit F: ApplicativeError[F, Throwable], G: Foldable[G]): CommittableOffsetBatch[F]

    Creates a CommittableOffsetBatch from a Foldable containing As, by applying f to each A to get the CommittableOffset.

    Creates a CommittableOffsetBatch from a Foldable containing As, by applying f to each A to get the CommittableOffset. Guaranteed to be equivalent to the following, but implemented more efficiently.

    ga.foldLeft(CommittableOffsetBatch.empty[F])(_ updated f(_))

    Note that just like for updated, offsets have to be in order per topic-partition.

    See also

    CommittableOffsetBatch#fromFoldable

    CommittableOffsetBatch#fromFoldableOption

  13. def fromFoldableOption[F[_], G[_]](offsets: G[Option[CommittableOffset[F]]])(implicit F: ApplicativeError[F, Throwable], G: Foldable[G]): CommittableOffsetBatch[F]

    Creates a CommittableOffsetBatch from some CommittableOffsets wrapped in Option, where the containing type has a Foldable instance.

    Creates a CommittableOffsetBatch from some CommittableOffsets wrapped in Option, where the containing type has a Foldable instance. Guaranteed to be equivalent to the following, but implemented more efficiently.

    offsets.foldLeft(CommittableOffsetBatch.empty[F]) {
      case (batch, Some(offset)) => batch.updated(offset)
      case (batch, None)         => batch
    }

    Note that just like for updated, offsets have to be in order per topic-partition.

    See also

    CommittableOffsetBatch#fromFoldable

    CommittableOffsetBatch#fromFoldableMap

  14. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  20. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  21. def toString(): String
    Definition Classes
    AnyRef → Any
  22. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped