OutputConsumer

@DefaultImplementation(value = StdoutOutputConsumer::class)

abstract class OutputConsumer(clock: Clock) : Consumer<AirbyteMessage> , AutoCloseable

Emits the AirbyteMessage instances produced by the connector.

Constructors

constructor(clock: Clock)

The constant emittedAt timestamp we use for record timestamps.

fun accept(analytics: AirbyteAnalyticsTraceMessage)

fun accept(catalog: AirbyteCatalog)

fun accept(status: AirbyteConnectionStatus)

fun accept(error: AirbyteErrorTraceMessage)

fun accept(estimate: AirbyteEstimateTraceMessage)

fun accept(log: AirbyteLogMessage)

open fun accept(record: AirbyteRecordMessage)

fun accept(state: AirbyteStateMessage)

fun accept(streamStatus: AirbyteStreamStatusTraceMessage)

fun accept(trace: AirbyteTraceMessage)

fun accept(spec: ConnectorSpecification)

fun accept(destinationCatalog: DestinationCatalog)

abstract fun accept(p0: AirbyteMessage)

open fun andThen(p0: Consumer<in AirbyteMessage>): Consumer<AirbyteMessage>

abstract fun close()