visch
05/20/2021, 8:36 PMvisch
05/20/2021, 8:38 PMaaronsteers
05/20/2021, 8:45 PMaaronsteers
05/20/2021, 8:48 PMmain
branch is up to date.aaronsteers
05/20/2021, 8:58 PMRenames:
- Sink.load_record(record) -> process_record(record)
- Sink.drain(records) -> process_batch(records)
And a third method to be called within `process_record()` if it applies:
- Sink.append_batch_record()
And same as today, if the dev does not override `process_record()`, the default implementation auto-adds it for processing in batch.
aaronsteers
05/20/2021, 8:59 PM