Skip to main content

engines.run_substrait_json()

Run a Substrait plan on DataFusion.

Usage

Source

engines.run_substrait_json(
    con,
    plan_json,
)

The plan runs as given; sverify.engines.run(con, plan, "datafusion") first rewrites a plan in Lean’s written form where DataFusion’s semantics differ, and is what to use for checked plans.

Parameters

con: Connection

The connection whose tables the plan reads.

plan_json: str
A Substrait plan as protobuf JSON.

Returns

pa.Table
The result, with doubles as canonical makes them.

Raises

ImportError
DataFusion is not installed.