in src/pyarrow_filter_expression.rs [33:53]
fn operator_to_py<'py>(
operator: &Operator,
op: &'py PyModule,
) -> Result<&'py PyAny, DataFusionError> {
let py_op: &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(DataFusionError::Common(format!(
"Unsupported operator {operator:?}"
)))
}
};
Ok(py_op)
}