ReadOperation

@Singleton

@Requires(property = "airbyte.connector.operation", value = "read")

@Requires(env = ["source"])

class ReadOperation(val config: SourceConfiguration, val configuredCatalog: ConfiguredAirbyteCatalog, val inputState: InputState, val stateManagerFactory: StateManagerFactory, val outputConsumer: StandardOutputConsumer, val metaFieldDecorator: MetaFieldDecorator, val resourceAcquirer: ResourceAcquirer, val partitionsCreatorFactoriesSupplier: List<PartitionsCreatorFactorySupplier<PartitionsCreatorFactory>>, @Value(value = "${airbyte.connector.data-channel.format}") val dataChannelFormat: String, @Value(value = "${airbyte.connector.data-channel.medium}") val dataChannelMedium: String, @Value(value = "${airbyte.connector.output.buffer-byte-size-threshold-for-flush:4096}") val bufferByteSizeThresholdForFlush: Int, clock: Clock) : Operation

Constructors

constructor(config: SourceConfiguration, configuredCatalog: ConfiguredAirbyteCatalog, inputState: InputState, stateManagerFactory: StateManagerFactory, outputConsumer: StandardOutputConsumer, metaFieldDecorator: MetaFieldDecorator, resourceAcquirer: ResourceAcquirer, partitionsCreatorFactoriesSupplier: List<PartitionsCreatorFactorySupplier<PartitionsCreatorFactory>>, @Value(value = "${airbyte.connector.data-channel.format}") dataChannelFormat: String, @Value(value = "${airbyte.connector.data-channel.medium}") dataChannelMedium: String, @Value(value = "${airbyte.connector.output.buffer-byte-size-threshold-for-flush:4096}") bufferByteSizeThresholdForFlush: Int, clock: Clock)