类 BaseCheckpointSaver<V>抽象

构造函数

• new BaseCheckpointSaver<V>(serde?): BaseCheckpointSaver<V>

• 类型参数

  • V extends string | number = number

  参数

  • 可选 serde: SerializerProtocol

  返回 BaseCheckpointSaver<V>

serde

get

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

• 参数

  • config: RunnableConfig<Record<string, any>>

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

getNextVersion

• getNextVersion(current, _channel): V

• 为通道生成下一个版本 ID。

  默认使用整数版本，每次递增 1。如果覆盖此方法，可以使用字符串/整数/浮点数版本，只要它们是单调递增的。

  参数

  • current: undefined | V
  • _channel: ChannelProtocol<unknown, unknown, unknown>

  返回 V

抽象 getTuple

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

• 参数

  • config: RunnableConfig<Record<string, any>>

  返回 Promise<undefined | CheckpointTuple>

抽象 list

• list(config, options?): AsyncGenerator<CheckpointTuple, any, any>

• 参数

  • config: RunnableConfig<Record<string, any>>
  • 可选 options: CheckpointListOptions

  返回 AsyncGenerator<CheckpointTuple, any, any>

抽象 put

• put(config, checkpoint, metadata, newVersions): Promise<RunnableConfig<Record<string, any>>>

• 参数

  • config: RunnableConfig<Record<string, any>>
  • checkpoint: Checkpoint<string, string>
  • metadata: CheckpointMetadata
  • newVersions: ChannelVersions

  返回 Promise<RunnableConfig<Record<string, any>>>

抽象 putWrites

• putWrites(config, writes, taskId): Promise<void>

• 存储与检查点关联的中间写入。

  参数

  • config: RunnableConfig<Record<string, any>>
  • writes: PendingWrite[]
  • taskId: string

  返回 Promise<void>