Class SqliteSaver

constructor

• new SqliteSaver(db: Database, serde?: any): SqliteSaver

  Parameters

  • db: Database
  • Optionalserde: any

  Returns SqliteSaver

db

deleteThread

• deleteThread(threadId: string): Promise<void>

  Parameters

  • threadId: string

  Returns Promise<void>

getTuple

• getTuple(config: RunnableConfig): Promise<any>

  Parameters

  • config: RunnableConfig

  Returns Promise<any>

list

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

  Parameters

  • config: RunnableConfig
  • Optionaloptions: any

  Returns AsyncGenerator<CheckpointTuple>

put

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

  Parameters

  • config: RunnableConfig
  • checkpoint: Checkpoint
  • metadata: CheckpointMetadata

  Returns Promise<RunnableConfig<Record<string, any>>>

putWrites

• putWrites(
      config: RunnableConfig,
      writes: PendingWrite[],
      taskId: string,
  ): Promise<void>

  Parameters

  • config: RunnableConfig
  • writes: PendingWrite[]
  • taskId: string

  Returns Promise<void>

StaticfromConnString

• fromConnString(connStringOrLocalPath: string): SqliteSaver

  Parameters

  • connStringOrLocalPath: string

  Returns SqliteSaver