类 BaseCheckpointSaver抽象

constructor

• new BaseCheckpointSaver(serde?): BaseCheckpointSaver

• 参数

  • 可选 serde: SerializerProtocol<unknown>

  返回值 BaseCheckpointSaver

serde

get

• get(config): Promise<undefined | Checkpoint<string, string>>

• 参数

  • config: RunnableConfig

  返回值 Promise<undefined | Checkpoint<string, string>>

抽象 getTuple

• getTuple(config): Promise<undefined | CheckpointTuple>

• 参数

  • config: RunnableConfig

  返回值 Promise<undefined | CheckpointTuple>

抽象 list

• list(config, limit?, before?): AsyncGenerator<CheckpointTuple, any, unknown>

• 参数

  • config: RunnableConfig
  • 可选 limit: number
  • 可选 before: RunnableConfig

  返回值 AsyncGenerator<CheckpointTuple, any, unknown>

抽象 put

• put(config, checkpoint, metadata): Promise<RunnableConfig>

• 参数

  • config: RunnableConfig
  • checkpoint: Checkpoint<string, string>
  • metadata: CheckpointMetadata

  返回值 Promise<RunnableConfig>