abstract class CommittableRecord extends AnyRef
- Source
- CommittableRecord.scala
- Alphabetic
- By Inheritance
- CommittableRecord
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- 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
- abstract def shutdownReason: Option[ShutdownReason]
Returns the ShutdownReason of the related software.amazon.kinesis.processor.ShardRecordProcessor, if any.
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val batchData: BatchData
- def canBeCheckpointed: Boolean
Helper method that tells the caller if it's safe to invoke
forceCheckpointor not.Helper method that tells the caller if it's safe to invoke
forceCheckpointor not. It doesn't guarantee that invocations to eithertryToCheckpointorforceCheckpointwill succeed. - def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- val processorData: ShardProcessorData
- val record: KinesisClientRecord
- val sequenceNumber: String
- val subSequenceNumber: Long
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()