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

JsonSocketEfficientStreamRecordConsumer

inner class JsonSocketEfficientStreamRecordConsumer(stream: Stream, outputer: OutputConsumer) : FeedBootstrap.EfficientStreamRecordConsumer(source)

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<EmittedField, FieldValueChange>?)

open override fun close()