Class BaseCheckpointSaver<V>Abstract
Type Parameters V extends string | number = number Defined in libs/checkpoint/dist/base.d.ts:54 Constructors constructor new Base Checkpoint Saver < V > ( serde ? ) : BaseCheckpointSaver < V > Type Parameters V extends string | number = number Defined in libs/checkpoint/dist/base.d.ts:56 Properties serde Defined in libs/checkpoint/dist/base.d.ts:55 Methods Abstract
delete Thread delete Thread ( threadId ) : Promise < void > Returns Promise < void > Defined in libs/checkpoint/dist/base.d.ts:69 get get ( config ) : Promise < undefined | Checkpoint < string , string > > Parameters config : RunnableConfig < Record < string , any > > Returns Promise < undefined | Checkpoint < string , string > > Defined in libs/checkpoint/dist/base.d.ts:57 get Next Version get Next Version ( current ) : V Returns V Defined in libs/checkpoint/dist/base.d.ts:76 Abstract
get Tuple get Tuple ( config ) : Promise < undefined | CheckpointTuple > Parameters config : RunnableConfig < Record < string , any > > Defined in libs/checkpoint/dist/base.d.ts:58 Abstract
list list ( config , options ? ) : AsyncGenerator < CheckpointTuple , any , any > Returns AsyncGenerator < CheckpointTuple , any , any > Defined in libs/checkpoint/dist/base.d.ts:59 Abstract
put put ( config , checkpoint , metadata , newVersions ) : Promise < RunnableConfig < Record < string , any > > > Returns Promise < RunnableConfig < Record < string , any > > > Defined in libs/checkpoint/dist/base.d.ts:60 Abstract
put Writes put Writes ( config , writes , taskId ) : Promise < void > Parameters config : RunnableConfig < Record < string , any > > writes : PendingWrite [] taskId : string Returns Promise < void > Defined in libs/checkpoint/dist/base.d.ts:64
Delete all checkpoints and writes associated with a specific thread ID.