in src/pyarrow_filter_expression.rs [34:54]
fn operator_to_py<'py>(
operator: &Operator,
op: &Bound<'py, PyModule>,
) -> PyDataFusionResult<Bound<'py, PyAny>> {
let py_op: Bound<'_, PyAny> = match operator {
Operator::Eq => op.getattr("eq")?,
Operator::NotEq => op.getattr("ne")?,
Operator::Lt => op.getattr("lt")?,
Operator::LtEq => op.getattr("le")?,
Operator::Gt => op.getattr("gt")?,
Operator::GtEq => op.getattr("ge")?,
Operator::And => op.getattr("and_")?,
Operator::Or => op.getattr("or_")?,
_ => {
return Err(PyDataFusionError::Common(format!(
"Unsupported operator {operator:?}"
)))
}
};
Ok(py_op)
}