dragon.data.ddict.NULLCheckpointPersister

class NULLCheckpointPersister

Bases: CheckpointPersister

__init__(ddict_name: str , persist_path: str , manager_id: int , traceit, manager, persist_freq: int = 0, persist_count: int = 0)

Methods

__init__(ddict_name, persist_path, ...[, ...])
advance()
checkpoints()
cleanup_metadata(persist_path, name)
dump(chkpt[, force])	Dump the given checkpoint to a persistent store.
dump_metadata(orc_logger, persist_path, ...)
load(pool[, cleanup])
load_metadata(orc_logger, persist_path, name)
position(chkpt)
prepare(orc_logger, persist_path, name, ...)

__init__(ddict_name: str , persist_path: str , manager_id: int , traceit, manager, persist_freq: int = 0, persist_count: int = 0)

dump(chkpt, force: bool = False)

Dump the given checkpoint to a persistent store. If force is True then overwrite a persisted checkpoint of the same id if necessary. See the Checkpoint class in the manager.py for internal details of checkpoints if implementing your own CheckpointPersister. Otherwise, use one of the subclasses provided by Dragon.

Parameters:

force – Overwrite an existing persisted checkpoint if necessary.

load(pool: MemoryPool, cleanup: bool = False)

advance()

position(chkpt: int )

checkpoints()

classmethod prepare(orc_logger, persist_path, name, restore_from, read_only)

classmethod dump_metadata(orc_logger, persist_path, name, metadata)

classmethod load_metadata(orc_logger, persist_path, name) → str

classmethod cleanup_metadata(persist_path, name)