Struct ScalarSparqlOpAdapter 

pub struct ScalarSparqlOpAdapter<TScalarSparqlOp>
where
    TScalarSparqlOp: ScalarSparqlOp,
{ /* private fields */ }

Mediates between DataFusion’s API and a ScalarSparqlOp.

This includes the following tasks:

• Set up the argument types of the UDFs depending on the supported encodings
• Set up the argument types of the UDFs depending on the configured encodings in the engine
• Detecting the used input encoding and calling the correct ScalarSparqlOpImpl.

Implementations

impl<TScalarSparqlOp> ScalarSparqlOpAdapter<TScalarSparqlOp>

where TScalarSparqlOp: ScalarSparqlOp,

pub fn new( encodings: RdfFusionEncodings, op: TScalarSparqlOp, ) -> ScalarSparqlOpAdapter<TScalarSparqlOp>

Creates a new adapter for the given op.

Trait Implementations

impl<TScalarSparqlOp> Debug for ScalarSparqlOpAdapter<TScalarSparqlOp>

where TScalarSparqlOp: Debug + ScalarSparqlOp,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<TScalarSparqlOp> Hash for ScalarSparqlOpAdapter<TScalarSparqlOp>

where TScalarSparqlOp: ScalarSparqlOp,

While it would be possible to create two different SparqlOpAdapters for the same ScalarSparqlOp that are not identical (different encodings), this situation is unlikely to happen when using RDF Fusion “normally”. Therefore, we only hash the contained ScalarSparqlOp.

fn hash<H>(&self, state: &mut H)

where H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl<TScalarSparqlOp> PartialEq for ScalarSparqlOpAdapter<TScalarSparqlOp>

where TScalarSparqlOp: ScalarSparqlOp,

fn eq(&self, other: &ScalarSparqlOpAdapter<TScalarSparqlOp>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<TScalarSparqlOp> ScalarUDFImpl for ScalarSparqlOpAdapter<TScalarSparqlOp>

where TScalarSparqlOp: ScalarSparqlOp + 'static,

fn as_any(&self) -> &(dyn Any + 'static)

Returns this object as an Any trait object

fn name(&self) -> &str

Returns this function’s name

fn signature(&self) -> &Signature

Returns a Signature describing the argument types for which this function has an implementation, and the function’s Volatility.

fn return_type( &self, arg_types: &[DataType], ) -> Result<DataType, DataFusionError>

DataType returned by this function, given the types of the arguments.

fn invoke_with_args( &self, args: ScalarFunctionArgs, ) -> Result<ColumnarValue, DataFusionError>

Invoke the function returning the appropriate result.

fn aliases(&self) -> &[String]

Returns any aliases (alternate names) for this function.

fn display_name(&self, args: &[Expr]) -> Result<String, DataFusionError>

👎Deprecated since 50.0.0: This method is unused and will be removed in a future release

Returns the user-defined display name of function, given the arguments

fn schema_name(&self, args: &[Expr]) -> Result<String, DataFusionError>

Returns the name of the column this expression would create

fn return_field_from_args( &self, args: ReturnFieldArgs<'_>, ) -> Result<Arc<Field>, DataFusionError>

What type will be returned by this function, given the arguments?

fn is_nullable(&self, _args: &[Expr], _schema: &dyn ExprSchema) -> bool

👎Deprecated since 45.0.0: Use return_field_from_args instead. if you use is_nullable that returns non-nullable with return_type, you would need to switch to return_field_from_args, you might have error

fn simplify( &self, args: Vec<Expr>, _info: &dyn SimplifyInfo, ) -> Result<ExprSimplifyResult, DataFusionError>

Optionally apply per-UDF simplification / rewrite rules.

fn short_circuits(&self) -> bool

Returns true if some of this exprs subexpressions may not be evaluated and thus any side effects (like divide by zero) may not be encountered.

fn evaluate_bounds( &self, _input: &[&Interval], ) -> Result<Interval, DataFusionError>

Computes the output Interval for a ScalarUDFImpl, given the input intervals.

fn propagate_constraints( &self, _interval: &Interval, _inputs: &[&Interval], ) -> Result<Option<Vec<Interval>>, DataFusionError>

Updates bounds for child expressions, given a known Intervals for this function.

fn output_ordering( &self, inputs: &[ExprProperties], ) -> Result<SortProperties, DataFusionError>

Calculates the SortProperties of this function based on its children’s properties.

fn preserves_lex_ordering( &self, _inputs: &[ExprProperties], ) -> Result<bool, DataFusionError>

Returns true if the function preserves lexicographical ordering based on the input ordering.

fn coerce_types( &self, _arg_types: &[DataType], ) -> Result<Vec<DataType>, DataFusionError>

Coerce arguments of a function call to types that the function can evaluate.

fn documentation(&self) -> Option<&Documentation>

Returns the documentation for this Scalar UDF.

impl<TScalarSparqlOp> Eq for ScalarSparqlOpAdapter<TScalarSparqlOp>

where TScalarSparqlOp: Eq + ScalarSparqlOp,