Packages

abstract class CommittableRecord extends AnyRef

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

Abstract Value Members

  1. abstract def forceCheckpoint(): Unit

    Basic checkpoint method, the caller should decide if it's safe to invoke it.

    Basic checkpoint method, the caller should decide if it's safe to invoke it. The method will throw any internal Exception.

    This method will potentially perform IO actions. Wrap accordingly in an IO Data Type if needed.

    See software.amazon.kinesis.processor.RecordProcessorCheckpointer

  2. abstract def shutdownReason: Option[ShutdownReason]

    Returns the ShutdownReason of the related software.amazon.kinesis.processor.ShardRecordProcessor, if any.

Concrete 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. val batchData: BatchData
  6. def canBeCheckpointed: Boolean

    Helper method that tells the caller if it's safe to invoke forceCheckpoint or not.

    Helper method that tells the caller if it's safe to invoke forceCheckpoint or not. It doesn't guarantee that invocations to either tryToCheckpoint or forceCheckpoint will succeed.

  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  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. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. val processorData: ShardProcessorData
  18. val record: KinesisClientRecord
  19. val sequenceNumber: String
  20. val subSequenceNumber: Long
  21. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. def tryToCheckpoint(): Unit

    Safe checkpoint method, that will only attempt to checkpoint if the lease has not been lost and will capture expected Exceptions (that may still occur due to unavoidable race conditions).

    Safe checkpoint method, that will only attempt to checkpoint if the lease has not been lost and will capture expected Exceptions (that may still occur due to unavoidable race conditions). The method will still throw critical Exceptions.

    This method will potentially perform IO actions. Wrap accordingly in an IO Data Type if needed.

    See software.amazon.kinesis.processor.RecordProcessorCheckpointer

  24. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  26. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped