bulk-cdk-core-base/io.airbyte.cdk/AirbyteConnectorRunnable

AirbyteConnectorRunnable

class AirbyteConnectorRunnable : Runnable(source)

AirbyteConnectorRunner tells Micronaut to use this Runnable as the entry point.

Constructors

AirbyteConnectorRunnable

constructor()

Properties

@Value(value = "${airbyte.connector.metadata.docker-repository}")

lateinit var connectorName: String

exceptionHandler

@Inject

lateinit var exceptionHandler: ExceptionHandler

@Value(value = "${airbyte.connector.operation}")

lateinit var operationName: String

operationProvider

@Inject

lateinit var operationProvider: Provider<Operation>

@Inject

lateinit var outputConsumer: OutputConsumer

Functions

open override fun run()