Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-core-extract/io.airbyte.cdk.read/FeedBootstrap/JsonSocketEfficientStreamRecordConsumer

JsonSocketEfficientStreamRecordConsumer

inner class JsonSocketEfficientStreamRecordConsumer(stream: Stream, outputer: OutputConsumer) : FeedBootstrap.EfficientStreamRecordConsumer<T>

Constructors

JsonSocketEfficientStreamRecordConsumer

constructor(stream: Stream, outputer: OutputConsumer)

Properties

outputDataChannel

val outputDataChannel: OutputConsumer

open override val stream: Stream

Functions

open override fun accept(recordData: NativeRecordPayload, changes: Map<Field, FieldValueChange>?)

open override fun close()