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

JsonSocketEfficientStreamRecordConsumer

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

Constructors

Link copied to clipboard
constructor(stream: Stream, outputer: OutputConsumer)

Properties

Link copied to clipboard
Link copied to clipboard
open override val stream: Stream

Functions

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