Type parameters
Hierarchy
-
QueryExecution↳QueryReservation
Constructors
constructor
• new QueryExecution<Row>(transport, executionId, initial?, recovery?)
Type parameters
Parameters
Properties
transport
•Protected Readonly transport: QueryTransport
executionId
•Readonly executionId: QueryExecutionId<Row>
Methods
snapshot
▸Readonly snapshot(): QuerySnapshot<Row>
Returns
QuerySnapshot<Row>
subscribe
▸Readonly subscribe(listener): () => void
Parameters
Returns
fn
▸ (): void
Returns
void
update
▸Protected update(change): void
Parameters
Returns
void
get
▸ get():Promise<QueryExecutionState<Row>>
Returns
Promise<QueryExecutionState<Row>>
wait
▸ wait(options?): Promise<{ executionId: QueryExecutionId<Row> ; deadline: string ; expiresAt: string } & { state: "ready" ; plan: QueryPlan ; basis: { kind: "statement" ; provider: "snowflake" | "databricks" } | { kind: "federated" ; localRevision?: string ; remote: { kind: "statement" ; provider: "snowflake" | "databricks" ; tables: string[] }[] } ; rowCount: number }>
Parameters
Returns
Promise<{ executionId: QueryExecutionId<Row> ; deadline: string ; expiresAt: string } & { state: "ready" ; plan: QueryPlan ; basis: { kind: "statement" ; provider: "snowflake" | "databricks" } | { kind: "federated" ; localRevision?: string ; remote: { kind: "statement" ; provider: "snowflake" | "databricks" ; tables: string[] }[] } ; rowCount: number }>
pages
▸ pages(options?): AsyncGenerator<QueryPage<Row>, any, unknown>
Parameters
Returns
AsyncGenerator<QueryPage<Row>, any, unknown>
result
▸ result(options?): Promise<QueryResult<Row>>
Collect the same complete result, within the native row and byte bounds.
Parameters
Returns
Promise<QueryResult<Row>>
cancel
▸ cancel():Promise<QueryControl<Row>>
Returns
Promise<QueryControl<Row>>
release
▸ release():Promise<QueryControl<Row>>
Returns
Promise<QueryControl<Row>>