StreamRecordConsumer

Emits an Airbyte RECORD message for the Stream associated with this instance.

The purpose of this interface is twofold:

  1. to encapsulate a performance-minded implementation behind a simple abstraction;

  2. to decorate the RECORD messages with

    a) meta-fields in the record data, and
b) field value changes and the motivating reason for these in the record metadata.

Inheritors

Properties

Link copied to clipboard
abstract val stream: Stream

Functions

Link copied to clipboard
abstract fun accept(recordData: NativeRecordPayload, changes: Map<Field, FieldValueChange>?)
Link copied to clipboard
abstract fun close()