DynamoDbBackfill

abstract class DynamoDbBackfill : Backfill

Functions

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

abstract fun runBatch(items: List, config: BackfillConfig)

Called for each batch of matching records.

validate

open fun validate(config: BackfillConfig)

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

dynamoDbTable

val dynamoDbTable: DynamoDbTable

itemType

UpdateInPlaceDynamoDbBackfill