Packages

o

akka.projection.dynamodb.scaladsl

DynamoDBProjection

object DynamoDBProjection

Annotations
@ApiMayChange()
Source
DynamoDBProjection.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DynamoDBProjection
  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 atLeastOnce[Offset, Envelope](projectionId: ProjectionId, settings: Option[DynamoDBProjectionSettings], sourceProvider: SourceProvider[Offset, Envelope], handler: () => Handler[Envelope])(implicit system: ActorSystem[_]): AtLeastOnceProjection[Offset, Envelope]

    Create a akka.projection.Projection with at-least-once processing semantics.

    Create a akka.projection.Projection with at-least-once processing semantics.

    It stores the offset in a DynamoDB table after the handler has processed the envelope. This means that if the projection is restarted from previously stored offset then some elements may be processed more than once.

    The offset is stored after a time window, or limited by a number of envelopes, whatever happens first. This window can be defined with akka.projection.scaladsl.AtLeastOnceProjection.withSaveOffset of the returned AtLeastOnceProjection. The default settings for the window is defined in configuration section akka.projection.at-least-once.

  6. def atLeastOnceFlow[Offset, Envelope](projectionId: ProjectionId, settings: Option[DynamoDBProjectionSettings], sourceProvider: SourceProvider[Offset, Envelope], handler: FlowWithContext[Envelope, ProjectionContext, Done, ProjectionContext, _])(implicit system: ActorSystem[_]): AtLeastOnceFlowProjection[Offset, Envelope]

    Create a akka.projection.Projection with a akka.stream.scaladsl.FlowWithContext as the envelope handler.

    Create a akka.projection.Projection with a akka.stream.scaladsl.FlowWithContext as the envelope handler. It has at-least-once processing semantics.

    The flow should emit a Done element for each completed envelope. The offset of the envelope is carried in the context of the FlowWithContext and is stored in the database when corresponding Done is emitted. Since the offset is stored after processing the envelope it means that if the projection is restarted from previously stored offset then some envelopes may be processed more than once.

    If the flow filters out envelopes the corresponding offset will not be stored, and such envelope will be processed again if the projection is restarted and no later offset was stored.

    The flow should not duplicate emitted envelopes (mapConcat) with same offset, because then it can result in that the first offset is stored and when the projection is restarted that offset is considered completed even though more of the duplicated envelopes were never processed.

    The flow must not reorder elements, because the offsets may be stored in the wrong order and when the projection is restarted all envelopes up to the latest stored offset are considered completed even though some of them may not have been processed. This is the reason the flow is restricted to FlowWithContext rather than ordinary Flow.

  7. def atLeastOnceGroupedWithin[Offset, Envelope](projectionId: ProjectionId, settings: Option[DynamoDBProjectionSettings], sourceProvider: SourceProvider[Offset, Envelope], handler: () => Handler[Seq[Envelope]])(implicit system: ActorSystem[_]): GroupedProjection[Offset, Envelope]

    Create a akka.projection.Projection that groups envelopes and calls the handler with a group of Envelopes.

    Create a akka.projection.Projection that groups envelopes and calls the handler with a group of Envelopes. The envelopes are grouped within a time window, or limited by a number of envelopes, whatever happens first. This window can be defined with akka.projection.scaladsl.GroupedProjection.withGroup of the returned GroupedProjection. The default settings for the window is defined in configuration section akka.projection.grouped.

    The offset is stored in DynamoDB immediately after the handler has processed the envelopes, but that is still with at-least-once processing semantics. This means that if the projection is restarted from previously stored offset the previous group of envelopes may be processed more than once.

  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  11. def exactlyOnce[Offset, Envelope](projectionId: ProjectionId, settings: Option[DynamoDBProjectionSettings], sourceProvider: SourceProvider[Offset, Envelope], handler: () => DynamoDBTransactHandler[Envelope])(implicit system: ActorSystem[_]): ExactlyOnceProjection[Offset, Envelope]

    Create a akka.projection.Projection with exactly-once processing semantics.

    Create a akka.projection.Projection with exactly-once processing semantics.

    The offset is stored in DynamoDB in the same transaction as the TransactWriteItems returned by the handler.

  12. def exactlyOnceGroupedWithin[Offset, Envelope](projectionId: ProjectionId, settings: Option[DynamoDBProjectionSettings], sourceProvider: SourceProvider[Offset, Envelope], handler: () => DynamoDBTransactHandler[Seq[Envelope]])(implicit system: ActorSystem[_]): GroupedProjection[Offset, Envelope]

    Create a akka.projection.Projection that groups envelopes and calls the handler with a group of Envelopes.

    Create a akka.projection.Projection that groups envelopes and calls the handler with a group of Envelopes. The envelopes are grouped within a time window, or limited by a number of envelopes, whatever happens first. This window can be defined with akka.projection.scaladsl.GroupedProjection.withGroup of the returned GroupedProjection. The default settings for the window is defined in configuration section akka.projection.grouped.

    The offset is stored in DynamoDB in the same transaction as the TransactWriteItems returned by the handler.

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

Deprecated Value Members

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

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped