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. All

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( ... ) @native() @HotSpotIntrinsicCandidate()
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  15. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  16. val processorData: ShardProcessorData
  17. val record: KinesisClientRecord
  18. val sequenceNumber: String
  19. val subSequenceNumber: Long
  20. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  21. def toString(): String
    Definition Classes
    AnyRef → Any
  22. def tryToCheckpoint(): Unit

    Safe checkpoint method, that will only attempt to checkpoint it 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 it 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

  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  25. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

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

    (Since version ) see corresponding Javadoc for more information.

Inherited from AnyRef

Inherited from Any

Ungrouped