def METHOD_NAME(
    self,
    stream,
    bookmarks: Dict = None,
    query: Dict = {},
    sample_data: bool = False,
    start_date: datetime = None,
    **kwargs,
) -> Generator[List[Dict], None, None]:
    table_name = stream.tap_stream_id
    for result in self.scan_table(table_name, bookmarks):
        data = []
        for item in result.get(ITEMS, []):
            record_message = common.row_to_singer_record(
                    stream.to_dict(),
                    item,
                    None,
                    None,
                )
            data.append(record_message.record)
        yield data