Module expr

for declare Expression in dataflow, including map, reduce, id and join(TODO!) etc.

Modules

df_func 🔒

Porting Datafusion scalar function to our scalar function to be used in dataflow

error 🔒

Error handling for expression evaluation.

func 🔒

This module contains the definition of functions that can be used in expressions.

id 🔒

Id is used to identify a dataflow component in plan like Plan::Get{id: Id}, this could be a source of data for an arrangement.

linear 🔒

define MapFilterProject which is a compound operator that can be applied row-by-row.

relation 🔒

Describes an aggregation function and it’s input expression.

scalar 🔒

Scalar expressions.

signature 🔒

Function signature, useful for type checking and function resolution.

utils 🔒

This module contains utility functions for expressions.

Structs

Batch

A batch of vectors with the same length but without schema, only useful in dataflow

VectorDiff 🔒

Vector with diff to note the insert and delete

VectorDiffIter 🔒

iterator for VectorDiff

Constants

TUMBLE_END

TUMBLE_START