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

ProtoEfficientStreamRecordConsumer

inner class ProtoEfficientStreamRecordConsumer(val stream: Stream, socketProtobufOutputConsumer: SocketProtobufOutputConsumer) : StreamRecordConsumer

Constructors

Link copied to clipboard
constructor(stream: Stream, socketProtobufOutputConsumer: SocketProtobufOutputConsumer)

Properties

Link copied to clipboard
val reusedMessageWithoutChanges: AirbyteMessage.AirbyteMessageProtobuf.Builder
Link copied to clipboard
open override val stream: Stream
Link copied to clipboard
val valueVBuilder: AirbyteRecordMessage.AirbyteValueProtobuf.Builder

Functions

Link copied to clipboard
open override fun accept(recordData: NativeRecordPayload, changes: Map<EmittedField, FieldValueChange>?)
Link copied to clipboard
open override fun close()