singer_sdk.RecordSink#
- class singer_sdk.RecordSink#
Base class for singleton record writers.
- process_batch(context: dict) None #
Do nothing and return immediately.
The RecordSink class does not support batching.
This method may not be overridden.
- Parameters:
context – Stream partition or context dictionary.
- abstract process_record(record: dict, context: dict) None #
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()
.- Parameters:
record – Individual record in the stream.
context – Stream partition or context dictionary.
- start_batch(context: dict) None #
Do nothing and return immediately.
The RecordSink class does not support batching.
This method may not be overridden.
- Parameters:
context – Stream partition or context dictionary.