abstract class CommittableRecord extends AnyRef
- Source
- CommittableRecord.scala
- Alphabetic
- By Inheritance
- CommittableRecord
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
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
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 eithertryToCheckpoint
orforceCheckpoint
will succeed. -
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- 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(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )