Class: QueryReservation<Schema>

browser.QueryReservation An execution identity allocated before any query is submitted.

​

Type parameters

​

Hierarchy

• QueryExecution ↳ QueryReservation

​

Constructors

​

constructor

• new QueryReservation<Schema>(transport, reservation, recovery?)

​

Type parameters

​

Parameters

​

Overrides

QueryExecution.constructor

​

Properties

​

transport

• Protected Readonly transport: QueryTransport

​

Inherited from

QueryExecution.transport

---

​

executionId

• Readonly executionId: QueryExecutionId<Record<string, Value>>

​

Inherited from

QueryExecution.executionId

---

​

expiresAt

• Readonly expiresAt: string

​

Methods

​

snapshot

▸ Readonly snapshot(): QuerySnapshot<Row>

​

Returns

QuerySnapshot<Row>

​

Inherited from

QueryExecution.snapshot

---

​

subscribe

▸ Readonly subscribe(listener): () => void

​

Parameters

​

Returns

fn ▸ (): void

Returns

void

​

Inherited from

QueryExecution.subscribe

---

​

update

▸ Protected update(change): void

​

Parameters

​

Returns

void

​

Inherited from

QueryExecution.update

---

​

get

▸ get(): Promise<QueryExecutionState<Record<string, Value>>>

​

Returns

Promise<QueryExecutionState<Record<string, Value>>>

​

Inherited from

QueryExecution.get

---

​

wait

▸ wait(options?): Promise<{ executionId: QueryExecutionId<Record<string, Value>> ; 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<Record<string, Value>> ; 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 }>

​

Inherited from

QueryExecution.wait

---

​

pages

▸ pages(options?): AsyncGenerator<QueryPage<Record<string, Value>>, any, unknown>

​

Parameters

​

Returns

AsyncGenerator<QueryPage<Record<string, Value>>, any, unknown>

​

Inherited from

QueryExecution.pages

---

​

result

▸ result(options?): Promise<QueryResult<Record<string, Value>>> Collect the same complete result, within the native row and byte bounds.

​

Parameters

​

Returns

Promise<QueryResult<Record<string, Value>>>

​

Inherited from

QueryExecution.result

---

​

cancel

▸ cancel(): Promise<QueryControl<Record<string, Value>>>

​

Returns

Promise<QueryControl<Record<string, Value>>>

​

Inherited from

QueryExecution.cancel

---

​

release

▸ release(): Promise<QueryControl<Record<string, Value>>>

​

Returns

Promise<QueryControl<Record<string, Value>>>

​

Inherited from

QueryExecution.release

---

​

start

▸ start<Plan>(query, bounds?): Promise<QueryExecution<QueryRow<Schema, Plan>>>

​

Type parameters

​

Parameters

​

Returns

Promise<QueryExecution<QueryRow<Schema, Plan>>>