morpheus_dfp.utils.cached_user_window.CachedUserWindow#

class CachedUserWindow(
user_id: str,
cache_location: str,
timestamp_column: str = 'timestamp',
total_count: int = 0,
count: int = 0,
min_epoch: datetime.datetime = datetime.datetime(1970, 1, 1, 0, 0, tzinfo=datetime.timezone.utc),
max_epoch: datetime.datetime = datetime.datetime(1970, 1, 1, 0, 0, tzinfo=datetime.timezone.utc),
batch_count: int = 0,
pending_batch_count: int = 0,
last_train_count: int = 0,
last_train_epoch: datetime.datetime = None,
last_train_batch: int = 0,
)[source]#

Bases: object

Attributes:
last_train_epoch

Methods

append_dataframe

flush

get_spanning_df

get_train_df

load

save

trim_dataframe