singer_sdk.batch.BaseBatcher#
- class singer_sdk.batch.BaseBatcher#
Base Record Batcher.
- __init__(tap_name: str, stream_name: str, batch_config: BatchConfig) None #
Initialize the batcher.
- Parameters:
tap_name – The name of the tap.
stream_name – The name of the stream.
batch_config – The batch configuration.
- abstract get_batches(records: Iterator[dict]) Iterator[list[str]] #
Yield manifest of batches.
- Parameters:
records – The records to batch.
- Raises:
NotImplementedError – If the method is not implemented.