bulk-cdk-core-extract/io.airbyte.cdk.read/UnlimitedTimePartitionReader

UnlimitedTimePartitionReader

interface UnlimitedTimePartitionReader : PartitionReader

A PartitionReader with no time limit for its execution.

Functions

Link copied to clipboard
abstract fun checkpoint(): PartitionReadCheckpoint

Returns the forward progress made by the execution of run.

Link copied to clipboard
abstract fun releaseResources()

Called after run and checkpoint to release any resources acquired by tryAcquireResources.

Link copied to clipboard
abstract suspend fun run()

Reads the corresponding partition.

Link copied to clipboard
abstract fun tryAcquireResources(): PartitionReader.TryAcquireResourcesStatus

Called before run to try to acquire all the resources required for its execution. These may be, but are not limited to: