UpdateInPlaceDynamoDbBackfill

abstract class UpdateInPlaceDynamoDbBackfill(dynamoDbClient: DynamoDbClient) : DynamoDbBackfill<I, P>

A base class that may make it easier to mutate the items in the DynamoDB store.

If saving fails the batch will fail. If succeeded rows are part of a failed batch they will be retried so implementations must be idempotent.

Constructors

fun UpdateInPlaceDynamoDbBackfill(dynamoDbClient: DynamoDbClient)

dynamoDbTable

abstract fun dynamoDbTable(): DynamoDbTable

Provides the table schema so Backfila knows the type and where the table is.

expressionAttributeValues

open fun expressionAttributeValues(config: BackfillConfig): Map<String, AttributeValue>?

See ScanRequest.

filterExpression

open fun filterExpression(config: BackfillConfig): String?

See ScanRequest.

fixedSegmentCount

open fun fixedSegmentCount(config: BackfillConfig): Int?

Override this to force Backfila to run this number of batches in total, divided among the partitions.

mustHaveProvisionedBillingMode

It is rather easy to run a backfill against a dynamo instance that is configured expensively.

partitionCount

open fun partitionCount(config: BackfillConfig): Int

The number of independent workers to perform the backfill.

runBatch

open override fun runBatch(items: List, config: BackfillConfig)

Called for each batch of matching records.

runOne

abstract fun runOne(item: I, config: BackfillConfig): Boolean

Called for each matching record.

validate

open fun validate(config: BackfillConfig)

Override this and throw an exception to prevent the backfill from being created.

dynamoDbClient

val dynamoDbClient: DynamoDbClient

dynamoDbTable

val dynamoDbTable: DynamoDbTable

itemType