LINKS
Github and Issue Tracker
Rust's API Docs
Code of conduct
Examples
USER GUIDE
Introduction
Concepts
Configuration
Common Operations
Basic Operations
Column Selections
Expressions
Joins
Functions
Aggregation
Window Functions
User-Defined Functions
IO
Arrow
Avro
CSV
JSON
Parquet
SQL
CONTRIBUTOR GUIDE
Introduction
API
API Reference
datafusion
datafusion.input
datafusion.input.base
datafusion.input.location
datafusion.catalog
datafusion.context
datafusion.dataframe
datafusion.expr
datafusion.functions
datafusion.object_store
datafusion.plan
datafusion.record_batch
datafusion.substrait
datafusion.udf
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
_
__add__() (datafusion.Expr method)
(datafusion.expr.Expr method)
__and__() (datafusion.Expr method)
(datafusion.expr.Expr method)
__arrow_c_stream__() (datafusion.dataframe.DataFrame method)
__call__() (datafusion.AggregateUDF method)
(datafusion.ScalarUDF method)
(datafusion.udf.AggregateUDF method)
(datafusion.udf.ScalarUDF method)
(datafusion.udf.WindowUDF method)
(datafusion.WindowUDF method)
__eq__() (datafusion.Expr method)
(datafusion.expr.Expr method)
__ge__() (datafusion.Expr method)
(datafusion.expr.Expr method)
__getitem__() (datafusion.dataframe.DataFrame method)
(datafusion.Expr method)
(datafusion.expr.Expr method)
__gt__() (datafusion.Expr method)
(datafusion.expr.Expr method)
__invert__() (datafusion.Expr method)
(datafusion.expr.Expr method)
__iter__() (datafusion.record_batch.RecordBatchStream method)
(datafusion.RecordBatchStream method)
__le__() (datafusion.Expr method)
(datafusion.expr.Expr method)
__lt__() (datafusion.Expr method)
(datafusion.expr.Expr method)
__mod__() (datafusion.Expr method)
(datafusion.expr.Expr method)
__mul__() (datafusion.Expr method)
(datafusion.expr.Expr method)
__ne__() (datafusion.Expr method)
(datafusion.expr.Expr method)
__next__() (datafusion.record_batch.RecordBatchStream method)
(datafusion.RecordBatchStream method)
__or__() (datafusion.Expr method)
(datafusion.expr.Expr method)
__radd__ (datafusion.Expr attribute)
(datafusion.expr.Expr attribute)
__rand__ (datafusion.Expr attribute)
(datafusion.expr.Expr attribute)
__repr__() (datafusion.dataframe.DataFrame method)
(datafusion.ExecutionPlan method)
(datafusion.Expr method)
(datafusion.expr.Expr method)
(datafusion.expr.SortExpr method)
(datafusion.LogicalPlan method)
(datafusion.plan.ExecutionPlan method)
(datafusion.plan.LogicalPlan method)
__richcmp__() (datafusion.Expr method)
(datafusion.expr.Expr method)
__rmod__ (datafusion.Expr attribute)
(datafusion.expr.Expr attribute)
__rmul__ (datafusion.Expr attribute)
(datafusion.expr.Expr attribute)
__ror__ (datafusion.Expr attribute)
(datafusion.expr.Expr attribute)
__rsub__ (datafusion.Expr attribute)
(datafusion.expr.Expr attribute)
__rtruediv__ (datafusion.Expr attribute)
(datafusion.expr.Expr attribute)
__str__() (datafusion.udf.Volatility method)
__sub__() (datafusion.Expr method)
(datafusion.expr.Expr method)
__truediv__() (datafusion.Expr method)
(datafusion.expr.Expr method)
_null_treatment (datafusion.expr.Window attribute)
_order_by (datafusion.expr.Window attribute)
_partition_by (datafusion.expr.Window attribute)
_R (in module datafusion.udf)
_raw_plan (datafusion.ExecutionPlan attribute)
(datafusion.LogicalPlan attribute)
(datafusion.plan.ExecutionPlan attribute)
(datafusion.plan.LogicalPlan attribute)
_repr_html_() (datafusion.dataframe.DataFrame method)
_to_pyarrow_types (datafusion.Expr attribute)
(datafusion.expr.Expr attribute)
_udaf (datafusion.AggregateUDF attribute)
(datafusion.udf.AggregateUDF attribute)
_udf (datafusion.ScalarUDF attribute)
(datafusion.udf.ScalarUDF attribute)
_udwf (datafusion.udf.WindowUDF attribute)
(datafusion.WindowUDF attribute)
_W (in module datafusion.udf)
_window_frame (datafusion.expr.Window attribute)
A
abs() (in module datafusion.functions)
Accumulator (class in datafusion)
(class in datafusion.udf)
acos() (in module datafusion.functions)
acosh() (in module datafusion.functions)
Aggregate (in module datafusion.expr)
aggregate() (datafusion.dataframe.DataFrame method)
AggregateFunction (in module datafusion.expr)
AggregateUDF (class in datafusion)
(class in datafusion.udf)
Alias (in module datafusion.expr)
alias() (datafusion.Expr method)
(datafusion.expr.Expr method)
(in module datafusion.functions)
AmazonS3 (in module datafusion.object_store)
Analyze (in module datafusion.expr)
approx_distinct() (in module datafusion.functions)
approx_median() (in module datafusion.functions)
approx_percentile_cont() (in module datafusion.functions)
approx_percentile_cont_with_weight() (in module datafusion.functions)
array() (in module datafusion.functions)
array_agg() (in module datafusion.functions)
array_append() (in module datafusion.functions)
array_cat() (in module datafusion.functions)
array_concat() (in module datafusion.functions)
array_dims() (in module datafusion.functions)
array_distinct() (in module datafusion.functions)
array_element() (in module datafusion.functions)
array_except() (in module datafusion.functions)
array_extract() (in module datafusion.functions)
array_has() (in module datafusion.functions)
array_has_all() (in module datafusion.functions)
array_has_any() (in module datafusion.functions)
array_indexof() (in module datafusion.functions)
array_intersect() (in module datafusion.functions)
array_join() (in module datafusion.functions)
array_length() (in module datafusion.functions)
array_ndims() (in module datafusion.functions)
array_pop_back() (in module datafusion.functions)
array_pop_front() (in module datafusion.functions)
array_position() (in module datafusion.functions)
array_positions() (in module datafusion.functions)
array_prepend() (in module datafusion.functions)
array_push_back() (in module datafusion.functions)
array_push_front() (in module datafusion.functions)
array_remove() (in module datafusion.functions)
array_remove_all() (in module datafusion.functions)
array_remove_n() (in module datafusion.functions)
array_repeat() (in module datafusion.functions)
array_replace() (in module datafusion.functions)
array_replace_all() (in module datafusion.functions)
array_replace_n() (in module datafusion.functions)
array_resize() (in module datafusion.functions)
array_slice() (in module datafusion.functions)
array_sort() (in module datafusion.functions)
array_to_string() (in module datafusion.functions)
array_union() (in module datafusion.functions)
arrow_typeof() (in module datafusion.functions)
ascending() (datafusion.expr.SortExpr method)
ascii() (in module datafusion.functions)
asin() (in module datafusion.functions)
asinh() (in module datafusion.functions)
atan() (in module datafusion.functions)
atan2() (in module datafusion.functions)
atanh() (in module datafusion.functions)
avg() (in module datafusion.functions)
B
BaseInputSource (class in datafusion.input.base)
Between (in module datafusion.expr)
between() (datafusion.Expr method)
(datafusion.expr.Expr method)
BinaryExpr (in module datafusion.expr)
bit_and() (in module datafusion.functions)
bit_length() (in module datafusion.functions)
bit_or() (in module datafusion.functions)
bit_xor() (in module datafusion.functions)
bool_and() (in module datafusion.functions)
bool_or() (in module datafusion.functions)
btrim() (in module datafusion.functions)
build_table() (datafusion.input.base.BaseInputSource method)
(datafusion.input.location.LocationInputPlugin method)
C
cache() (datafusion.dataframe.DataFrame method)
canonical_name() (datafusion.Expr method)
(datafusion.expr.Expr method)
Case (in module datafusion.expr)
case() (in module datafusion.functions)
case_builder (datafusion.expr.CaseBuilder attribute)
CaseBuilder (class in datafusion.expr)
Cast (in module datafusion.expr)
cast() (datafusion.Expr method)
(datafusion.expr.Expr method)
Catalog (class in datafusion)
(class in datafusion.catalog)
catalog (datafusion.Catalog attribute)
(datafusion.catalog.Catalog attribute)
catalog() (datafusion.context.SessionContext method)
cbrt() (in module datafusion.functions)
ceil() (in module datafusion.functions)
char_length() (in module datafusion.functions)
character_length() (in module datafusion.functions)
children() (datafusion.ExecutionPlan method)
(datafusion.plan.ExecutionPlan method)
chr() (in module datafusion.functions)
coalesce() (in module datafusion.functions)
col() (in module datafusion)
(in module datafusion.functions)
collect() (datafusion.dataframe.DataFrame method)
collect_partitioned() (datafusion.dataframe.DataFrame method)
Column (in module datafusion.expr)
column() (datafusion.Expr static method)
(datafusion.expr.Expr static method)
(in module datafusion)
column_name() (datafusion.Expr method)
(datafusion.expr.Expr method)
concat() (in module datafusion.functions)
concat_ws() (in module datafusion.functions)
config (datafusion.context.SessionContext attribute)
config_internal (datafusion.context.RuntimeConfig attribute)
(datafusion.context.SessionConfig attribute)
(datafusion.RuntimeConfig attribute)
(datafusion.SessionConfig attribute)
Consumer (class in datafusion.substrait)
corr() (in module datafusion.functions)
cos() (in module datafusion.functions)
cosh() (in module datafusion.functions)
cot() (in module datafusion.functions)
count() (datafusion.dataframe.DataFrame method)
(in module datafusion.functions)
count_star() (in module datafusion.functions)
covar() (in module datafusion.functions)
covar_pop() (in module datafusion.functions)
covar_samp() (in module datafusion.functions)
create_dataframe() (datafusion.context.SessionContext method)
create_dataframe_from_logical_plan() (datafusion.context.SessionContext method)
CreateMemoryTable (in module datafusion.expr)
CreateView (in module datafusion.expr)
CrossJoin (in module datafusion.expr)
ctx (datafusion.context.SessionContext attribute)
cume_dist() (in module datafusion.functions)
current_date() (in module datafusion.functions)
current_time() (in module datafusion.functions)
D
Database (class in datafusion)
(class in datafusion.catalog)
database() (datafusion.Catalog method)
(datafusion.catalog.Catalog method)
DataFrame (class in datafusion.dataframe)
datafusion
module
datafusion.catalog
module
datafusion.context
module
datafusion.dataframe
module
datafusion.expr
module
datafusion.functions
module
datafusion.input
module
datafusion.input.base
module
datafusion.input.location
module
datafusion.object_store
module
datafusion.plan
module
datafusion.record_batch
module
datafusion.substrait
module
datafusion.udf
module
date_bin() (in module datafusion.functions)
date_part() (in module datafusion.functions)
date_trunc() (in module datafusion.functions)
datepart() (in module datafusion.functions)
datetrunc() (in module datafusion.functions)
db (datafusion.catalog.Database attribute)
(datafusion.Database attribute)
decode() (in module datafusion.functions)
degrees() (in module datafusion.functions)
dense_rank() (in module datafusion.functions)
deregister_table() (datafusion.context.SessionContext method)
describe() (datafusion.dataframe.DataFrame method)
deserialize() (datafusion.substrait.Serde static method)
deserialize_bytes() (datafusion.substrait.Serde static method)
df (datafusion.dataframe.DataFrame attribute)
DFSchema (in module datafusion)
digest() (in module datafusion.functions)
display() (datafusion.ExecutionPlan method)
(datafusion.LogicalPlan method)
(datafusion.plan.ExecutionPlan method)
(datafusion.plan.LogicalPlan method)
display_graphviz() (datafusion.LogicalPlan method)
(datafusion.plan.LogicalPlan method)
display_indent() (datafusion.ExecutionPlan method)
(datafusion.LogicalPlan method)
(datafusion.plan.ExecutionPlan method)
(datafusion.plan.LogicalPlan method)
display_indent_schema() (datafusion.LogicalPlan method)
(datafusion.plan.LogicalPlan method)
display_name() (datafusion.Expr method)
(datafusion.expr.Expr method)
Distinct (in module datafusion.expr)
distinct() (datafusion.dataframe.DataFrame method)
(datafusion.Expr method)
(datafusion.expr.Expr method)
DropTable (in module datafusion.expr)
E
empty_table() (datafusion.context.SessionContext method)
EmptyRelation (in module datafusion.expr)
encode() (datafusion.substrait.Plan method)
(in module datafusion.functions)
end() (datafusion.expr.CaseBuilder method)
ends_with() (in module datafusion.functions)
evaluate() (datafusion.Accumulator method)
(datafusion.udf.Accumulator method)
(datafusion.udf.WindowEvaluator method)
evaluate_all() (datafusion.udf.WindowEvaluator method)
evaluate_all_with_rank() (datafusion.udf.WindowEvaluator method)
except_all() (datafusion.dataframe.DataFrame method)
execute() (datafusion.context.SessionContext method)
execute_stream() (datafusion.dataframe.DataFrame method)
execute_stream_partitioned() (datafusion.dataframe.DataFrame method)
execution_plan() (datafusion.dataframe.DataFrame method)
ExecutionPlan (class in datafusion)
(class in datafusion.plan)
Exists (in module datafusion.expr)
exp() (in module datafusion.functions)
Explain (in module datafusion.expr)
explain() (datafusion.dataframe.DataFrame method)
Expr (class in datafusion)
(class in datafusion.expr)
expr (datafusion.Expr attribute)
(datafusion.expr.Expr attribute)
expr() (datafusion.expr.SortExpr method)
Extension (in module datafusion.expr)
F
factorial() (in module datafusion.functions)
Filter (in module datafusion.expr)
filter() (datafusion.dataframe.DataFrame method)
(datafusion.Expr method)
(datafusion.expr.Expr method)
find_in_set() (in module datafusion.functions)
first_value() (in module datafusion.functions)
flatten() (in module datafusion.functions)
floor() (in module datafusion.functions)
frame_bound (datafusion.expr.WindowFrameBound attribute)
from_arrow() (datafusion.context.SessionContext method)
from_arrow_table() (datafusion.context.SessionContext method)
from_pandas() (datafusion.context.SessionContext method)
from_polars() (datafusion.context.SessionContext method)
from_proto() (datafusion.ExecutionPlan static method)
(datafusion.LogicalPlan static method)
(datafusion.plan.ExecutionPlan static method)
(datafusion.plan.LogicalPlan static method)
from_pydict() (datafusion.context.SessionContext method)
from_pylist() (datafusion.context.SessionContext method)
from_substrait_plan() (datafusion.substrait.Consumer static method)
from_unixtime() (in module datafusion.functions)
G
gcd() (in module datafusion.functions)
get_frame_units() (datafusion.expr.WindowFrame method)
(datafusion.WindowFrame method)
get_lower_bound() (datafusion.expr.WindowFrame method)
(datafusion.WindowFrame method)
get_offset() (datafusion.expr.WindowFrameBound method)
get_range() (datafusion.udf.WindowEvaluator method)
get_upper_bound() (datafusion.expr.WindowFrame method)
(datafusion.WindowFrame method)
GoogleCloud (in module datafusion.object_store)
GroupingSet (in module datafusion.expr)
H
Http (in module datafusion.object_store)
I
ILike (in module datafusion.expr)
Immutable (datafusion.udf.Volatility attribute)
in_list() (in module datafusion.functions)
include_rank() (datafusion.udf.WindowEvaluator method)
initcap() (in module datafusion.functions)
InList (in module datafusion.expr)
inputs() (datafusion.LogicalPlan method)
(datafusion.plan.LogicalPlan method)
InSubquery (in module datafusion.expr)
intersect() (datafusion.dataframe.DataFrame method)
is_causal() (datafusion.udf.WindowEvaluator method)
is_correct_input() (datafusion.input.base.BaseInputSource method)
(datafusion.input.location.LocationInputPlugin method)
is_current_row() (datafusion.expr.WindowFrameBound method)
is_following() (datafusion.expr.WindowFrameBound method)
is_not_null() (datafusion.Expr method)
(datafusion.expr.Expr method)
is_null() (datafusion.Expr method)
(datafusion.expr.Expr method)
is_preceding() (datafusion.expr.WindowFrameBound method)
is_unbounded() (datafusion.expr.WindowFrameBound method)
IsFalse (in module datafusion.expr)
isnan() (in module datafusion.functions)
IsNotFalse (in module datafusion.expr)
IsNotNull (in module datafusion.expr)
IsNotTrue (in module datafusion.expr)
IsNotUnknown (in module datafusion.expr)
IsNull (in module datafusion.expr)
IsTrue (in module datafusion.expr)
IsUnknown (in module datafusion.expr)
iszero() (in module datafusion.functions)
J
Join (in module datafusion.expr)
join() (datafusion.dataframe.DataFrame method)
JoinConstraint (in module datafusion.expr)
JoinType (in module datafusion.expr)
K
kind (datafusion.catalog.Table property)
(datafusion.Table property)
L
lag() (in module datafusion.functions)
last_value() (in module datafusion.functions)
lcm() (in module datafusion.functions)
lead() (in module datafusion.functions)
left() (in module datafusion.functions)
length() (in module datafusion.functions)
levenshtein() (in module datafusion.functions)
Like (in module datafusion.expr)
Limit (in module datafusion.expr)
limit() (datafusion.dataframe.DataFrame method)
list_append() (in module datafusion.functions)
list_dims() (in module datafusion.functions)
list_distinct() (in module datafusion.functions)
list_element() (in module datafusion.functions)
list_except() (in module datafusion.functions)
list_extract() (in module datafusion.functions)
list_indexof() (in module datafusion.functions)
list_intersect() (in module datafusion.functions)
list_join() (in module datafusion.functions)
list_length() (in module datafusion.functions)
list_ndims() (in module datafusion.functions)
list_position() (in module datafusion.functions)
list_positions() (in module datafusion.functions)
list_prepend() (in module datafusion.functions)
list_push_back() (in module datafusion.functions)
list_push_front() (in module datafusion.functions)
list_remove() (in module datafusion.functions)
list_remove_all() (in module datafusion.functions)
list_remove_n() (in module datafusion.functions)
list_replace() (in module datafusion.functions)
list_replace_all() (in module datafusion.functions)
list_replace_n() (in module datafusion.functions)
list_resize() (in module datafusion.functions)
list_slice() (in module datafusion.functions)
list_sort() (in module datafusion.functions)
list_to_string() (in module datafusion.functions)
list_union() (in module datafusion.functions)
lit() (in module datafusion)
Literal (in module datafusion.expr)
literal() (datafusion.Expr static method)
(datafusion.expr.Expr static method)
(in module datafusion)
ln() (in module datafusion.functions)
LocalFileSystem (in module datafusion.object_store)
LocationInputPlugin (class in datafusion.input.location)
log() (in module datafusion.functions)
log10() (in module datafusion.functions)
log2() (in module datafusion.functions)
logical_plan() (datafusion.dataframe.DataFrame method)
LogicalPlan (class in datafusion)
(class in datafusion.plan)
lower() (in module datafusion.functions)
lpad() (in module datafusion.functions)
ltrim() (in module datafusion.functions)
M
make_array() (in module datafusion.functions)
make_date() (in module datafusion.functions)
max() (in module datafusion.functions)
md5() (in module datafusion.functions)
mean() (in module datafusion.functions)
median() (in module datafusion.functions)
memoize() (datafusion.udf.WindowEvaluator method)
merge() (datafusion.Accumulator method)
(datafusion.udf.Accumulator method)
MicrosoftAzure (in module datafusion.object_store)
min() (in module datafusion.functions)
module
datafusion
datafusion.catalog
datafusion.context
datafusion.dataframe
datafusion.expr
datafusion.functions
datafusion.input
datafusion.input.base
datafusion.input.location
datafusion.object_store
datafusion.plan
datafusion.record_batch
datafusion.substrait
datafusion.udf
N
named_struct() (in module datafusion.functions)
names() (datafusion.Catalog method)
(datafusion.catalog.Catalog method)
(datafusion.catalog.Database method)
(datafusion.Database method)
nanvl() (in module datafusion.functions)
Negative (in module datafusion.expr)
next() (datafusion.record_batch.RecordBatchStream method)
(datafusion.RecordBatchStream method)
Not (in module datafusion.expr)
now() (in module datafusion.functions)
nth_value() (in module datafusion.functions)
ntile() (in module datafusion.functions)
null_treatment() (datafusion.Expr method)
(datafusion.expr.Expr method)
nullif() (in module datafusion.functions)
nulls_first() (datafusion.expr.SortExpr method)
O
octet_length() (in module datafusion.functions)
optimized_logical_plan() (datafusion.dataframe.DataFrame method)
options_internal (datafusion.context.SQLOptions attribute)
(datafusion.SQLOptions attribute)
order_by() (datafusion.Expr method)
(datafusion.expr.Expr method)
(in module datafusion.functions)
otherwise() (datafusion.expr.CaseBuilder method)
over() (datafusion.Expr method)
(datafusion.expr.Expr method)
overlay() (in module datafusion.functions)
P
partition_by() (datafusion.Expr method)
(datafusion.expr.Expr method)
partition_count (datafusion.ExecutionPlan property)
(datafusion.plan.ExecutionPlan property)
Partitioning (in module datafusion.expr)
percent_rank() (in module datafusion.functions)
pi() (in module datafusion.functions)
Placeholder (in module datafusion.expr)
Plan (class in datafusion.substrait)
plan_internal (datafusion.substrait.Plan attribute)
pow() (in module datafusion.functions)
power() (in module datafusion.functions)
Producer (class in datafusion.substrait)
Projection (in module datafusion.expr)
python_value() (datafusion.Expr method)
(datafusion.expr.Expr method)
R
radians() (in module datafusion.functions)
random() (in module datafusion.functions)
range() (in module datafusion.functions)
rank() (in module datafusion.functions)
raw_sort (datafusion.expr.SortExpr attribute)
rbs (datafusion.record_batch.RecordBatchStream attribute)
(datafusion.RecordBatchStream attribute)
read_avro() (datafusion.context.SessionContext method)
read_csv() (datafusion.context.SessionContext method)
read_json() (datafusion.context.SessionContext method)
read_parquet() (datafusion.context.SessionContext method)
read_table() (datafusion.context.SessionContext method)
record_batch (datafusion.record_batch.RecordBatch attribute)
(datafusion.RecordBatch attribute)
RecordBatch (class in datafusion)
(class in datafusion.record_batch)
RecordBatchStream (class in datafusion)
(class in datafusion.record_batch)
regexp_like() (in module datafusion.functions)
regexp_match() (in module datafusion.functions)
regexp_replace() (in module datafusion.functions)
register_avro() (datafusion.context.SessionContext method)
register_csv() (datafusion.context.SessionContext method)
register_dataset() (datafusion.context.SessionContext method)
register_json() (datafusion.context.SessionContext method)
register_listing_table() (datafusion.context.SessionContext method)
register_object_store() (datafusion.context.SessionContext method)
register_parquet() (datafusion.context.SessionContext method)
register_record_batches() (datafusion.context.SessionContext method)
register_table() (datafusion.context.SessionContext method)
register_udaf() (datafusion.context.SessionContext method)
register_udf() (datafusion.context.SessionContext method)
register_udwf() (datafusion.context.SessionContext method)
regr_avgx() (in module datafusion.functions)
regr_avgy() (in module datafusion.functions)
regr_count() (in module datafusion.functions)
regr_intercept() (in module datafusion.functions)
regr_r2() (in module datafusion.functions)
regr_slope() (in module datafusion.functions)
regr_sxx() (in module datafusion.functions)
regr_sxy() (in module datafusion.functions)
regr_syy() (in module datafusion.functions)
Repartition (in module datafusion.expr)
repartition() (datafusion.dataframe.DataFrame method)
repartition_by_hash() (datafusion.dataframe.DataFrame method)
repeat() (in module datafusion.functions)
replace() (in module datafusion.functions)
reverse() (in module datafusion.functions)
rex_call_operands() (datafusion.Expr method)
(datafusion.expr.Expr method)
rex_call_operator() (datafusion.Expr method)
(datafusion.expr.Expr method)
rex_type() (datafusion.Expr method)
(datafusion.expr.Expr method)
right() (in module datafusion.functions)
round() (in module datafusion.functions)
row_number() (in module datafusion.functions)
rpad() (in module datafusion.functions)
rtrim() (in module datafusion.functions)
runtime (datafusion.context.SessionContext attribute)
RuntimeConfig (class in datafusion)
(class in datafusion.context)
S
ScalarSubquery (in module datafusion.expr)
ScalarUDF (class in datafusion)
(class in datafusion.udf)
ScalarVariable (in module datafusion.expr)
schema() (datafusion.catalog.Table method)
(datafusion.dataframe.DataFrame method)
(datafusion.Table method)
schema_name() (datafusion.Expr method)
(datafusion.expr.Expr method)
select() (datafusion.dataframe.DataFrame method)
select_columns() (datafusion.dataframe.DataFrame method)
Serde (class in datafusion.substrait)
serialize() (datafusion.substrait.Serde static method)
serialize_bytes() (datafusion.substrait.Serde static method)
serialize_to_plan() (datafusion.substrait.Serde static method)
session_id() (datafusion.context.SessionContext method)
SessionConfig (class in datafusion)
(class in datafusion.context)
SessionContext (class in datafusion.context)
set() (datafusion.context.SessionConfig method)
(datafusion.SessionConfig method)
sha224() (in module datafusion.functions)
sha256() (in module datafusion.functions)
sha384() (in module datafusion.functions)
sha512() (in module datafusion.functions)
show() (datafusion.dataframe.DataFrame method)
signum() (in module datafusion.functions)
SimilarTo (in module datafusion.expr)
sin() (in module datafusion.functions)
sinh() (in module datafusion.functions)
Sort (in module datafusion.expr)
sort() (datafusion.dataframe.DataFrame method)
(datafusion.Expr method)
(datafusion.expr.Expr method)
SortExpr (class in datafusion.expr)
split_part() (in module datafusion.functions)
sql() (datafusion.context.SessionContext method)
sql_with_options() (datafusion.context.SessionContext method)
SQLOptions (class in datafusion)
(class in datafusion.context)
sqrt() (in module datafusion.functions)
Stable (datafusion.udf.Volatility attribute)
starts_with() (in module datafusion.functions)
state() (datafusion.Accumulator method)
(datafusion.udf.Accumulator method)
stddev() (in module datafusion.functions)
stddev_pop() (in module datafusion.functions)
stddev_samp() (in module datafusion.functions)
string_agg() (in module datafusion.functions)
strpos() (in module datafusion.functions)
struct() (in module datafusion.functions)
Subquery (in module datafusion.expr)
SubqueryAlias (in module datafusion.expr)
substr() (in module datafusion.functions)
substr_index() (in module datafusion.functions)
substring() (in module datafusion.functions)
sum() (in module datafusion.functions)
supports_bounded_execution() (datafusion.udf.WindowEvaluator method)
T
Table (class in datafusion)
(class in datafusion.catalog)
table (datafusion.catalog.Table attribute)
(datafusion.Table attribute)
table() (datafusion.catalog.Database method)
(datafusion.context.SessionContext method)
(datafusion.Database method)
table_exist() (datafusion.context.SessionContext method)
TableScan (in module datafusion.expr)
tan() (in module datafusion.functions)
tanh() (in module datafusion.functions)
to_arrow_table() (datafusion.dataframe.DataFrame method)
to_hex() (in module datafusion.functions)
to_pandas() (datafusion.dataframe.DataFrame method)
to_polars() (datafusion.dataframe.DataFrame method)
to_proto() (datafusion.ExecutionPlan method)
(datafusion.LogicalPlan method)
(datafusion.plan.ExecutionPlan method)
(datafusion.plan.LogicalPlan method)
to_pyarrow() (datafusion.record_batch.RecordBatch method)
(datafusion.RecordBatch method)
to_pydict() (datafusion.dataframe.DataFrame method)
to_pylist() (datafusion.dataframe.DataFrame method)
to_substrait_plan() (datafusion.substrait.Producer static method)
to_timestamp() (in module datafusion.functions)
to_timestamp_micros() (in module datafusion.functions)
to_timestamp_millis() (in module datafusion.functions)
to_timestamp_seconds() (in module datafusion.functions)
to_unixtime() (in module datafusion.functions)
to_variant() (datafusion.Expr method)
(datafusion.expr.Expr method)
(datafusion.LogicalPlan method)
(datafusion.plan.LogicalPlan method)
transform() (datafusion.dataframe.DataFrame method)
translate() (in module datafusion.functions)
trim() (in module datafusion.functions)
trunc() (in module datafusion.functions)
TryCast (in module datafusion.expr)
types() (datafusion.Expr method)
(datafusion.expr.Expr method)
U
udaf() (datafusion.AggregateUDF static method)
(datafusion.udf.AggregateUDF static method)
udf() (datafusion.ScalarUDF static method)
(datafusion.udf.ScalarUDF static method)
udwf() (datafusion.udf.WindowUDF static method)
(datafusion.WindowUDF static method)
Union (in module datafusion.expr)
union() (datafusion.dataframe.DataFrame method)
union_distinct() (datafusion.dataframe.DataFrame method)
Unnest (in module datafusion.expr)
unnest_columns() (datafusion.dataframe.DataFrame method)
UnnestExpr (in module datafusion.expr)
update() (datafusion.Accumulator method)
(datafusion.udf.Accumulator method)
upper() (in module datafusion.functions)
uses_window_frame() (datafusion.udf.WindowEvaluator method)
uuid() (in module datafusion.functions)
V
var() (in module datafusion.functions)
var_pop() (in module datafusion.functions)
var_samp() (in module datafusion.functions)
var_sample() (in module datafusion.functions)
variant_name() (datafusion.Expr method)
(datafusion.expr.Expr method)
Volatile (datafusion.udf.Volatility attribute)
Volatility (class in datafusion.udf)
W
when() (datafusion.expr.CaseBuilder method)
(in module datafusion.functions)
Window (class in datafusion.expr)
window() (in module datafusion.functions)
window_frame (datafusion.expr.WindowFrame attribute)
(datafusion.WindowFrame attribute)
window_frame() (datafusion.Expr method)
(datafusion.expr.Expr method)
WindowEvaluator (class in datafusion.udf)
WindowExpr (in module datafusion.expr)
WindowFrame (class in datafusion)
(class in datafusion.expr)
WindowFrameBound (class in datafusion.expr)
WindowUDF (class in datafusion)
(class in datafusion.udf)
with_allow_ddl() (datafusion.context.SQLOptions method)
(datafusion.SQLOptions method)
with_allow_dml() (datafusion.context.SQLOptions method)
(datafusion.SQLOptions method)
with_allow_statements() (datafusion.context.SQLOptions method)
(datafusion.SQLOptions method)
with_batch_size() (datafusion.context.SessionConfig method)
(datafusion.SessionConfig method)
with_column() (datafusion.dataframe.DataFrame method)
with_column_renamed() (datafusion.dataframe.DataFrame method)
with_create_default_catalog_and_schema() (datafusion.context.SessionConfig method)
(datafusion.SessionConfig method)
with_default_catalog_and_schema() (datafusion.context.SessionConfig method)
(datafusion.SessionConfig method)
with_disk_manager_disabled() (datafusion.context.RuntimeConfig method)
(datafusion.RuntimeConfig method)
with_disk_manager_os() (datafusion.context.RuntimeConfig method)
(datafusion.RuntimeConfig method)
with_disk_manager_specified() (datafusion.context.RuntimeConfig method)
(datafusion.RuntimeConfig method)
with_fair_spill_pool() (datafusion.context.RuntimeConfig method)
(datafusion.RuntimeConfig method)
with_greedy_memory_pool() (datafusion.context.RuntimeConfig method)
(datafusion.RuntimeConfig method)
with_information_schema() (datafusion.context.SessionConfig method)
(datafusion.SessionConfig method)
with_parquet_pruning() (datafusion.context.SessionConfig method)
(datafusion.SessionConfig method)
with_repartition_aggregations() (datafusion.context.SessionConfig method)
(datafusion.SessionConfig method)
with_repartition_file_min_size() (datafusion.context.SessionConfig method)
(datafusion.SessionConfig method)
with_repartition_file_scans() (datafusion.context.SessionConfig method)
(datafusion.SessionConfig method)
with_repartition_joins() (datafusion.context.SessionConfig method)
(datafusion.SessionConfig method)
with_repartition_sorts() (datafusion.context.SessionConfig method)
(datafusion.SessionConfig method)
with_repartition_windows() (datafusion.context.SessionConfig method)
(datafusion.SessionConfig method)
with_target_partitions() (datafusion.context.SessionConfig method)
(datafusion.SessionConfig method)
with_temp_file_path() (datafusion.context.RuntimeConfig method)
(datafusion.RuntimeConfig method)
with_unbounded_memory_pool() (datafusion.context.RuntimeConfig method)
(datafusion.RuntimeConfig method)
write_csv() (datafusion.dataframe.DataFrame method)
write_json() (datafusion.dataframe.DataFrame method)
write_parquet() (datafusion.dataframe.DataFrame method)