Substrait

这些函数允许您对 Arrow 数据执行 Substrait 计划

查询执行

run_query(plan, *[, table_provider, use_threads])

执行 Substrait 计划并将结果读取为 RecordBatchReader。

表达式序列化

这些函数允许对 pyarrow 计算表达式进行序列化和反序列化。

绑定表达式()	命名表达式及其所绑定模式的集合
deserialize_expressions(buf)	将 ExtendedExpression Substrait 消息反序列化为 BoundExpressions 对象
serialize_expressions(exprs, names, schema, *)	将表达式集合序列化为 Substrait
serialize_schema(schema)	将模式序列化为 SubstraitSchema 对象。
deserialize_schema(buf)	将 NamedStruct Substrait 消息或 SubstraitSchema 对象反序列化为 Arrow Schema 对象
SubstraitSchema(schema, expression)	为 Substrait 用途编码的模式。

工具

get_supported_functions()

获取底层引擎当前支持的 Substrait 函数列表。