Options
All
  • Public
  • Public/Protected
  • All
Menu

Type parameters

  • TRecord = any

Hierarchy

  • Job

Index

Constructors

constructor

  • new Job<TRecord>(connection: Connection, jobData: WarehouseJobData): Job<TRecord>
  • Type parameters

    • TRecord = any

    Parameters

    • connection: Connection
    • jobData: WarehouseJobData

    Returns Job<TRecord>

Properties

Optional bytesScanned

bytesScanned: number

Private connection

connection: Connection

Private jobData

jobData: WarehouseJobData

Optional jobID

jobID: string

Optional referencedInstanceIDs

referencedInstanceIDs: string[]

Optional replayCursor

replayCursor: string

Optional resultAvroSchema

resultAvroSchema: string

Optional resultSizeBytes

resultSizeBytes: number

Optional resultSizeRecords

resultSizeRecords: number

status

status: "pending" | "running" | "done"

Methods

Private checkIsNotDry

  • checkIsNotDry(): void
  • Returns void

getCursor

  • getCursor(opts?: GetCursorOptions): Promise<{ cursor?: Cursor<TRecord>; error?: Error }>
  • Parameters

    • Optional opts: GetCursorOptions

    Returns Promise<{ cursor?: Cursor<TRecord>; error?: Error }>

poll

  • poll(): Promise<{ error?: Error }>
  • Returns Promise<{ error?: Error }>

Private setJobData

  • setJobData(jobData: WarehouseJobData): void
  • Parameters

    • jobData: WarehouseJobData

    Returns void

Legend

  • Constructor
  • Property
  • Method
  • Private property
  • Private method
  • Property

Generated using TypeDoc