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

RootReader

class RootReader(val stateManager: StateManager, val resourceAcquisitionHeartbeat: Duration, val timeout: Duration, val outputConsumer: StandardOutputConsumer, val metaFieldDecorator: MetaFieldDecorator, val resourceAcquirer: ResourceAcquirer, val partitionsCreatorFactories: List<PartitionsCreatorFactory>, val dataChannelFormat: DataChannelFormat, val dataChannelMedium: DataChannelMedium, val bufferByteSizeThresholdForFlush: Int, clock: Clock)

RootReader is at the heart of the READ operation. A RootReader manages multiple FeedReader instances (one per Feed) and synchronizes them using coroutines.

This object exists mainly to facilitate unit testing by keeping dependencies to a minimum.

Constructors

RootReader

constructor(stateManager: StateManager, resourceAcquisitionHeartbeat: Duration, timeout: Duration, outputConsumer: StandardOutputConsumer, metaFieldDecorator: MetaFieldDecorator, resourceAcquirer: ResourceAcquirer, partitionsCreatorFactories: List<PartitionsCreatorFactory>, dataChannelFormat: DataChannelFormat, dataChannelMedium: DataChannelMedium, bufferByteSizeThresholdForFlush: Int, clock: Clock)