bulk-cdk-core-base/io.airbyte.cdk.output/StdoutOutputConsumer

StdoutOutputConsumer

@Singleton

@Secondary

class StdoutOutputConsumer(val stdout: PrintStream, clock: Clock, @Value(value = "${airbyte.connector.output.buffer-byte-size-threshold-for-flush:4096}") val bufferByteSizeThresholdForFlush: Int) : StandardOutputConsumer(source)

Default implementation of OutputConsumer.

Constructors

StdoutOutputConsumer

constructor(stdout: PrintStream, clock: Clock, @Value(value = "${airbyte.connector.output.buffer-byte-size-threshold-for-flush:4096}") bufferByteSizeThresholdForFlush: Int)

Properties

bufferByteSizeThresholdForFlush

val bufferByteSizeThresholdForFlush: Int

bufferByteSizeThresholdForFlush triggers flushing the record buffer to stdout once the buffer's size (in bytes) grows past this value.

recordEmittedAt

val recordEmittedAt: Instant

The constant emittedAt timestamp we use for record timestamps.

val stdout: PrintStream

Functions

open override fun accept(airbyteMessage: AirbyteMessage)

fun accept(analytics: AirbyteAnalyticsTraceMessage)

fun accept(catalog: AirbyteCatalog)

fun accept(status: AirbyteConnectionStatus)

fun accept(error: AirbyteErrorTraceMessage)

fun accept(estimate: AirbyteEstimateTraceMessage)

fun accept(log: AirbyteLogMessage)

fun accept(state: AirbyteStateMessage)

fun accept(streamStatus: AirbyteStreamStatusTraceMessage)

fun accept(trace: AirbyteTraceMessage)

fun accept(spec: ConnectorSpecification)

fun accept(destinationCatalog: DestinationCatalog)

open override fun accept(record: AirbyteRecordMessage)

open fun andThen(after: Consumer<in AirbyteMessage?>?): Consumer<AirbyteMessage?>?

open override fun close()

open override fun withLockFlush()