DynamoDbBackfillOperator

class DynamoDbBackfillOperator<I : Any, P : Any>(dynamoDbClient: DynamoDbClient, backfill: DynamoDbBackfill<I, P>, parametersOperator: BackfilaParametersOperator<P>, keyRangeCodec: DynamoDbKeyRangeCodec) : BackfillOperator

Functions

getNextBatchRange
Link copied to clipboard
open override fun getNextBatchRange(request: GetNextBatchRangeRequest): GetNextBatchRangeResponse
name
Link copied to clipboard
open override fun name(): String
prepareBackfill
Link copied to clipboard
open override fun prepareBackfill(request: PrepareBackfillRequest): PrepareBackfillResponse
runBatch
Link copied to clipboard
open override fun runBatch(request: RunBatchRequest): RunBatchResponse

Properties

backfill
Link copied to clipboard
open override val backfill: DynamoDbBackfill<I, P>