ReadOperation

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)