Skip to main content

​
Type Aliases

​
AnalyticalExecutionMethods

Ƭ AnalyticalExecutionMethods: ResourceMethods["analyticalExecution"]

​
AnalyticalExecutionFunctions

Ƭ AnalyticalExecutionFunctions: ResourceFunctions["analyticalExecution"]

​
AnalyticalExecutionContinuation

Ƭ AnalyticalExecutionContinuation: ResourceContinuation

​
Variables

​
analyticalExecution

• Const analyticalExecution: Readonly<{ protocol: "analyticalExecution" ; contractDigest: "705a0c1a5cd16953844e1d5d80d9f18b6b9c7fd9bcacb8395718427502ae1b96" ; functions: (ctx: ResourceFunctionContext, resource: ComponentResource<"analyticalExecution">) => Promise<{ cancel: string & FunctionReference<"mutation", "internal", { request: string ; request_id: string } & {}, { request: string } & {}> ; inspect: string & FunctionReference<"query", "internal", { request: string } & {}, { observation: string } & {}> ; plan: string & FunctionReference<"query", "internal", { execution: { readonly binding: string; readonly kind: “binding”; } & {} | { readonly bindings: string[]; readonly kind: “automatic”; } & {} ; expression: string ; inputs: string ; max_bytes: number ; max_rows: number ; request_id: string ; timeout_ms: number } & {}, { columns: string ; computation: { readonly binding: string; readonly binding_revisions: string[]; readonly plan_digest: string; readonly runtime_profiles: Record<string, string>; } & {} ; engine: "spark" | "trino" ; physical_plan: string } & {}> ; read: string & FunctionReference<"query", "internal", { part: number ; request: string ; result: { readonly contract: string; readonly digest: string; readonly kind: “dataset”; readonly owner: string; readonly reference: string; readonly version: string; } & {} } & {}, { part: string } & {}> ; release: string & FunctionReference<"mutation", "internal", { request: string ; request_id: string } & {}, { request: string } & {}> ; submit: string & FunctionReference<"mutation", "internal", { execution: { readonly binding: string; readonly kind: “binding”; } & {} | { readonly bindings: string[]; readonly kind: “automatic”; } & {} ; expression: string ; inputs: string ; max_bytes: number ; max_rows: number ; request_id: string ; timeout_ms: number } & {}, { columns: string ; computation: { readonly binding: string; readonly binding_revisions: string[]; readonly plan_digest: string; readonly runtime_profiles: Record<string, string>; } & {} ; continuation: { readonly contractDigest: string; readonly methods: Record<string, string>; readonly record: string; } & {} ; engine: "spark" | "trino" ; input_versions: Record<string, string> ; request: string } & {}> }> ; continuationValidator: ; retainCallbacks: (ctx: Pick<GenericMutationCtx<GenericDataModel>, "db">, methods: Pick<{ cancel: FunctionReference<"mutation", "internal", { request: string ; request_id: string } & {}, { request: string } & {}> ; inspect: FunctionReference<"query", "internal", { request: string } & {}, { observation: string } & {}> ; plan: FunctionReference<"query", "internal", { execution: { readonly binding: string; readonly kind: “binding”; } & {} | { readonly bindings: string[]; readonly kind: “automatic”; } & {} ; expression: string ; inputs: string ; max_bytes: number ; max_rows: number ; request_id: string ; timeout_ms: number } & {}, { columns: string ; computation: { readonly binding: string; readonly binding_revisions: string[]; readonly plan_digest: string; readonly runtime_profiles: Record<string, string>; } & {} ; engine: "spark" | "trino" ; physical_plan: string } & {}> ; read: FunctionReference<"query", "internal", { part: number ; request: string ; result: { readonly contract: string; readonly digest: string; readonly kind: “dataset”; readonly owner: string; readonly reference: string; readonly version: string; } & {} } & {}, { part: string } & {}> ; release: FunctionReference<"mutation", "internal", { request: string ; request_id: string } & {}, { request: string } & {}> ; submit: FunctionReference<"mutation", "internal", { execution: { readonly binding: string; readonly kind: “binding”; } & {} | { readonly bindings: string[]; readonly kind: “automatic”; } & {} ; expression: string ; inputs: string ; max_bytes: number ; max_rows: number ; request_id: string ; timeout_ms: number } & {}, { columns: string ; computation: { readonly binding: string; readonly binding_revisions: string[]; readonly plan_digest: string; readonly runtime_profiles: Record<string, string>; } & {} ; continuation: { readonly contractDigest: string; readonly methods: Record<string, string>; readonly record: string; } & {} ; engine: "spark" | "trino" ; input_versions: Record<string, string> ; request: string } & {}> }, "read" | "release" | "cancel" | "inspect">, options: { record: string }) => Promise<ResourceContinuation> ; contract: ; implement: (methods: { cancel: FunctionReference<"mutation", "internal", { request: string ; request_id: string } & {}, { request: string } & {}> ; inspect: FunctionReference<"query", "internal", { request: string } & {}, { observation: string } & {}> ; plan: FunctionReference<"query", "internal", { execution: { readonly binding: string; readonly kind: “binding”; } & {} | { readonly bindings: string[]; readonly kind: “automatic”; } & {} ; expression: string ; inputs: string ; max_bytes: number ; max_rows: number ; request_id: string ; timeout_ms: number } & {}, { columns: string ; computation: { readonly binding: string; readonly binding_revisions: string[]; readonly plan_digest: string; readonly runtime_profiles: Record<string, string>; } & {} ; engine: "spark" | "trino" ; physical_plan: string } & {}> ; read: FunctionReference<"query", "internal", { part: number ; request: string ; result: { readonly contract: string; readonly digest: string; readonly kind: “dataset”; readonly owner: string; readonly reference: string; readonly version: string; } & {} } & {}, { part: string } & {}> ; release: FunctionReference<"mutation", "internal", { request: string ; request_id: string } & {}, { request: string } & {}> ; submit: FunctionReference<"mutation", "internal", { execution: { readonly binding: string; readonly kind: “binding”; } & {} | { readonly bindings: string[]; readonly kind: “automatic”; } & {} ; expression: string ; inputs: string ; max_bytes: number ; max_rows: number ; request_id: string ; timeout_ms: number } & {}, { columns: string ; computation: { readonly binding: string; readonly binding_revisions: string[]; readonly plan_digest: string; readonly runtime_profiles: Record<string, string>; } & {} ; continuation: { readonly contractDigest: string; readonly methods: Record<string, string>; readonly record: string; } & {} ; engine: "spark" | "trino" ; input_versions: Record<string, string> ; request: string } & {}> }) => ResourceProvider<"analyticalExecution"> }> Bounded analytical execution through an explicitly selected installation.