stream_data
(DataFrame): New data to be included in snapshotstream
(str): Name of the streamsnapshot_dir
(str): Directory for storing snapshotspk
(str|list): Primary key(s) for deduplicationjust_new
(bool): Adds only new records if Trueuse_csv
(bool): Use CSV format instead of Parquetcoerce_types
(bool): Force snapshot types to match stream_data**kwargs
: Additional pandas read optionsstream
(str): Name of the stream to readsnapshot_dir
(str): Directory containing snapshots**kwargs
: Additional pandas read optionsdf
(DataFrame): DataFrame to check for duplicatesname
(str): Name for snapshot hash fileoutput_dir
(str): Directory to save state filespk
(str|list): Primary key(s) for state trackingupdated_flag
(bool): Add flag for new/updated rowsuse_csv
(bool): Use CSV format instead of Parquet