Index _ | A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | Q | R | S | T | U | V | W | X | Z _ __add__() (datafusion.Expr method) (datafusion.expr.Expr method) __aiter__() (datafusion.dataframe.DataFrame method) (datafusion.record_batch.RecordBatchStream method) (datafusion.RecordBatchStream method) __and__() (datafusion.Expr method) (datafusion.expr.Expr method) __anext__() (datafusion.record_batch.RecordBatchStream method) (datafusion.RecordBatchStream method) __arrow_c_array__() (datafusion.context.ArrowArrayExportable method) (datafusion.record_batch.RecordBatch method) (datafusion.RecordBatch method) __arrow_c_stream__() (datafusion.context.ArrowStreamExportable method) (datafusion.dataframe.DataFrame method) __call__() (datafusion.dataframe_formatter.CellFormatter method) (datafusion.user_defined.AggregateUDF method) (datafusion.user_defined.ScalarUDF method) (datafusion.user_defined.TableFunction method) (datafusion.user_defined.WindowUDF method) __datafusion_aggregate_udf__() (datafusion.user_defined.AggregateUDFExportable method) __datafusion_codec_id__ (datafusion.context.SessionContext property) __datafusion_logical_extension_codec__() (datafusion.context.SessionContext method) (datafusion.user_defined.LogicalExtensionCodecExportable method) __datafusion_physical_extension_codec__() (datafusion.context.SessionContext method) (datafusion.user_defined.PhysicalExtensionCodecExportable method) __datafusion_physical_optimizer_rule__() (datafusion.extensions.PhysicalOptimizerRuleExportable method) __datafusion_query_planner__() (datafusion.context.SessionContext method) (datafusion.extensions.QueryPlannerExportable method) __datafusion_scalar_udf__() (datafusion.user_defined.ScalarUDFExportable method) __datafusion_session_components__() (datafusion.extensions.SessionComponentsExportable method) __datafusion_session_planner__() (datafusion.extensions.SessionPlannerExportable method) __datafusion_table_provider__() (datafusion.context.TableProviderExportable method) __datafusion_table_provider_factory__() (datafusion.TableProviderFactoryExportable method) __datafusion_task_context_provider__() (datafusion.context.SessionContext method) __datafusion_window_udf__() (datafusion.user_defined.WindowUDFExportable method) __eq__() (datafusion.Expr method) (datafusion.expr.Expr method) (datafusion.LogicalPlan method) (datafusion.PhysicalPartitioning method) (datafusion.plan.LogicalPlan method) (datafusion.plan.PhysicalPartitioning 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) __hash__() (datafusion.PhysicalPartitioning method) (datafusion.plan.PhysicalPartitioning method) __invert__() (datafusion.Expr method) (datafusion.expr.Expr method) __iter__() (datafusion.dataframe.DataFrame method) (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) __post_init__() (datafusion.extensions.SessionExtensionComponents method) __radd__ (datafusion.Expr attribute) (datafusion.expr.Expr attribute) __rand__ (datafusion.Expr attribute) (datafusion.expr.Expr attribute) __reduce__() (datafusion.Expr method) (datafusion.expr.Expr method) __repr__() (datafusion.Catalog method) (datafusion.catalog.Catalog method) (datafusion.catalog.CatalogList method) (datafusion.catalog.Schema method) (datafusion.catalog.Table method) (datafusion.context.SessionContext method) (datafusion.dataframe.DataFrame method) (datafusion.ExecutionPlan method) (datafusion.Expr method) (datafusion.expr.Expr method) (datafusion.expr.SortExpr method) (datafusion.expr.WindowFrame method) (datafusion.LogicalPlan method) (datafusion.Metric method) (datafusion.MetricsSet method) (datafusion.PhysicalPartitioning method) (datafusion.plan.ExecutionPlan method) (datafusion.plan.LogicalPlan method) (datafusion.plan.Metric method) (datafusion.plan.MetricsSet method) (datafusion.plan.PhysicalPartitioning method) (datafusion.Table method) (datafusion.user_defined.AggregateUDF method) (datafusion.user_defined.ScalarUDF method) (datafusion.user_defined.TableFunction method) (datafusion.user_defined.WindowUDF method) (datafusion.WindowFrame 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) __slots__ (datafusion.catalog.Table attribute) (datafusion.Table attribute) __str__() (datafusion.user_defined.Volatility method) __sub__() (datafusion.Expr method) (datafusion.expr.Expr method) __truediv__() (datafusion.Expr method) (datafusion.expr.Expr method) _build_expandable_cell() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) _build_html_footer() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) _build_html_header() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) _build_regular_cell() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) _build_table_body() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) _build_table_container_start() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) _build_table_header() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) _convert_file_sort_order() (datafusion.context.SessionContext static method) _convert_table_partition_cols() (datafusion.context.SessionContext static method) _create_table_udf() (datafusion.user_defined.TableFunction static method) _create_table_udf_decorator() (datafusion.user_defined.TableFunction static method) _create_window_udf() (datafusion.user_defined.WindowUDF static method) _create_window_udf_decorator() (datafusion.user_defined.WindowUDF static method) _custom_cell_builder (datafusion.dataframe_formatter.DataFrameHtmlFormatter attribute) _custom_header_builder (datafusion.dataframe_formatter.DataFrameHtmlFormatter attribute) _default_formatter (datafusion.dataframe_formatter.FormatterManager attribute) _format_cell_value() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) _from_internal() (datafusion.user_defined.AggregateUDF class method) (datafusion.user_defined.ScalarUDF class method) (datafusion.user_defined.WindowUDF class method) _get_cell_value() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) _get_default_css() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) _get_default_name() (datafusion.user_defined.WindowUDF static method) _get_javascript() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) _inner (datafusion.catalog.Table attribute) (datafusion.Table attribute) _is_pycapsule() (in module datafusion.user_defined) _key() (datafusion.PhysicalPartitioning method) (datafusion.plan.PhysicalPartitioning method) _max_rows (datafusion.dataframe_formatter.DataFrameHtmlFormatter attribute) _normalize_input_types() (datafusion.user_defined.WindowUDF static method) _null_treatment (datafusion.expr.Window attribute) _order_by (datafusion.expr.Window attribute) _partition_by (datafusion.expr.Window attribute) _R (in module datafusion.user_defined) _raw (datafusion.Metric attribute) (datafusion.MetricsSet attribute) (datafusion.plan.Metric attribute) (datafusion.plan.MetricsSet attribute) _raw_partitioning (datafusion.PhysicalPartitioning attribute) (datafusion.plan.PhysicalPartitioning attribute) _raw_plan (datafusion.ExecutionPlan attribute) (datafusion.LogicalPlan attribute) (datafusion.plan.ExecutionPlan attribute) (datafusion.plan.LogicalPlan attribute) _raw_schema (datafusion.catalog.Schema attribute) _raw_write_options (datafusion.dataframe.DataFrameWriteOptions attribute) (datafusion.DataFrameWriteOptions attribute) _reconstruct() (datafusion.Expr class method) (datafusion.expr.Expr class method) _refresh_formatter_reference() (in module datafusion.dataframe_formatter) _register_object_store_for_path() (datafusion.context.SessionContext method) _repr_html_() (datafusion.dataframe.DataFrame method) _to_pyarrow_types (datafusion.Expr attribute) (datafusion.expr.Expr attribute) _type_formatters (datafusion.dataframe_formatter.DataFrameHtmlFormatter attribute) _udaf (datafusion.user_defined.AggregateUDF attribute) _udf (datafusion.user_defined.ScalarUDF attribute) _udtf (datafusion.user_defined.TableFunction attribute) _udwf (datafusion.user_defined.WindowUDF attribute) _validate_bool() (in module datafusion.dataframe_formatter) _validate_formatter_parameters() (in module datafusion.dataframe_formatter) _validate_positive_int() (in module datafusion.dataframe_formatter) _window_frame (datafusion.expr.Window attribute) _wrap_session_kwarg_for_udtf() (in module datafusion.user_defined) A abs() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) (in module datafusion.functions.spark) Accumulator (class in datafusion.user_defined) acos() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) acosh() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) add_months() (in module datafusion.functions.spark) add_physical_optimizer_rule() (datafusion.context.SessionContext method) Aggregate (in module datafusion.expr) aggregate() (datafusion.dataframe.DataFrame method) AggregateFunction (in module datafusion.expr) AggregateUDF (class in datafusion.user_defined) AggregateUDFExportable (class in datafusion.user_defined) Alias (in module datafusion.expr) alias() (datafusion.dataframe.DataFrame method) (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) allow_single_file_parallelism (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) AmazonS3 (in module datafusion.object_store) Analyze (in module datafusion.expr) any_match() (in module datafusion.functions) any_value() (in module datafusion.functions) APPEND (datafusion.dataframe.InsertOp attribute) (datafusion.InsertOp attribute) 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) (in module datafusion.functions.spark) array_add() (in module datafusion.functions) array_agg() (in module datafusion.functions) array_any_match() (in module datafusion.functions) array_any_value() (in module datafusion.functions) array_append() (in module datafusion.functions) array_avg() (in module datafusion.functions) array_cat() (in module datafusion.functions) array_compact() (in module datafusion.functions) array_concat() (in module datafusion.functions) array_contains() (in module datafusion.functions) (in module datafusion.functions.spark) array_dims() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) array_distance() (in module datafusion.functions) array_distinct() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) array_element() (in module datafusion.functions) array_empty() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) array_except() (in module datafusion.functions) array_extract() (in module datafusion.functions) array_filter() (in module datafusion.functions) array_first() (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() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) array_max() (in module datafusion.functions) array_min() (in module datafusion.functions) array_ndims() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) array_normalize() (in module datafusion.functions) array_pop_back() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) array_pop_front() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) array_position() (in module datafusion.functions) array_positions() (in module datafusion.functions) array_prepend() (in module datafusion.functions) array_product() (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) (in module datafusion.functions.spark) 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_reverse() (in module datafusion.functions) array_scale() (in module datafusion.functions) array_slice() (in module datafusion.functions) array_sort() (in module datafusion.functions) array_subtract() (in module datafusion.functions) array_sum() (in module datafusion.functions) array_to_string() (in module datafusion.functions) array_transform() (in module datafusion.functions) array_union() (in module datafusion.functions) arrays_overlap() (in module datafusion.functions) arrays_zip() (in module datafusion.functions) arrow_cast() (in module datafusion.functions) arrow_field() (in module datafusion.functions) arrow_metadata() (in module datafusion.functions) arrow_try_cast() (in module datafusion.functions) arrow_typeof() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) ArrowArrayExportable (class in datafusion.context) ArrowStreamExportable (class in datafusion.context) ascending() (datafusion.expr.SortExpr method) ascii() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) (in module datafusion.functions.spark) asin() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) asinh() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) atan() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) atan2() (in module datafusion.functions) (in module datafusion.functions.spark) atanh() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) avg() (in module datafusion.functions) (in module datafusion.functions.spark) B base64() (in module datafusion.functions.spark) BaseInputSource (class in datafusion.input.base) Between (in module datafusion.expr) between() (datafusion.Expr method) (datafusion.expr.Expr method) bin() (in module datafusion.functions.spark) BinaryExpr (in module datafusion.expr) bit_and() (in module datafusion.functions) bit_count() (in module datafusion.functions.spark) bit_get() (in module datafusion.functions.spark) bit_length() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) bit_or() (in module datafusion.functions) bit_xor() (in module datafusion.functions) bitmap_bit_position() (in module datafusion.functions.spark) bitmap_bucket_number() (in module datafusion.functions.spark) bitmap_count() (in module datafusion.functions.spark) bitwise_not() (in module datafusion.functions.spark) bloom_filter_enabled (datafusion.dataframe.ParquetColumnOptions attribute) (datafusion.ParquetColumnOptions attribute) bloom_filter_fpp (datafusion.dataframe.ParquetColumnOptions attribute) (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetColumnOptions attribute) (datafusion.ParquetWriterOptions attribute) bloom_filter_ndv (datafusion.dataframe.ParquetColumnOptions attribute) (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetColumnOptions attribute) (datafusion.ParquetWriterOptions attribute) bloom_filter_on_write (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) bool_and() (in module datafusion.functions) bool_or() (in module datafusion.functions) BROTLI (datafusion.dataframe.Compression attribute) btrim() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) build_table() (datafusion.input.base.BaseInputSource method) (datafusion.input.location.LocationInputPlugin method) (datafusion.input.LocationInputPlugin method) BYTES (datafusion.dataframe.ExplainMetricCategory attribute) C cache() (datafusion.dataframe.DataFrame method) canonical_name() (datafusion.Expr method) (datafusion.expr.Expr method) cardinality() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) 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.dataframe.DataFrame method) (datafusion.Expr method) (datafusion.expr.Expr method) cast_to_type() (in module datafusion.functions) Catalog (class in datafusion) (class in datafusion.catalog) catalog (datafusion.Catalog attribute) (datafusion.catalog.Catalog attribute) catalog() (datafusion.catalog.CatalogList method) (datafusion.catalog.CatalogProviderList method) (datafusion.context.SessionContext method) catalog_list (datafusion.catalog.CatalogList attribute) catalog_names() (datafusion.catalog.CatalogList method) (datafusion.catalog.CatalogProviderList method) (datafusion.context.SessionContext method) CatalogList (class in datafusion.catalog) CatalogProvider (class in datafusion.catalog) CatalogProviderList (class in datafusion.catalog) cbrt() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) ceil() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) (in module datafusion.functions.spark) ceiling() (in module datafusion.functions.spark) CellFormatter (class in datafusion.dataframe_formatter) char() (in module datafusion.functions.spark) char_length() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) (in module datafusion.functions.spark) character_length() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) (in module datafusion.functions.spark) children() (datafusion.ExecutionPlan method) (datafusion.plan.ExecutionPlan method) chr() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) clear_sender_ctx() (in module datafusion.ipc) clear_worker_ctx() (in module datafusion.ipc) coalesce() (in module datafusion.functions) coerce_to_expr() (in module datafusion.expr) coerce_to_expr_list() (in module datafusion.expr) coerce_to_expr_or_none() (in module datafusion.expr) col (in module datafusion) col() (datafusion.dataframe.DataFrame method) (in module datafusion.functions) collect() (datafusion.dataframe.DataFrame method) collect_column() (datafusion.dataframe.DataFrame method) collect_list() (in module datafusion.functions.spark) collect_metrics() (datafusion.ExecutionPlan method) (datafusion.plan.ExecutionPlan method) collect_partitioned() (datafusion.dataframe.DataFrame method) collect_set() (in module datafusion.functions.spark) column (in module datafusion) Column (in module datafusion.expr) column() (datafusion.dataframe.DataFrame method) (datafusion.Expr static method) (datafusion.expr.Expr static method) column_index_truncate_length (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) column_name() (datafusion.Expr method) (datafusion.expr.Expr method) column_specific_options (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) comment (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) Compression (class in datafusion.dataframe) compression (datafusion.dataframe.ParquetColumnOptions attribute) (datafusion.ParquetColumnOptions attribute) concat() (in module datafusion.functions) (in module datafusion.functions.spark) concat_ws() (in module datafusion.functions) (in module datafusion.functions.spark) config_internal (datafusion.context.RuntimeEnvBuilder attribute) (datafusion.context.SessionConfig attribute) (datafusion.RuntimeEnvBuilder attribute) (datafusion.SessionConfig attribute) configure_formatter() (in module datafusion) (in module datafusion.dataframe_formatter) Consumer (class in datafusion.substrait) contains() (in module datafusion.functions) copied_config() (datafusion.context.SessionContext method) CopyTo (in module datafusion.expr) corr() (in module datafusion.functions) cos() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) cosh() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) cosine_distance() (in module datafusion.functions) cot() (datafusion.Expr method) (datafusion.expr.Expr method) (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) crc32() (in module datafusion.functions.spark) create() (datafusion.catalog.TableProviderFactory method) (datafusion.TableProviderFactory method) create_dataframe() (datafusion.context.SessionContext method) create_dataframe_from_logical_plan() (datafusion.context.SessionContext method) CreateCatalog (in module datafusion.expr) CreateCatalogSchema (in module datafusion.expr) created_by (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) CreateExternalTable (in module datafusion.expr) CreateFunction (in module datafusion.expr) CreateFunctionBody (in module datafusion.expr) CreateIndex (in module datafusion.expr) CreateMemoryTable (in module datafusion.expr) CreateView (in module datafusion.expr) csc() (in module datafusion.functions.spark) CsvReadOptions (class in datafusion) (class in datafusion.options) ctx (datafusion.context.SessionContext attribute) cube() (datafusion.expr.GroupingSet static method) cume_dist() (in module datafusion.functions) current_date() (in module datafusion.functions) current_time() (in module datafusion.functions) current_timestamp() (in module datafusion.functions) custom_css (datafusion.dataframe_formatter.DataFrameHtmlFormatter attribute) D data_page_row_count_limit (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) data_pagesize_limit (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) data_type_or_field_to_field() (in module datafusion.user_defined) data_types_or_fields_to_field_list() (in module datafusion.user_defined) DataFrame (class in datafusion.dataframe) DataFrameHtmlFormatter (class in datafusion.dataframe_formatter) DataFrameWriteOptions (class in datafusion) (class in datafusion.dataframe) datafusion module datafusion.catalog module datafusion.context module datafusion.dataframe module datafusion.dataframe_formatter module datafusion.expr module datafusion.extensions module datafusion.functions module datafusion.functions.spark module datafusion.input module datafusion.input.base module datafusion.input.location module datafusion.io module datafusion.ipc module datafusion.object_store module datafusion.options module datafusion.plan module datafusion.record_batch module datafusion.substrait module datafusion.unparser module datafusion.user_defined module date_add() (in module datafusion.functions.spark) date_bin() (in module datafusion.functions) date_diff() (in module datafusion.functions.spark) date_format() (in module datafusion.functions) date_part() (in module datafusion.functions) (in module datafusion.functions.spark) date_sub() (in module datafusion.functions.spark) date_trunc() (in module datafusion.functions) (in module datafusion.functions.spark) dateadd() (in module datafusion.functions.spark) datediff() (in module datafusion.functions.spark) datepart() (in module datafusion.functions) (in module datafusion.functions.spark) datetrunc() (in module datafusion.functions) Deallocate (in module datafusion.expr) decode() (in module datafusion.functions) default() (datafusion.unparser.Dialect static method) default_str_repr() (datafusion.dataframe.DataFrame static method) DefaultStyleProvider (class in datafusion.dataframe_formatter) degrees() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) delimiter (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) dense_rank() (in module datafusion.functions) deregister_object_store() (datafusion.context.SessionContext method) deregister_schema() (datafusion.Catalog method) (datafusion.catalog.Catalog method) (datafusion.catalog.CatalogProvider method) deregister_table() (datafusion.catalog.Schema method) (datafusion.catalog.SchemaProvider method) (datafusion.context.SessionContext method) deregister_udaf() (datafusion.context.SessionContext method) deregister_udf() (datafusion.context.SessionContext method) deregister_udtf() (datafusion.context.SessionContext method) deregister_udwf() (datafusion.context.SessionContext method) describe() (datafusion.dataframe.DataFrame method) DescribeTable (in module datafusion.expr) deserialize() (datafusion.substrait.Serde static method) deserialize_bytes() (datafusion.substrait.Serde static method) DEV (datafusion.dataframe.ExplainAnalyzeLevel attribute) df (datafusion.dataframe.DataFrame attribute) DFSchema (in module datafusion) Dialect (class in datafusion.unparser) dialect (datafusion.unparser.Dialect attribute) dictionary_enabled (datafusion.dataframe.ParquetColumnOptions attribute) (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetColumnOptions attribute) (datafusion.ParquetWriterOptions attribute) dictionary_page_size_limit (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) 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) Distinct (in module datafusion.expr) distinct() (datafusion.dataframe.DataFrame method) (datafusion.Expr method) (datafusion.expr.Expr method) distinct_on() (datafusion.dataframe.DataFrame method) DmlStatement (in module datafusion.expr) dot_product() (in module datafusion.functions) drop() (datafusion.dataframe.DataFrame method) DropCatalogSchema (in module datafusion.expr) DropFunction (in module datafusion.expr) DropTable (in module datafusion.expr) DropView (in module datafusion.expr) duckdb() (datafusion.unparser.Dialect static method) E elapsed_compute (datafusion.MetricsSet property) (datafusion.plan.MetricsSet property) element_at() (in module datafusion.functions) elt() (in module datafusion.functions.spark) empty() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) empty_table() (datafusion.context.SessionContext method) EmptyRelation (in module datafusion.expr) enable_cell_expansion (datafusion.dataframe_formatter.DataFrameHtmlFormatter attribute) enable_ident_normalization() (datafusion.context.SessionContext method) enable_spark_functions() (datafusion.context.SessionContext method) enable_url_table() (datafusion.context.SessionContext method) encode() (datafusion.substrait.Plan method) (in module datafusion.functions) encoding (datafusion.dataframe.ParquetColumnOptions attribute) (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetColumnOptions attribute) (datafusion.ParquetWriterOptions attribute) end() (datafusion.expr.CaseBuilder method) ends_with() (in module datafusion.functions) ensure_expr() (in module datafusion.expr) ensure_expr_list() (in module datafusion.expr) escape (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) evaluate() (datafusion.user_defined.Accumulator method) (datafusion.user_defined.WindowEvaluator method) evaluate_all() (datafusion.user_defined.WindowEvaluator method) evaluate_all_with_rank() (datafusion.user_defined.WindowEvaluator method) except_all() (datafusion.dataframe.DataFrame method) Execute (in module datafusion.expr) execute() (datafusion.context.SessionContext method) execute_logical_plan() (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() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) Explain (in module datafusion.expr) explain() (datafusion.dataframe.DataFrame method) ExplainAnalyzeLevel (class in datafusion.dataframe) ExplainFormat (class in datafusion) (class in datafusion.dataframe) ExplainMetricCategory (class in datafusion.dataframe) expm1() (in module datafusion.functions.spark) Expr (class in datafusion) (class in datafusion.expr) expr (datafusion.Expr attribute) (datafusion.expr.Expr attribute) expr() (datafusion.expr.SortExpr method) EXPR_TYPE_ERROR (in module datafusion.expr) Extension (in module datafusion.expr) extract() (in module datafusion.functions) F factorial() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) (in module datafusion.functions.spark) file_compression_type (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) file_extension (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) file_row_index() (in module datafusion.functions) file_sort_order (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) FileType (in module datafusion.expr) fill_nan() (datafusion.dataframe.DataFrame method) (datafusion.Expr method) (datafusion.expr.Expr method) fill_null() (datafusion.dataframe.DataFrame method) (datafusion.Expr method) (datafusion.expr.Expr method) Filter (in module datafusion.expr) filter() (datafusion.dataframe.DataFrame method) (datafusion.Expr method) (datafusion.expr.Expr method) find_in_set() (in module datafusion.functions) find_qualified_columns() (datafusion.dataframe.DataFrame method) first_value() (in module datafusion.functions) flatten() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) floor() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) (in module datafusion.functions.spark) format_html() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) format_str() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) format_string() (in module datafusion.functions.spark) FormatterManager (class in datafusion.dataframe_formatter) frame_bound (datafusion.expr.WindowFrameBound attribute) from_arrow() (datafusion.context.SessionContext method) from_bytes() (datafusion.ExecutionPlan static method) (datafusion.Expr class method) (datafusion.expr.Expr class method) (datafusion.LogicalPlan static method) (datafusion.plan.ExecutionPlan static method) (datafusion.plan.LogicalPlan static method) from_dataset() (datafusion.catalog.Table static method) (datafusion.Table static method) from_json() (datafusion.substrait.Plan static 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_pycapsule() (datafusion.user_defined.AggregateUDF static method) (datafusion.user_defined.ScalarUDF static method) (datafusion.user_defined.WindowUDF static method) from_pydict() (datafusion.context.SessionContext method) from_pylist() (datafusion.context.SessionContext method) from_str() (datafusion.dataframe.Compression class method) from_substrait_plan() (datafusion.substrait.Consumer static method) from_unixtime() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) from_utc_timestamp() (in module datafusion.functions.spark) G gcd() (in module datafusion.functions) gen_series() (in module datafusion.functions) generate_series() (in module datafusion.functions) get_cell_style() (datafusion.dataframe_formatter.DefaultStyleProvider method) (datafusion.dataframe_formatter.StyleProvider method) get_default_level() (datafusion.dataframe.Compression method) get_field() (in module datafusion.functions) get_formatter() (datafusion.dataframe_formatter.FormatterManager class method) (in module datafusion.dataframe_formatter) get_frame_units() (datafusion.expr.WindowFrame method) (datafusion.WindowFrame method) get_header_style() (datafusion.dataframe_formatter.DefaultStyleProvider method) (datafusion.dataframe_formatter.StyleProvider method) get_lower_bound() (datafusion.expr.WindowFrame method) (datafusion.WindowFrame method) get_offset() (datafusion.expr.WindowFrameBound method) get_range() (datafusion.user_defined.WindowEvaluator method) get_sender_ctx() (in module datafusion.ipc) get_upper_bound() (datafusion.expr.WindowFrame method) (datafusion.WindowFrame method) get_worker_ctx() (in module datafusion.ipc) getbit() (in module datafusion.functions.spark) global_ctx() (datafusion.context.SessionContext class method) GoogleCloud (in module datafusion.object_store) GRAPHVIZ (datafusion.dataframe.ExplainFormat attribute) (datafusion.ExplainFormat attribute) greatest() (in module datafusion.functions) grouping() (in module datafusion.functions) grouping_sets() (datafusion.expr.GroupingSet static method) GroupingSet (class in datafusion.expr) GZIP (datafusion.dataframe.Compression attribute) H has_header (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) hash_expressions (datafusion.PhysicalPartitioning property) (datafusion.plan.PhysicalPartitioning property) head() (datafusion.dataframe.DataFrame method) hex() (in module datafusion.functions.spark) HigherOrderFunction (in module datafusion.expr) hour() (in module datafusion.functions.spark) Http (in module datafusion.object_store) hypot() (in module datafusion.functions.spark) I if_() (in module datafusion.functions.spark) ifnull() (in module datafusion.functions) ILike (in module datafusion.expr) ilike() (in module datafusion.functions.spark) Immutable (datafusion.user_defined.Volatility attribute) in_list() (in module datafusion.functions) include_rank() (datafusion.user_defined.WindowEvaluator method) INDENT (datafusion.dataframe.ExplainFormat attribute) (datafusion.ExplainFormat attribute) initcap() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) InList (in module datafusion.expr) inner_product() (in module datafusion.functions) input_file_name() (in module datafusion.functions) inputs() (datafusion.LogicalPlan method) (datafusion.plan.LogicalPlan method) InsertOp (class in datafusion) (class in datafusion.dataframe) instr() (in module datafusion.functions) InSubquery (in module datafusion.expr) intersect() (datafusion.dataframe.DataFrame method) into_view() (datafusion.dataframe.DataFrame method) is_causal() (datafusion.user_defined.WindowEvaluator method) is_correct_input() (datafusion.input.base.BaseInputSource method) (datafusion.input.location.LocationInputPlugin method) (datafusion.input.LocationInputPlugin method) is_current_row() (datafusion.expr.WindowFrameBound method) is_following() (datafusion.expr.WindowFrameBound method) is_nan() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) 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) is_valid_utf8() (in module datafusion.functions.spark) IsFalse (in module datafusion.expr) isnan() (datafusion.Expr method) (datafusion.expr.Expr method) (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() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) J Join (in module datafusion.expr) join() (datafusion.dataframe.DataFrame method) join_on() (datafusion.dataframe.DataFrame method) JoinConstraint (in module datafusion.expr) JoinType (in module datafusion.expr) json_tuple() (in module datafusion.functions.spark) K kind (datafusion.catalog.Table property) (datafusion.Table property) L labels() (datafusion.Metric method) (datafusion.plan.Metric method) lag() (in module datafusion.functions) Lambda (in module datafusion.expr) lambda_() (in module datafusion.functions) lambda_var() (in module datafusion.functions) LambdaVariable (in module datafusion.expr) last_day() (in module datafusion.functions.spark) last_value() (in module datafusion.functions) lcm() (in module datafusion.functions) lead() (in module datafusion.functions) least() (in module datafusion.functions) left() (in module datafusion.functions) length() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) (in module datafusion.functions.spark) levenshtein() (in module datafusion.functions) Like (in module datafusion.expr) like() (in module datafusion.functions.spark) Limit (in module datafusion.expr) limit() (datafusion.dataframe.DataFrame method) list_add() (in module datafusion.functions) list_any_match() (in module datafusion.functions) list_any_value() (in module datafusion.functions) list_append() (in module datafusion.functions) list_avg() (in module datafusion.functions) list_cat() (in module datafusion.functions) list_compact() (in module datafusion.functions) list_concat() (in module datafusion.functions) list_contains() (in module datafusion.functions) list_dims() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) list_distance() (in module datafusion.functions) list_distinct() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) list_element() (in module datafusion.functions) list_empty() (in module datafusion.functions) list_except() (in module datafusion.functions) list_extract() (in module datafusion.functions) list_filter() (in module datafusion.functions) list_first() (in module datafusion.functions) list_has() (in module datafusion.functions) list_has_all() (in module datafusion.functions) list_has_any() (in module datafusion.functions) list_indexof() (in module datafusion.functions) list_intersect() (in module datafusion.functions) list_join() (in module datafusion.functions) list_length() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) list_max() (in module datafusion.functions) list_min() (in module datafusion.functions) list_ndims() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) list_normalize() (in module datafusion.functions) list_overlap() (in module datafusion.functions) list_pop_back() (in module datafusion.functions) list_pop_front() (in module datafusion.functions) list_position() (in module datafusion.functions) list_positions() (in module datafusion.functions) list_prepend() (in module datafusion.functions) list_product() (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_repeat() (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_reverse() (in module datafusion.functions) list_scale() (in module datafusion.functions) list_slice() (in module datafusion.functions) list_sort() (in module datafusion.functions) list_subtract() (in module datafusion.functions) list_sum() (in module datafusion.functions) list_to_string() (in module datafusion.functions) list_transform() (in module datafusion.functions) list_union() (in module datafusion.functions) list_zip() (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) literal_with_metadata() (datafusion.Expr static method) (datafusion.expr.Expr static method) ln() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) LocalFileSystem (in module datafusion.object_store) LocationInputPlugin (class in datafusion.input) (class in datafusion.input.location) log() (in module datafusion.functions) log10() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) log2() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) logical_extension_codec_ids() (datafusion.context.SessionContext method) logical_extension_codecs (datafusion.extensions.SessionExtensionComponents attribute) logical_plan() (datafusion.dataframe.DataFrame method) LogicalExtensionCodecExportable (class in datafusion.user_defined) LogicalPlan (class in datafusion) (class in datafusion.plan) lower() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) lpad() (in module datafusion.functions) ltrim() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) luhn_check() (in module datafusion.functions.spark) LZ4 (datafusion.dataframe.Compression attribute) LZ4_RAW (datafusion.dataframe.Compression attribute) M make_array() (in module datafusion.functions) make_date() (in module datafusion.functions) make_dt_interval() (in module datafusion.functions.spark) make_interval() (in module datafusion.functions.spark) make_list() (in module datafusion.functions) make_map() (in module datafusion.functions) make_time() (in module datafusion.functions) make_valid_utf8() (in module datafusion.functions.spark) map_entries() (in module datafusion.functions) map_extract() (in module datafusion.functions) map_from_arrays() (in module datafusion.functions.spark) map_from_entries() (in module datafusion.functions.spark) map_keys() (in module datafusion.functions) map_values() (in module datafusion.functions) max() (in module datafusion.functions) max_cell_length (datafusion.dataframe_formatter.DataFrameHtmlFormatter attribute) max_height (datafusion.dataframe_formatter.DataFrameHtmlFormatter attribute) max_memory_bytes (datafusion.dataframe_formatter.DataFrameHtmlFormatter attribute) max_row_group_size (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) max_rows (datafusion.dataframe_formatter.DataFrameHtmlFormatter property) max_width (datafusion.dataframe_formatter.DataFrameHtmlFormatter attribute) maximum_buffered_record_batches_per_stream (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) maximum_parallel_row_group_writers (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) md5() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) mean() (in module datafusion.functions) median() (in module datafusion.functions) memoize() (datafusion.user_defined.WindowEvaluator method) memory_catalog() (datafusion.Catalog static method) (datafusion.catalog.Catalog static method) (datafusion.catalog.CatalogList static method) memory_schema() (datafusion.catalog.Schema static method) merge() (datafusion.user_defined.Accumulator method) Metric (class in datafusion) (class in datafusion.plan) metrics() (datafusion.ExecutionPlan method) (datafusion.MetricsSet method) (datafusion.plan.ExecutionPlan method) (datafusion.plan.MetricsSet method) MetricsSet (class in datafusion) (class in datafusion.plan) MicrosoftAzure (in module datafusion.object_store) min() (in module datafusion.functions) min_rows (datafusion.dataframe_formatter.DataFrameHtmlFormatter attribute) minute() (in module datafusion.functions.spark) module datafusion datafusion.catalog datafusion.context datafusion.dataframe datafusion.dataframe_formatter datafusion.expr datafusion.extensions datafusion.functions datafusion.functions.spark datafusion.input datafusion.input.base datafusion.input.location datafusion.io datafusion.ipc datafusion.object_store datafusion.options datafusion.plan datafusion.record_batch datafusion.substrait datafusion.unparser datafusion.user_defined modulus() (in module datafusion.functions.spark) monthname() (in module datafusion.functions.spark) mysql() (datafusion.unparser.Dialect static method) N name (datafusion.Metric property) (datafusion.plan.Metric property) (datafusion.user_defined.AggregateUDF property) (datafusion.user_defined.ScalarUDF property) (datafusion.user_defined.WindowUDF property) named_struct() (in module datafusion.functions) names() (datafusion.Catalog method) (datafusion.catalog.Catalog method) (datafusion.catalog.CatalogList method) (datafusion.catalog.Schema method) nanvl() (in module datafusion.functions) Negative (in module datafusion.expr) negative() (in module datafusion.functions.spark) newlines_in_values (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) next() (datafusion.record_batch.RecordBatchStream method) (datafusion.RecordBatchStream method) next_day() (in module datafusion.functions.spark) Not (in module datafusion.expr) now() (in module datafusion.functions) nth_value() (in module datafusion.functions) ntile() (in module datafusion.functions) null_regex (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) null_treatment() (datafusion.Expr method) (datafusion.expr.Expr method) nullif() (in module datafusion.functions) nulls_first() (datafusion.expr.SortExpr method) nvl() (in module datafusion.functions) nvl2() (in module datafusion.functions) O octet_length() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) OperateFunctionArg (in module datafusion.expr) 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) output_partitioning (datafusion.ExecutionPlan property) (datafusion.plan.ExecutionPlan property) output_rows (datafusion.MetricsSet property) (datafusion.plan.MetricsSet property) over() (datafusion.Expr method) (datafusion.expr.Expr method) overlay() (in module datafusion.functions) OVERWRITE (datafusion.dataframe.InsertOp attribute) (datafusion.InsertOp attribute) owner_name() (datafusion.catalog.SchemaProvider method) P ParquetColumnOptions (class in datafusion) (class in datafusion.dataframe) ParquetWriterOptions (class in datafusion) (class in datafusion.dataframe) parse_capacity_limit() (datafusion.context.SessionContext static method) parse_sql_expr() (datafusion.context.SessionContext method) (datafusion.dataframe.DataFrame method) parse_url() (in module datafusion.functions.spark) partition (datafusion.Metric property) (datafusion.plan.Metric property) partition_by() (datafusion.Expr method) (datafusion.expr.Expr method) partition_count (datafusion.ExecutionPlan property) (datafusion.PhysicalPartitioning property) (datafusion.plan.ExecutionPlan property) (datafusion.plan.PhysicalPartitioning property) Partitioning (in module datafusion.expr) percent_rank() (in module datafusion.functions) percentile_cont() (in module datafusion.functions) PGJSON (datafusion.dataframe.ExplainFormat attribute) (datafusion.ExplainFormat attribute) physical_extension_codec_ids() (datafusion.context.SessionContext method) physical_extension_codecs (datafusion.extensions.SessionExtensionComponents attribute) PhysicalExtensionCodecExportable (class in datafusion.user_defined) PhysicalOptimizerRuleExportable (class in datafusion.extensions) PhysicalPartitioning (class in datafusion) (class in datafusion.plan) pi() (in module datafusion.functions) Placeholder (in module datafusion.expr) Plan (class in datafusion.substrait) plan_internal (datafusion.substrait.Plan attribute) plan_to_sql() (datafusion.unparser.Unparser method) pmod() (in module datafusion.functions.spark) position() (in module datafusion.functions) postgres() (datafusion.unparser.Dialect static method) pow() (in module datafusion.functions) (in module datafusion.functions.spark) power() (in module datafusion.functions) (in module datafusion.functions.spark) Prepare (in module datafusion.expr) printf() (in module datafusion.functions.spark) Producer (class in datafusion.substrait) Projection (in module datafusion.expr) python_value() (datafusion.Expr method) (datafusion.expr.Expr method) Q quantile_cont() (in module datafusion.functions) QueryPlannerExportable (class in datafusion.extensions) quote (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) quote() (in module datafusion.functions.spark) R radians() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) rand() (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_arrow() (datafusion.context.SessionContext method) read_avro() (datafusion.context.SessionContext method) (in module datafusion) (in module datafusion.io) read_batch() (datafusion.context.SessionContext method) read_batches() (datafusion.context.SessionContext method) read_csv() (datafusion.context.SessionContext method) (in module datafusion) (in module datafusion.io) read_empty() (datafusion.context.SessionContext method) read_json() (datafusion.context.SessionContext method) (in module datafusion) (in module datafusion.io) read_parquet() (datafusion.context.SessionContext method) (in module datafusion) (in module datafusion.io) 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) RecursiveQuery (in module datafusion.expr) refresh_catalogs() (datafusion.context.SessionContext method) regexp_count() (in module datafusion.functions) regexp_instr() (in module datafusion.functions) regexp_like() (in module datafusion.functions) regexp_match() (in module datafusion.functions) regexp_replace() (in module datafusion.functions) register_arrow() (datafusion.context.SessionContext method) register_avro() (datafusion.context.SessionContext method) register_batch() (datafusion.context.SessionContext method) register_catalog() (datafusion.catalog.CatalogList method) (datafusion.catalog.CatalogProviderList method) register_catalog_provider() (datafusion.context.SessionContext method) register_catalog_provider_list() (datafusion.context.SessionContext method) register_csv() (datafusion.context.SessionContext method) register_dataset() (datafusion.context.SessionContext method) register_formatter() (datafusion.dataframe_formatter.DataFrameHtmlFormatter 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_schema() (datafusion.Catalog method) (datafusion.catalog.Catalog method) (datafusion.catalog.CatalogProvider method) register_table() (datafusion.catalog.Schema method) (datafusion.catalog.SchemaProvider method) (datafusion.context.SessionContext method) register_table_factory() (datafusion.context.SessionContext method) register_table_provider() (datafusion.context.SessionContext method) register_udaf() (datafusion.context.SessionContext method) register_udf() (datafusion.context.SessionContext method) register_udtf() (datafusion.context.SessionContext method) register_udwf() (datafusion.context.SessionContext method) register_view() (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) remove_optimizer_rule() (datafusion.context.SessionContext method) Repartition (in module datafusion.expr) repartition() (datafusion.dataframe.DataFrame method) repartition_by_hash() (datafusion.dataframe.DataFrame method) repeat() (in module datafusion.functions) REPLACE (datafusion.dataframe.InsertOp attribute) (datafusion.InsertOp attribute) replace() (in module datafusion.functions) repr_rows (datafusion.dataframe_formatter.DataFrameHtmlFormatter property) reset_formatter() (in module datafusion.dataframe_formatter) reverse() (datafusion.Expr method) (datafusion.expr.Expr method) (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) rint() (in module datafusion.functions.spark) rollup() (datafusion.expr.GroupingSet static method) round() (in module datafusion.functions) (in module datafusion.functions.spark) row() (in module datafusion.functions) row_number() (in module datafusion.functions) ROWS (datafusion.dataframe.ExplainMetricCategory attribute) rpad() (in module datafusion.functions) rtrim() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) RuntimeEnvBuilder (class in datafusion) (class in datafusion.context) S ScalarSubquery (in module datafusion.expr) ScalarUDF (class in datafusion.user_defined) ScalarUDFExportable (class in datafusion.user_defined) ScalarVariable (in module datafusion.expr) Schema (class in datafusion.catalog) schema (datafusion.catalog.Table property) (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) (datafusion.Table property) schema() (datafusion.Catalog method) (datafusion.catalog.Catalog method) (datafusion.catalog.CatalogProvider method) (datafusion.dataframe.DataFrame method) schema_infer_max_records (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) schema_name() (datafusion.Expr method) (datafusion.expr.Expr method) schema_names() (datafusion.Catalog method) (datafusion.catalog.Catalog method) (datafusion.catalog.CatalogProvider method) SchemaProvider (class in datafusion.catalog) scheme (datafusion.PhysicalPartitioning property) (datafusion.plan.PhysicalPartitioning property) sec() (in module datafusion.functions.spark) second() (in module datafusion.functions.spark) select() (datafusion.dataframe.DataFrame method) select_exprs() (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) session_start_time() (datafusion.context.SessionContext method) SessionComponentsExportable (class in datafusion.extensions) SessionConfig (class in datafusion) (class in datafusion.context) SessionContext (class in datafusion.context) SessionExtensionComponents (class in datafusion.extensions) SessionPlannerExportable (class in datafusion.extensions) set() (datafusion.context.SessionConfig method) (datafusion.SessionConfig method) set_custom_cell_builder() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) set_custom_header_builder() (datafusion.dataframe_formatter.DataFrameHtmlFormatter method) set_formatter() (datafusion.dataframe_formatter.FormatterManager class method) (in module datafusion.dataframe_formatter) set_query_planner() (datafusion.context.SessionContext method) set_sender_ctx() (in module datafusion.ipc) set_worker_ctx() (in module datafusion.ipc) SetVariable (in module datafusion.expr) sha() (in module datafusion.functions.spark) sha1() (in module datafusion.functions.spark) sha2() (in module datafusion.functions.spark) sha224() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) sha256() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) sha384() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) sha512() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) shiftleft() (in module datafusion.functions.spark) shiftright() (in module datafusion.functions.spark) shiftrightunsigned() (in module datafusion.functions.spark) show() (datafusion.dataframe.DataFrame method) show_truncation_message (datafusion.dataframe_formatter.DataFrameHtmlFormatter attribute) shuffle() (in module datafusion.functions.spark) signum() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) SimilarTo (in module datafusion.expr) sin() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) sinh() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) size() (in module datafusion.functions.spark) skip_arrow_metadata (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) slice() (in module datafusion.functions.spark) SNAPPY (datafusion.dataframe.Compression attribute) Sort (in module datafusion.expr) sort() (datafusion.dataframe.DataFrame method) (datafusion.Expr method) (datafusion.expr.Expr method) sort_by() (datafusion.dataframe.DataFrame method) SortExpr (class in datafusion.expr) SortKey (in module datafusion.expr) soundex() (in module datafusion.functions.spark) space() (in module datafusion.functions.spark) spark_cast() (in module datafusion.functions.spark) spill_count (datafusion.MetricsSet property) (datafusion.plan.MetricsSet property) spilled_bytes (datafusion.MetricsSet property) (datafusion.plan.MetricsSet property) spilled_rows (datafusion.MetricsSet property) (datafusion.plan.MetricsSet property) split_part() (in module datafusion.functions) sql() (datafusion.context.SessionContext method) sql_with_options() (datafusion.context.SessionContext method) sqlite() (datafusion.unparser.Dialect static method) SQLOptions (class in datafusion) (class in datafusion.context) sqrt() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) Stable (datafusion.user_defined.Volatility attribute) starts_with() (in module datafusion.functions) state() (datafusion.user_defined.Accumulator method) statistics_enabled (datafusion.dataframe.ParquetColumnOptions attribute) (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetColumnOptions attribute) (datafusion.ParquetWriterOptions attribute) statistics_truncate_length (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) stddev() (in module datafusion.functions) stddev_pop() (in module datafusion.functions) stddev_samp() (in module datafusion.functions) str_to_map() (in module datafusion.functions.spark) string_agg() (in module datafusion.functions) string_literal() (datafusion.Expr static method) (datafusion.expr.Expr static method) string_to_array() (in module datafusion.functions) string_to_list() (in module datafusion.functions) strpos() (in module datafusion.functions) struct() (in module datafusion.functions) style_provider (datafusion.dataframe_formatter.DataFrameHtmlFormatter attribute) StyleProvider (class in datafusion.dataframe_formatter) Subquery (in module datafusion.expr) SubqueryAlias (in module datafusion.expr) substr() (in module datafusion.functions) (in module datafusion.functions.spark) substr_index() (in module datafusion.functions) substring() (in module datafusion.functions) (in module datafusion.functions.spark) substring_index() (in module datafusion.functions) sum() (in module datafusion.functions) sum_by_name() (datafusion.MetricsSet method) (datafusion.plan.MetricsSet method) SUMMARY (datafusion.dataframe.ExplainAnalyzeLevel attribute) supports_bounded_execution() (datafusion.user_defined.WindowEvaluator method) T Table (class in datafusion) (class in datafusion.catalog) table() (datafusion.catalog.Schema method) (datafusion.catalog.SchemaProvider method) (datafusion.context.SessionContext method) table_exist() (datafusion.catalog.Schema method) (datafusion.catalog.SchemaProvider method) (datafusion.context.SessionContext method) table_names() (datafusion.catalog.Schema method) (datafusion.catalog.SchemaProvider method) table_partition_cols (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) table_provider() (datafusion.context.SessionContext method) TableFunction (class in datafusion.user_defined) TableProviderExportable (class in datafusion.context) TableProviderFactory (class in datafusion) (class in datafusion.catalog) TableProviderFactoryExportable (class in datafusion) TableScan (in module datafusion.expr) tail() (datafusion.dataframe.DataFrame method) tan() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) tanh() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) terminator (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) time_trunc() (in module datafusion.functions.spark) TIMING (datafusion.dataframe.ExplainMetricCategory attribute) to_arrow_table() (datafusion.dataframe.DataFrame method) to_bytes() (datafusion.ExecutionPlan method) (datafusion.Expr method) (datafusion.expr.Expr method) (datafusion.LogicalPlan method) (datafusion.plan.ExecutionPlan method) (datafusion.plan.LogicalPlan method) to_char() (in module datafusion.functions) to_date() (in module datafusion.functions) to_hex() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) to_inner() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions method) to_json() (datafusion.substrait.Plan method) to_local_time() (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_time() (in module datafusion.functions) to_timestamp() (in module datafusion.functions) to_timestamp_micros() (in module datafusion.functions) to_timestamp_millis() (in module datafusion.functions) to_timestamp_nanos() (in module datafusion.functions) to_timestamp_seconds() (in module datafusion.functions) to_unixtime() (in module datafusion.functions) to_utc_timestamp() (in module datafusion.functions.spark) to_variant() (datafusion.Expr method) (datafusion.expr.Expr method) (datafusion.LogicalPlan method) (datafusion.plan.LogicalPlan method) today (in module datafusion.functions) TransactionAccessMode (in module datafusion.expr) TransactionConclusion (in module datafusion.expr) TransactionEnd (in module datafusion.expr) TransactionIsolationLevel (in module datafusion.expr) TransactionStart (in module datafusion.expr) transform() (datafusion.dataframe.DataFrame method) translate() (in module datafusion.functions) TREE (datafusion.dataframe.ExplainFormat attribute) (datafusion.ExplainFormat attribute) trim() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) trunc() (in module datafusion.functions) (in module datafusion.functions.spark) truncated_rows (datafusion.CsvReadOptions attribute) (datafusion.options.CsvReadOptions attribute) try_cast() (datafusion.Expr method) (datafusion.expr.Expr method) try_cast_to_type() (in module datafusion.functions) try_parse_url() (in module datafusion.functions.spark) try_sum() (in module datafusion.functions.spark) try_url_decode() (in module datafusion.functions.spark) TryCast (in module datafusion.expr) types() (datafusion.Expr method) (datafusion.expr.Expr method) U udaf (in module datafusion.user_defined) udaf() (datafusion.context.SessionContext method) (datafusion.user_defined.AggregateUDF static method) udafs() (datafusion.context.SessionContext method) udf (in module datafusion.user_defined) udf() (datafusion.context.SessionContext method) (datafusion.user_defined.ScalarUDF static method) udfs() (datafusion.context.SessionContext method) udtf (in module datafusion.user_defined) udtf() (datafusion.user_defined.TableFunction static method) udwf (in module datafusion.user_defined) udwf() (datafusion.context.SessionContext method) (datafusion.user_defined.WindowUDF static method) udwfs() (datafusion.context.SessionContext method) unbase64() (in module datafusion.functions.spark) UNCATEGORIZED (datafusion.dataframe.ExplainMetricCategory attribute) UNCOMPRESSED (datafusion.dataframe.Compression attribute) unhex() (in module datafusion.functions.spark) Union (in module datafusion.expr) union() (datafusion.dataframe.DataFrame method) union_by_name() (datafusion.dataframe.DataFrame method) union_distinct() (datafusion.dataframe.DataFrame method) union_extract() (in module datafusion.functions) union_tag() (in module datafusion.functions) unix_date() (in module datafusion.functions.spark) unix_micros() (in module datafusion.functions.spark) unix_millis() (in module datafusion.functions.spark) unix_seconds() (in module datafusion.functions.spark) Unnest (in module datafusion.expr) unnest_columns() (datafusion.dataframe.DataFrame method) UnnestExpr (in module datafusion.expr) Unparser (class in datafusion.unparser) unparser (datafusion.unparser.Unparser attribute) update() (datafusion.user_defined.Accumulator method) upper() (datafusion.Expr method) (datafusion.expr.Expr method) (in module datafusion.functions) url_decode() (in module datafusion.functions.spark) url_encode() (in module datafusion.functions.spark) use_shared_styles (datafusion.dataframe_formatter.DataFrameHtmlFormatter attribute) uses_window_frame() (datafusion.user_defined.WindowEvaluator method) uuid() (in module datafusion.functions) V value (datafusion.Metric property) (datafusion.plan.Metric property) value_as_datetime (datafusion.Metric property) (datafusion.plan.Metric property) Values (in module datafusion.expr) var() (in module datafusion.functions) var_pop() (in module datafusion.functions) var_population() (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) version() (in module datafusion.functions) Volatile (datafusion.user_defined.Volatility attribute) Volatility (class in datafusion.user_defined) W weekday() (in module datafusion.functions.spark) when() (datafusion.expr.CaseBuilder method) (in module datafusion.functions) width_bucket() (in module datafusion.functions.spark) Window (class in datafusion.expr) window() (datafusion.dataframe.DataFrame method) window_frame (datafusion.expr.WindowFrame attribute) (datafusion.WindowFrame attribute) window_frame() (datafusion.Expr method) (datafusion.expr.Expr method) WindowEvaluator (class in datafusion.user_defined) WindowExpr (in module datafusion.expr) WindowFrame (class in datafusion) (class in datafusion.expr) WindowFrameBound (class in datafusion.expr) WindowUDF (class in datafusion.user_defined) WindowUDFExportable (class in datafusion.user_defined) 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_columns() (datafusion.dataframe.DataFrame method) with_comment() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions 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_delimiter() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions method) with_disk_manager_disabled() (datafusion.context.RuntimeEnvBuilder method) (datafusion.RuntimeEnvBuilder method) with_disk_manager_os() (datafusion.context.RuntimeEnvBuilder method) (datafusion.RuntimeEnvBuilder method) with_disk_manager_specified() (datafusion.context.RuntimeEnvBuilder method) (datafusion.RuntimeEnvBuilder method) with_escape() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions method) with_extension() (datafusion.context.SessionConfig method) (datafusion.SessionConfig method) with_extensions() (datafusion.context.SessionContext method) with_fair_spill_pool() (datafusion.context.RuntimeEnvBuilder method) (datafusion.RuntimeEnvBuilder method) with_file_compression_type() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions method) with_file_extension() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions method) with_file_sort_order() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions method) with_greedy_memory_pool() (datafusion.context.RuntimeEnvBuilder method) (datafusion.RuntimeEnvBuilder method) with_has_header() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions method) with_information_schema() (datafusion.context.SessionConfig method) (datafusion.SessionConfig method) with_logical_extension_codec() (datafusion.context.SessionContext method) with_metadata() (in module datafusion.functions) with_newlines_in_values() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions method) with_null_regex() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions method) with_parquet_pruning() (datafusion.context.SessionConfig method) (datafusion.SessionConfig method) with_physical_extension_codec() (datafusion.context.SessionContext method) with_pretty() (datafusion.unparser.Unparser method) with_python_udf_inlining() (datafusion.context.SessionContext method) with_quote() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions 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_schema() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions method) with_schema_infer_max_records() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions method) with_table_partition_cols() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions method) with_target_partitions() (datafusion.context.SessionConfig method) (datafusion.SessionConfig method) with_temp_file_path() (datafusion.context.RuntimeEnvBuilder method) (datafusion.RuntimeEnvBuilder method) with_terminator() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions method) with_truncated_rows() (datafusion.CsvReadOptions method) (datafusion.options.CsvReadOptions method) with_unbounded_memory_pool() (datafusion.context.RuntimeEnvBuilder method) (datafusion.RuntimeEnvBuilder method) write_batch_size (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) write_csv() (datafusion.dataframe.DataFrame method) write_json() (datafusion.dataframe.DataFrame method) write_parquet() (datafusion.dataframe.DataFrame method) write_parquet_with_options() (datafusion.dataframe.DataFrame method) write_table() (datafusion.dataframe.DataFrame method) writer_version (datafusion.dataframe.ParquetWriterOptions attribute) (datafusion.ParquetWriterOptions attribute) X xxhash64() (in module datafusion.functions.spark) Z ZSTD (datafusion.dataframe.Compression attribute)
