singer_sdk.RecordSink#
- class singer_sdk.RecordSink[source]#
Base class for singleton record writers.
- final process_batch(context)[source]#
Do nothing and return immediately.
The RecordSink class does not support batching.
This method may not be overridden.
- Parameters:
context (dict) – Stream partition or context dictionary.
- Return type:
None
- abstract process_record(record, context)[source]#
Load the latest record from the stream.
This method must be overridden.
Implementations should permanently serialize each record to the target prior to returning.
If duplicates are merged/skipped instead of being loaded, merges can be tracked via
tally_duplicate_merged().