Module datafusion::prelude
source · [−]Expand description
A “prelude” for users of the datafusion crate.
Like the standard library’s prelude, this module simplifies importing of common items. Unlike the standard prelude, the contents of this module must be imported manually:
use datafusion::prelude::*;
Re-exports
pub use crate::dataframe::DataFrame;
pub use crate::execution::context::SessionConfig;
pub use crate::execution::context::SessionContext;
pub use crate::execution::options::AvroReadOptions;
pub use crate::execution::options::CsvReadOptions;
pub use crate::execution::options::NdJsonReadOptions;
pub use crate::execution::options::ParquetReadOptions;
Structs
A named reference to a qualified field in a schema.
Enums
Expr
is a central struct of DataFusion’s query API, and
represent logical expressions such as A + 1
, or CAST(c1 AS int)
.
Join type
Logical partitioning schemes supported by the repartition operator.
Functions
Calculate an approximation of the specified percentile
for expr
.
Returns an array of fixed size with each argument on it.
Scalar function definition for ascii
Create an expression to represent the avg() aggregate function
Scalar function definition for bit_length
Scalar function definition for btrim
Create a cast expression
Scalar function definition for character_length
Scalar function definition for chr
Create a column expression based on a qualified or unqualified column name
Concatenates the text representations of all the arguments. NULL arguments are ignored.
Concatenates all but the first argument, with separators. The first argument is used as the separator string, and should not be NULL. Other NULL arguments are ignored.
Create an expression to represent the count() aggregate function
Creates a new UDF with a specific signature and specific return type.
This is a helper function to create a new UDF.
The function create_udf
returns a subset of all possible ScalarFunction
:
Scalar function definition for date_part
Scalar function definition for date_trunc
Scalar function definition for digest
Create an EXISTS subquery expression
Scalar function definition for from_unixtime
Create an in_list expression
Create an IN subquery expression
Scalar function definition for initcap
Scalar function definition for left
Scalar function definition for length
Create a literal expression
Scalar function definition for lower
Scalar function definition for lpad
Scalar function definition for ltrim
Create an expression to represent the max() aggregate function
Scalar function definition for md5
Create an expression to represent the min() aggregate function
Create a NOT EXISTS subquery expression
Create a NOT IN subquery expression
current time
Scalar function definition for octet_length
Returns a random value in the range 0.0 <= x < 1.0
Scalar function definition for regexp_match
Scalar function definition for regexp_replace
Scalar function definition for repeat
Scalar function definition for replace
Scalar function definition for reverse
Scalar function definition for right
Scalar function definition for rpad
Scalar function definition for rtrim
Create a scalar subquery expression
Scalar function definition for sha224
Scalar function definition for sha256
Scalar function definition for sha384
Scalar function definition for sha512
Scalar function definition for split_part
Scalar function definition for starts_with
Scalar function definition for strpos
Scalar function definition for substr
Create an expression to represent the sum() aggregate function
Scalar function definition for to_hex
Scalar function definition for translate
Scalar function definition for trim
Scalar function definition for upper