Index A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | Q | R | S | T | U | V | W | Y | Z A add() (fugue.workflow.workflow.FugueWorkflow method) add_func_handler() (fugue.column.sql.SQLExpressionGenerator method) agg_funcs (fugue.column.sql.SelectColumns property) aggregate() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) (in module fugue.execution.api) algo (fugue.collections.partition.PartitionSpec property) alias (fugue_duckdb.dataframe.DuckDataFrame property) (fugue_spark.dataframe.SparkDataFrame property) alias() (fugue.column.expressions.ColumnExpr method) all_cols (fugue.column.sql.SelectColumns property) all_cols() (in module fugue.column.expressions) alter_columns() (fugue.dataframe.array_dataframe.ArrayDataFrame method) (fugue.dataframe.arrow_dataframe.ArrowDataFrame method) (fugue.dataframe.dataframe.DataFrame method) (fugue.dataframe.dataframe_iterable_dataframe.LocalDataFrameIterableDataFrame method) (fugue.dataframe.iterable_dataframe.IterableDataFrame method) (fugue.dataframe.pandas_dataframe.PandasDataFrame method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.dataframe.DaskDataFrame method) (fugue_duckdb.dataframe.DuckDataFrame method) (fugue_ibis.dataframe.IbisDataFrame method) (fugue_ray.dataframe.RayDataFrame method) (fugue_spark.dataframe.SparkDataFrame method) (in module fugue.api) anti_join() (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) (in module fugue.execution.api) ArrayBag (class in fugue.bag.array_bag) ArrayDataFrame (class in fugue.dataframe.array_dataframe) ArrowDataFrame (class in fugue.dataframe.arrow_dataframe) as_array() (fugue.bag.array_bag.ArrayBag method) (fugue.bag.bag.Bag method) (fugue.dataframe.array_dataframe.ArrayDataFrame method) (fugue.dataframe.arrow_dataframe.ArrowDataFrame method) (fugue.dataframe.dataframe.DataFrame method) (fugue.dataframe.dataframe_iterable_dataframe.LocalDataFrameIterableDataFrame method) (fugue.dataframe.iterable_dataframe.IterableDataFrame method) (fugue.dataframe.pandas_dataframe.PandasDataFrame method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.dataframe.DaskDataFrame method) (fugue_duckdb.dataframe.DuckDataFrame method) (fugue_ibis.dataframe.IbisDataFrame method) (fugue_ray.dataframe.RayDataFrame method) (fugue_spark.dataframe.SparkDataFrame method) (in module fugue.api) as_array_iterable() (fugue.dataframe.array_dataframe.ArrayDataFrame method) (fugue.dataframe.arrow_dataframe.ArrowDataFrame method) (fugue.dataframe.dataframe.DataFrame method) (fugue.dataframe.dataframe_iterable_dataframe.LocalDataFrameIterableDataFrame method) (fugue.dataframe.iterable_dataframe.IterableDataFrame method) (fugue.dataframe.pandas_dataframe.PandasDataFrame method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.dataframe.DaskDataFrame method) (fugue_duckdb.dataframe.DuckDataFrame method) (fugue_ibis.dataframe.IbisDataFrame method) (fugue_ray.dataframe.RayDataFrame method) (fugue_spark.dataframe.SparkDataFrame method) (in module fugue.api) as_arrow() (fugue.dataframe.arrow_dataframe.ArrowDataFrame method) (fugue.dataframe.dataframe.DataFrame method) (fugue.dataframe.dataframe_iterable_dataframe.LocalDataFrameIterableDataFrame method) (fugue_duckdb.dataframe.DuckDataFrame method) (fugue_ibis.dataframe.IbisDataFrame method) (fugue_ray.dataframe.RayDataFrame method) (in module fugue.api) as_context() (fugue.execution.execution_engine.ExecutionEngine method) as_dict_iterable() (fugue.dataframe.dataframe.DataFrame method) (in module fugue.api) as_fugue() (in module fugue_ibis.extensions) as_fugue_dataset() (in module fugue.api) as_fugue_df() (in module fugue.api) (in module fugue.dataframe.dataframe) as_fugue_engine_df() (in module fugue.api) as_ibis() (in module fugue_ibis.extensions) as_local() (fugue.bag.bag.Bag method) (fugue.dataframe.dataframe.DataFrame method) (fugue.dataframe.dataframe.LocalUnboundedDataFrame method) (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) as_local_bounded() (fugue.bag.bag.Bag method) (fugue.bag.bag.LocalBoundedBag method) (fugue.dataframe.dataframe.DataFrame method) (fugue.dataframe.dataframe.LocalBoundedDataFrame method) (fugue.dataframe.dataframe_iterable_dataframe.IterablePandasDataFrame method) (fugue.dataframe.dataframe_iterable_dataframe.LocalDataFrameIterableDataFrame method) (fugue.dataframe.iterable_dataframe.IterableDataFrame method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.dataframe.DaskDataFrame method) (fugue_duckdb.dataframe.DuckDataFrame method) (fugue_ibis.dataframe.IbisDataFrame method) (fugue_ray.dataframe.RayDataFrame method) (fugue_spark.dataframe.SparkDataFrame method) (in module fugue.api) as_name (fugue.column.expressions.ColumnExpr property) as_pandas() (fugue.dataframe.arrow_dataframe.ArrowDataFrame method) (fugue.dataframe.dataframe.DataFrame method) (fugue.dataframe.dataframe_iterable_dataframe.LocalDataFrameIterableDataFrame method) (fugue.dataframe.pandas_dataframe.PandasDataFrame method) (fugue_dask.dataframe.DaskDataFrame method) (fugue_duckdb.dataframe.DuckDataFrame method) (fugue_ibis.dataframe.IbisDataFrame method) (fugue_ray.dataframe.RayDataFrame method) (fugue_spark.dataframe.SparkDataFrame method) (in module fugue.api) as_type (fugue.column.expressions.ColumnExpr property) assert_all_with_names() (fugue.column.sql.SelectColumns method) assert_eq() (fugue.workflow.workflow.FugueWorkflow method) (fugue.workflow.workflow.WorkflowDataFrame method) assert_no_agg() (fugue.column.sql.SelectColumns method) assert_no_wildcard() (fugue.column.sql.SelectColumns method) assert_not_empty() (fugue.dataset.dataset.Dataset method) assert_not_eq() (fugue.workflow.workflow.FugueWorkflow method) (fugue.workflow.workflow.WorkflowDataFrame method) assign() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) (in module fugue.execution.api) avg() (in module fugue.column.functions) B backend (fugue_ibis.execution_engine.IbisSQLEngine property) Bag (class in fugue.bag.bag) BagDisplay (class in fugue.bag.bag) BagPartitionCursor (class in fugue.collections.partition) bg (fugue.bag.bag.BagDisplay property) body_str (fugue.column.expressions.ColumnExpr property) broadcast() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.dask.DuckDaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ray.execution_engine.RayExecutionEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) (in module fugue.api) (in module fugue.execution.api) C callback (fugue.extensions.context.ExtensionContext property) cast() (fugue.column.expressions.ColumnExpr method) checkpoint() (fugue.workflow.workflow.WorkflowDataFrame method) clear_global_engine() (in module fugue.api) (in module fugue.execution.api) coalesce() (in module fugue.column.functions) col() (in module fugue.column.expressions) ColumnExpr (class in fugue.column.expressions) columns (fugue.dataframe.dataframe.DataFrame property) (fugue_ibis.dataframe.IbisDataFrame property) comap() (fugue.execution.execution_engine.ExecutionEngine method) compute() (fugue.workflow.workflow.WorkflowDataFrame method) conf (fugue.execution.execution_engine.EngineFacet property) (fugue.execution.execution_engine.ExecutionEngine property) (fugue.execution.execution_engine.FugueEngineBase property) (fugue.rpc.base.RPCServer property) (fugue.workflow.workflow.FugueWorkflow property) connection (fugue_duckdb.execution_engine.DuckExecutionEngine property) construct() (fugue.collections.sql.StructuredRawSQL method) convert() (fugue.dataframe.dataframes.DataFrames method) convert_yield_dataframe() (fugue.execution.execution_engine.ExecutionEngine method) (fugue_duckdb.dask.DuckDaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ray.execution_engine.RayExecutionEngine method) correct_select_schema() (fugue.column.sql.SQLExpressionGenerator method) CoTransformer (class in fugue.extensions.transformer.transformer) cotransformer() (in module fugue.extensions.transformer.convert) count() (fugue.bag.array_bag.ArrayBag method) (fugue.dataframe.array_dataframe.ArrayDataFrame method) (fugue.dataframe.arrow_dataframe.ArrowDataFrame method) (fugue.dataframe.dataframe.LocalUnboundedDataFrame method) (fugue.dataframe.function_wrapper.DataFrameParam method) (fugue.dataframe.function_wrapper.LocalDataFrameParam method) (fugue.dataframe.pandas_dataframe.PandasDataFrame method) (fugue.dataset.dataset.Dataset method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.dataframe.DaskDataFrame method) (fugue_duckdb.dataframe.DuckDataFrame method) (fugue_ibis.dataframe.IbisDataFrame method) (fugue_ray.dataframe.RayDataFrame method) (fugue_spark.dataframe.SparkDataFrame method) (in module fugue.api) (in module fugue.column.functions) count_distinct() (in module fugue.column.functions) create() (fugue.extensions.creator.creator.Creator method) (fugue.workflow.workflow.FugueWorkflow method) create_data() (fugue.workflow.workflow.FugueWorkflow method) create_default_map_engine() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.dask.DuckDaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ray.execution_engine.RayExecutionEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) create_default_sql_engine() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) create_non_ibis_execution_engine() (fugue_ibis.execution_engine.IbisExecutionEngine method) Creator (class in fugue.extensions.creator.creator) creator() (in module fugue.extensions.creator.convert) cross_join() (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) (in module fugue.execution.api) cursor (fugue.extensions.context.ExtensionContext property) D dask_client (fugue_dask.execution_engine.DaskExecutionEngine property) (fugue_duckdb.dask.DuckDaskExecutionEngine property) DaskDataFrame (class in fugue_dask.dataframe) DaskExecutionEngine (class in fugue_dask.execution_engine) DaskIbisEngine (class in fugue_dask.ibis_engine) DaskMapEngine (class in fugue_dask.execution_engine) DataFrame (class in fugue.dataframe.dataframe) DataFrameDisplay (class in fugue.dataframe.dataframe) DataFrameFunctionWrapper (class in fugue.dataframe.function_wrapper) DataFrameParam (class in fugue.dataframe.function_wrapper) DataFrames (class in fugue.dataframe.dataframes) Dataset (class in fugue.dataset.dataset) DatasetDisplay (class in fugue.dataset.dataset) DatasetPartitionCursor (class in fugue.collections.partition) deserialize_df() (in module fugue.dataframe.utils) deterministic_checkpoint() (fugue.workflow.workflow.WorkflowDataFrame method) df (fugue.dataframe.dataframe.DataFrameDisplay property) df() (fugue.workflow.workflow.FugueWorkflow method) dialect (fugue.collections.sql.StructuredRawSQL property) (fugue.execution.execution_engine.SQLEngine property) (fugue.execution.native_execution_engine.QPDPandasEngine property) (fugue_dask.execution_engine.QPDDaskEngine property) (fugue_duckdb.execution_engine.DuckDBEngine property) (fugue_spark.execution_engine.SparkSQLEngine property) distinct() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ibis.execution_engine.IbisSQLEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) (in module fugue.api) (in module fugue.execution.api) drop() (fugue.dataframe.dataframe.DataFrame method) (fugue.workflow.workflow.WorkflowDataFrame method) drop_columns() (in module fugue.api) dropna() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ibis.execution_engine.IbisSQLEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) (in module fugue.api) (in module fugue.execution.api) DuckDaskExecutionEngine (class in fugue_duckdb.dask) DuckDataFrame (class in fugue_duckdb.dataframe) DuckDBEngine (class in fugue_duckdb.execution_engine) DuckDBIbisEngine (class in fugue_duckdb.ibis_engine) DuckExecutionEngine (class in fugue_duckdb.execution_engine) E empty (fugue.bag.array_bag.ArrayBag property) (fugue.collections.partition.PartitionSpec property) (fugue.dataframe.array_dataframe.ArrayDataFrame property) (fugue.dataframe.arrow_dataframe.ArrowDataFrame property) (fugue.dataframe.dataframe_iterable_dataframe.LocalDataFrameIterableDataFrame property) (fugue.dataframe.iterable_dataframe.IterableDataFrame property) (fugue.dataframe.pandas_dataframe.PandasDataFrame property) (fugue.dataset.dataset.Dataset property) (fugue.workflow.workflow.WorkflowDataFrame property) (fugue_dask.dataframe.DaskDataFrame property) (fugue_duckdb.dataframe.DuckDataFrame property) (fugue_ibis.dataframe.IbisDataFrame property) (fugue_ray.dataframe.RayDataFrame property) (fugue_spark.dataframe.SparkDataFrame property) EmptyRPCHandler (class in fugue.rpc.base) encode() (fugue.execution.execution_engine.SQLEngine method) encode_column_name() (fugue_ibis.execution_engine.IbisSQLEngine method) encode_name() (fugue.execution.execution_engine.SQLEngine method) engine_context() (in module fugue.api) (in module fugue.execution.api) EngineFacet (class in fugue.execution.execution_engine) execution_engine (fugue.execution.execution_engine.EngineFacet property) (fugue.extensions.context.ExtensionContext property) execution_engine_constraint (fugue.execution.execution_engine.EngineFacet property) (fugue.execution.native_execution_engine.PandasMapEngine property) (fugue_dask.execution_engine.DaskMapEngine property) (fugue_ibis.execution_engine.IbisMapEngine property) (fugue_ray.execution_engine.RayMapEngine property) (fugue_spark.execution_engine.SparkSQLEngine property) ExecutionEngine (class in fugue.execution.execution_engine) ExecutionEngineParam (class in fugue.execution.execution_engine) ExtensionContext (class in fugue.extensions.context) F fillna() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ibis.execution_engine.IbisSQLEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) (in module fugue.api) (in module fugue.execution.api) filter() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) (in module fugue.execution.api) first() (in module fugue.column.functions) FlaskRPCClient (class in fugue.rpc.flask) FlaskRPCServer (class in fugue.rpc.flask) from_expr() (fugue.collections.sql.StructuredRawSQL static method) fs (fugue.execution.execution_engine.ExecutionEngine property) (fugue.execution.native_execution_engine.NativeExecutionEngine property) (fugue_dask.execution_engine.DaskExecutionEngine property) (fugue_duckdb.execution_engine.DuckExecutionEngine property) (fugue_ibis.execution_engine.IbisExecutionEngine property) (fugue_spark.execution_engine.SparkExecutionEngine property) fugue.api module fugue.bag.array_bag module fugue.bag.bag module fugue.collections.partition module fugue.collections.sql module fugue.collections.yielded module fugue.column.expressions module fugue.column.functions module fugue.column.sql module fugue.constants module fugue.dataframe.api module fugue.dataframe.array_dataframe module fugue.dataframe.arrow_dataframe module fugue.dataframe.dataframe module fugue.dataframe.dataframe_iterable_dataframe module fugue.dataframe.dataframes module fugue.dataframe.function_wrapper module fugue.dataframe.iterable_dataframe module fugue.dataframe.pandas_dataframe module fugue.dataframe.utils module fugue.dataset.api module fugue.dataset.dataset module fugue.dev module fugue.exceptions module fugue.execution.api module fugue.execution.execution_engine module fugue.execution.factory module fugue.execution.native_execution_engine module fugue.extensions.context module fugue.extensions.creator.convert module fugue.extensions.creator.creator module fugue.extensions.outputter.convert module fugue.extensions.outputter.outputter module fugue.extensions.processor.convert module fugue.extensions.processor.processor module fugue.extensions.transformer.constants module fugue.extensions.transformer.convert module fugue.extensions.transformer.transformer module fugue.plugins module fugue.registry module fugue.rpc.base module fugue.rpc.flask module fugue.sql.api module fugue.sql.workflow module fugue.workflow.api module fugue.workflow.input module fugue.workflow.module module fugue.workflow.workflow module fugue_dask.dataframe module fugue_dask.execution_engine module fugue_dask.ibis_engine module fugue_dask.registry module fugue_duckdb.dask module fugue_duckdb.dataframe module fugue_duckdb.execution_engine module fugue_duckdb.ibis_engine module fugue_duckdb.registry module fugue_ibis.dataframe module fugue_ibis.execution.ibis_engine module fugue_ibis.execution.pandas_backend module fugue_ibis.execution_engine module fugue_ibis.extensions module fugue_ray.dataframe module fugue_ray.execution_engine module fugue_ray.registry module fugue_spark.dataframe module fugue_spark.execution_engine module fugue_spark.ibis_engine module fugue_spark.registry module fugue_sql() (in module fugue.api) (in module fugue.sql.api) fugue_sql.exceptions module fugue_sql_flow() (in module fugue.api) (in module fugue.sql.api) FugueBug FugueDataFrameError FugueDataFrameInitError FugueDataFrameOperationError FugueDatasetEmptyError FugueEngineBase (class in fugue.execution.execution_engine) FugueError FugueInterfacelessError FugueInvalidOperation FuguePluginsRegistrationError FugueSQLError FugueSQLRuntimeError FugueSQLSyntaxError FugueSQLWorkflow (class in fugue.sql.workflow) FugueWorkflow (class in fugue.workflow.workflow) FugueWorkflowCompileError FugueWorkflowCompileValidationError FugueWorkflowError FugueWorkflowResult (class in fugue.workflow.workflow) FugueWorkflowRuntimeError FugueWorkflowRuntimeValidationError full_outer_join() (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) (in module fugue.execution.api) function() (in module fugue.column.expressions) G generate() (fugue.column.sql.SQLExpressionGenerator method) get_column_names() (in module fugue.api) get_context_engine() (in module fugue.api) (in module fugue.execution.api) get_current_conf() (in module fugue.execution.api) get_current_parallelism() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.dask.DuckDaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ray.execution_engine.RayExecutionEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) (in module fugue.execution.api) get_cursor() (fugue.collections.partition.PartitionSpec method) get_format_hint() (fugue.dataframe.function_wrapper.DataFrameFunctionWrapper method) (fugue.extensions.transformer.transformer.CoTransformer method) (fugue.extensions.transformer.transformer.Transformer method) get_info_str() (fugue.dataframe.dataframe.DataFrame method) get_join_schemas() (in module fugue.dataframe.utils) get_key_schema() (fugue.collections.partition.PartitionSpec method) get_native_as_df() (in module fugue.api) (in module fugue.dataframe.api) get_num_partitions() (fugue.collections.partition.PartitionSpec method) (in module fugue.api) get_output_schema() (fugue.extensions.transformer.transformer.CoTransformer method) (fugue.extensions.transformer.transformer.OutputCoTransformer method) (fugue.extensions.transformer.transformer.OutputTransformer method) (fugue.extensions.transformer.transformer.Transformer method) get_partitioner() (fugue.collections.partition.PartitionSpec method) get_result() (fugue.workflow.workflow.FugueWorkflow method) get_schema() (in module fugue.api) get_sorts() (fugue.collections.partition.PartitionSpec method) get_temp_table_name() (fugue_ibis.execution_engine.IbisSQLEngine method) group_keys (fugue.column.sql.SelectColumns property) H has_agg (fugue.column.sql.SelectColumns property) has_callback (fugue.extensions.context.ExtensionContext property) has_key (fugue.dataframe.dataframes.DataFrames property) has_literals (fugue.column.sql.SelectColumns property) has_metadata (fugue.dataset.dataset.Dataset property) head() (fugue.bag.array_bag.ArrayBag method) (fugue.bag.bag.Bag method) (fugue.dataframe.array_dataframe.ArrayDataFrame method) (fugue.dataframe.arrow_dataframe.ArrowDataFrame method) (fugue.dataframe.dataframe.DataFrame method) (fugue.dataframe.dataframe_iterable_dataframe.LocalDataFrameIterableDataFrame method) (fugue.dataframe.iterable_dataframe.IterableDataFrame method) (fugue.dataframe.pandas_dataframe.PandasDataFrame method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.dataframe.DaskDataFrame method) (fugue_duckdb.dataframe.DuckDataFrame method) (fugue_ibis.dataframe.IbisDataFrame method) (fugue_ray.dataframe.RayDataFrame method) (fugue_spark.dataframe.SparkDataFrame method) (in module fugue.api) I ibis_sql_engine (fugue_ibis.execution_engine.IbisExecutionEngine property) IbisDataFrame (class in fugue_ibis.dataframe) IbisEngine (class in fugue_ibis.execution.ibis_engine) IbisExecutionEngine (class in fugue_ibis.execution_engine) IbisMapEngine (class in fugue_ibis.execution_engine) IbisSQLEngine (class in fugue_ibis.execution_engine) in_context (fugue.execution.execution_engine.ExecutionEngine property) infer_alias() (fugue.column.expressions.ColumnExpr method) infer_type() (fugue.column.expressions.ColumnExpr method) inner_join() (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) (in module fugue.execution.api) intersect() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue.workflow.workflow.FugueWorkflow method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ibis.execution_engine.IbisSQLEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) (in module fugue.api) (in module fugue.execution.api) invoke() (fugue.rpc.base.RPCServer method) is_agg() (in module fugue.column.functions) is_bounded (fugue.bag.bag.LocalBoundedBag property) (fugue.dataframe.dataframe.LocalBoundedDataFrame property) (fugue.dataframe.dataframe.LocalUnboundedDataFrame property) (fugue.dataset.dataset.Dataset property) (fugue.workflow.workflow.WorkflowDataFrame property) (fugue_dask.dataframe.DaskDataFrame property) (fugue_ibis.dataframe.IbisDataFrame property) (fugue_ray.dataframe.RayDataFrame property) (fugue_spark.dataframe.SparkDataFrame property) is_bounded() (in module fugue.api) is_df() (in module fugue.api) is_distinct (fugue.column.sql.SelectColumns property) is_distributed (fugue.execution.execution_engine.FugueEngineBase property) (fugue.execution.native_execution_engine.NativeExecutionEngine property) (fugue.execution.native_execution_engine.PandasMapEngine property) (fugue.execution.native_execution_engine.QPDPandasEngine property) (fugue_dask.execution_engine.DaskExecutionEngine property) (fugue_dask.execution_engine.DaskMapEngine property) (fugue_dask.execution_engine.QPDDaskEngine property) (fugue_duckdb.execution_engine.DuckDBEngine property) (fugue_duckdb.execution_engine.DuckExecutionEngine property) (fugue_ibis.execution.ibis_engine.IbisEngine property) (fugue_ibis.execution_engine.IbisMapEngine property) (fugue_ray.execution_engine.RayExecutionEngine property) (fugue_ray.execution_engine.RayMapEngine property) (fugue_spark.execution_engine.SparkExecutionEngine property) (fugue_spark.execution_engine.SparkMapEngine property) (fugue_spark.execution_engine.SparkSQLEngine property) is_empty() (in module fugue.api) is_global (fugue.execution.execution_engine.ExecutionEngine property) is_local (fugue.bag.bag.LocalBag property) (fugue.dataframe.dataframe.LocalDataFrame property) (fugue.dataset.dataset.Dataset property) (fugue.workflow.workflow.WorkflowDataFrame property) (fugue_dask.dataframe.DaskDataFrame property) (fugue_ibis.dataframe.IbisDataFrame property) (fugue_ray.dataframe.RayDataFrame property) (fugue_spark.dataframe.SparkDataFrame property) is_local() (in module fugue.api) is_non_ibis() (fugue_ibis.execution_engine.IbisExecutionEngine method) is_null() (fugue.column.expressions.ColumnExpr method) is_pandas_or() (in module fugue.execution.factory) is_set (fugue.collections.yielded.PhysicalYielded property) (fugue.collections.yielded.Yielded property) (fugue.dataframe.dataframe.YieldedDataFrame property) is_spark_connect (fugue_spark.execution_engine.SparkExecutionEngine property) (fugue_spark.execution_engine.SparkMapEngine property) item (fugue.collections.partition.DatasetPartitionCursor property) IterableArrowDataFrame (class in fugue.dataframe.dataframe_iterable_dataframe) IterableDataFrame (class in fugue.dataframe.iterable_dataframe) IterablePandasDataFrame (class in fugue.dataframe.dataframe_iterable_dataframe) J join() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue.workflow.workflow.FugueWorkflow method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ibis.execution_engine.IbisSQLEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) (in module fugue.api) (in module fugue.execution.api) jsondict (fugue.collections.partition.PartitionSpec property) K key_schema (fugue.collections.partition.PartitionCursor property) (fugue.extensions.context.ExtensionContext property) key_value_array (fugue.collections.partition.PartitionCursor property) key_value_dict (fugue.collections.partition.PartitionCursor property) L last() (in module fugue.column.functions) last_df (fugue.workflow.workflow.FugueWorkflow property) left_anti_join() (fugue.workflow.workflow.WorkflowDataFrame method) left_outer_join() (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) (in module fugue.execution.api) left_semi_join() (fugue.workflow.workflow.WorkflowDataFrame method) lit() (in module fugue.column.expressions) literals (fugue.column.sql.SelectColumns property) load() (fugue.workflow.workflow.FugueWorkflow method) (in module fugue.api) (in module fugue.execution.api) load_df() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ray.execution_engine.RayExecutionEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) load_table() (fugue.execution.execution_engine.SQLEngine method) (fugue_duckdb.execution_engine.DuckDBEngine method) (fugue_ibis.execution_engine.IbisSQLEngine method) load_yielded() (fugue.execution.execution_engine.ExecutionEngine method) LocalBag (class in fugue.bag.bag) LocalBoundedBag (class in fugue.bag.bag) LocalBoundedDataFrame (class in fugue.dataframe.dataframe) LocalDataFrame (class in fugue.dataframe.dataframe) LocalDataFrameIterableDataFrame (class in fugue.dataframe.dataframe_iterable_dataframe) LocalDataFrameParam (class in fugue.dataframe.function_wrapper) LocalUnboundedDataFrame (class in fugue.dataframe.dataframe) log (fugue.execution.execution_engine.EngineFacet property) (fugue.execution.execution_engine.FugueEngineBase property) (fugue.execution.native_execution_engine.NativeExecutionEngine property) (fugue_dask.execution_engine.DaskExecutionEngine property) (fugue_duckdb.execution_engine.DuckExecutionEngine property) (fugue_ibis.execution_engine.IbisExecutionEngine property) (fugue_spark.execution_engine.SparkExecutionEngine property) M make_client() (fugue.rpc.base.NativeRPCServer method) (fugue.rpc.base.RPCServer method) (fugue.rpc.flask.FlaskRPCServer method) make_execution_engine() (in module fugue.execution.factory) make_rpc_server() (in module fugue.rpc.base) make_sql_engine() (in module fugue.execution.factory) map_bag() (fugue.execution.execution_engine.MapEngine method) (fugue_ibis.execution_engine.IbisMapEngine method) map_dataframe() (fugue.execution.execution_engine.MapEngine method) (fugue.execution.native_execution_engine.PandasMapEngine method) (fugue_dask.execution_engine.DaskMapEngine method) (fugue_ibis.execution_engine.IbisMapEngine method) (fugue_ray.execution_engine.RayMapEngine method) (fugue_spark.execution_engine.SparkMapEngine method) map_engine (fugue.execution.execution_engine.ExecutionEngine property) MapEngine (class in fugue.execution.execution_engine) max() (in module fugue.column.functions) metadata (fugue.dataset.dataset.Dataset property) min() (in module fugue.column.functions) module fugue.api fugue.bag.array_bag fugue.bag.bag fugue.collections.partition fugue.collections.sql fugue.collections.yielded fugue.column.expressions fugue.column.functions fugue.column.sql fugue.constants fugue.dataframe.api fugue.dataframe.array_dataframe fugue.dataframe.arrow_dataframe fugue.dataframe.dataframe fugue.dataframe.dataframe_iterable_dataframe fugue.dataframe.dataframes fugue.dataframe.function_wrapper fugue.dataframe.iterable_dataframe fugue.dataframe.pandas_dataframe fugue.dataframe.utils fugue.dataset.api fugue.dataset.dataset fugue.dev fugue.exceptions fugue.execution.api fugue.execution.execution_engine fugue.execution.factory fugue.execution.native_execution_engine fugue.extensions.context fugue.extensions.creator.convert fugue.extensions.creator.creator fugue.extensions.outputter.convert fugue.extensions.outputter.outputter fugue.extensions.processor.convert fugue.extensions.processor.processor fugue.extensions.transformer.constants fugue.extensions.transformer.convert fugue.extensions.transformer.transformer fugue.plugins fugue.registry fugue.rpc.base fugue.rpc.flask fugue.sql.api fugue.sql.workflow fugue.workflow.api fugue.workflow.input fugue.workflow.module fugue.workflow.workflow fugue_dask.dataframe fugue_dask.execution_engine fugue_dask.ibis_engine fugue_dask.registry fugue_duckdb.dask fugue_duckdb.dataframe fugue_duckdb.execution_engine fugue_duckdb.ibis_engine fugue_duckdb.registry fugue_ibis.dataframe fugue_ibis.execution.ibis_engine fugue_ibis.execution.pandas_backend fugue_ibis.execution_engine fugue_ibis.extensions fugue_ray.dataframe fugue_ray.execution_engine fugue_ray.registry fugue_spark.dataframe fugue_spark.execution_engine fugue_spark.ibis_engine fugue_spark.registry fugue_sql.exceptions module() (in module fugue.workflow.module) N name (fugue.collections.yielded.PhysicalYielded property) (fugue.column.expressions.ColumnExpr property) (fugue.workflow.workflow.WorkflowDataFrame property) native (fugue.bag.array_bag.ArrayBag property) (fugue.dataframe.array_dataframe.ArrayDataFrame property) (fugue.dataframe.arrow_dataframe.ArrowDataFrame property) (fugue.dataframe.dataframe_iterable_dataframe.LocalDataFrameIterableDataFrame property) (fugue.dataframe.iterable_dataframe.IterableDataFrame property) (fugue.dataframe.pandas_dataframe.PandasDataFrame property) (fugue.dataset.dataset.Dataset property) (fugue.workflow.workflow.WorkflowDataFrame property) (fugue_dask.dataframe.DaskDataFrame property) (fugue_duckdb.dataframe.DuckDataFrame property) (fugue_ibis.dataframe.IbisDataFrame property) (fugue_ray.dataframe.RayDataFrame property) (fugue_spark.dataframe.SparkDataFrame property) native_as_df() (fugue.dataframe.arrow_dataframe.ArrowDataFrame method) (fugue.dataframe.dataframe.DataFrame method) (fugue.dataframe.dataframe.LocalDataFrame method) (fugue.dataframe.pandas_dataframe.PandasDataFrame method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.dataframe.DaskDataFrame method) (fugue_duckdb.dataframe.DuckDataFrame method) (fugue_ibis.dataframe.IbisDataFrame method) (fugue_ray.dataframe.RayDataFrame method) (fugue_spark.dataframe.SparkDataFrame method) NativeExecutionEngine (class in fugue.execution.native_execution_engine) NativeRPCClient (class in fugue.rpc.base) NativeRPCServer (class in fugue.rpc.base) need_output_schema (fugue.dataframe.function_wrapper.DataFrameFunctionWrapper property) non_agg_funcs (fugue.column.sql.SelectColumns property) non_ibis_engine (fugue_ibis.execution_engine.IbisExecutionEngine property) normalize_column_names() (in module fugue.api) (in module fugue.dataframe.api) not_null() (fugue.column.expressions.ColumnExpr method) null() (in module fugue.column.expressions) num_partitions (fugue.bag.bag.LocalBag property) (fugue.collections.partition.PartitionSpec property) (fugue.dataframe.dataframe.LocalDataFrame property) (fugue.dataset.dataset.Dataset property) (fugue.workflow.workflow.WorkflowDataFrame property) (fugue_dask.dataframe.DaskDataFrame property) (fugue_ibis.dataframe.IbisDataFrame property) (fugue_ray.dataframe.RayDataFrame property) (fugue_spark.dataframe.SparkDataFrame property) O on_enter_context() (fugue.execution.execution_engine.ExecutionEngine method) on_exit_context() (fugue.execution.execution_engine.ExecutionEngine method) on_init() (fugue.extensions.transformer.transformer.CoTransformer method) (fugue.extensions.transformer.transformer.Transformer method) out_transform() (fugue.workflow.workflow.FugueWorkflow method) (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) (in module fugue.workflow.api) output() (fugue.workflow.workflow.FugueWorkflow method) (fugue.workflow.workflow.WorkflowDataFrame method) output_cotransformer() (in module fugue.extensions.transformer.convert) output_name (fugue.column.expressions.ColumnExpr property) output_schema (fugue.extensions.context.ExtensionContext property) output_transformer() (in module fugue.extensions.transformer.convert) OutputCoTransformer (class in fugue.extensions.transformer.transformer) Outputter (class in fugue.extensions.outputter.outputter) outputter() (in module fugue.extensions.outputter.convert) OutputTransformer (class in fugue.extensions.transformer.transformer) P PandasDataFrame (class in fugue.dataframe.pandas_dataframe) PandasIbisEngine (class in fugue_ibis.execution.pandas_backend) PandasMapEngine (class in fugue.execution.native_execution_engine) params (fugue.extensions.context.ExtensionContext property) parse_presort_exp() (in module fugue.collections.partition) partition() (fugue.workflow.workflow.WorkflowDataFrame method) partition_by (fugue.collections.partition.PartitionSpec property) partition_by() (fugue.workflow.workflow.WorkflowDataFrame method) partition_no (fugue.collections.partition.DatasetPartitionCursor property) partition_spec (fugue.extensions.context.ExtensionContext property) (fugue.workflow.workflow.WorkflowDataFrame property) PartitionCursor (class in fugue.collections.partition) PartitionSpec (class in fugue.collections.partition) peek() (fugue.bag.array_bag.ArrayBag method) (fugue.bag.bag.Bag method) peek_array() (fugue.dataframe.array_dataframe.ArrayDataFrame method) (fugue.dataframe.arrow_dataframe.ArrowDataFrame method) (fugue.dataframe.dataframe.DataFrame method) (fugue.dataframe.dataframe_iterable_dataframe.LocalDataFrameIterableDataFrame method) (fugue.dataframe.iterable_dataframe.IterableDataFrame method) (fugue.dataframe.pandas_dataframe.PandasDataFrame method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.dataframe.DaskDataFrame method) (fugue_duckdb.dataframe.DuckDataFrame method) (fugue_ibis.dataframe.IbisDataFrame method) (fugue_ray.dataframe.RayDataFrame method) (fugue_spark.dataframe.SparkDataFrame method) (in module fugue.api) peek_dict() (fugue.dataframe.arrow_dataframe.ArrowDataFrame method) (fugue.dataframe.dataframe.DataFrame method) (in module fugue.api) per_partition_by() (fugue.workflow.workflow.WorkflowDataFrame method) per_row() (fugue.workflow.workflow.WorkflowDataFrame method) persist() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.dataframe.DaskDataFrame method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.dask.DuckDaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ibis.execution_engine.IbisSQLEngine method) (fugue_ray.dataframe.RayDataFrame method) (fugue_ray.execution_engine.RayExecutionEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) (in module fugue.api) (in module fugue.execution.api) physical_partition_no (fugue.collections.partition.DatasetPartitionCursor property) PhysicalYielded (class in fugue.collections.yielded) pickle_df() (in module fugue.dataframe.utils) pl_utils (fugue.execution.native_execution_engine.NativeExecutionEngine property) (fugue_dask.execution_engine.DaskExecutionEngine property) presort (fugue.collections.partition.PartitionSpec property) presort_expr (fugue.collections.partition.PartitionSpec property) process() (fugue.extensions.outputter.outputter.Outputter method) (fugue.extensions.processor.processor.Processor method) (fugue.extensions.transformer.transformer.OutputCoTransformer method) (fugue.extensions.transformer.transformer.OutputTransformer method) (fugue.workflow.workflow.FugueWorkflow method) (fugue.workflow.workflow.WorkflowDataFrame method) Processor (class in fugue.extensions.processor.processor) processor() (in module fugue.extensions.processor.convert) Q QPDDaskEngine (class in fugue_dask.execution_engine) QPDPandasEngine (class in fugue.execution.native_execution_engine) query_to_table() (fugue_ibis.execution_engine.IbisSQLEngine method) R raw_sql() (in module fugue.api) (in module fugue.workflow.api) RayDataFrame (class in fugue_ray.dataframe) RayExecutionEngine (class in fugue_ray.execution_engine) RayMapEngine (class in fugue_ray.execution_engine) register() (fugue.rpc.base.RPCServer method) (fugue_spark.execution_engine.SparkExecutionEngine method) register_creator() (in module fugue.extensions.creator.convert) register_default_execution_engine() (in module fugue.execution.factory) register_default_sql_engine() (in module fugue.execution.factory) register_execution_engine() (in module fugue.execution.factory) register_global_conf() (in module fugue.constants) register_output_transformer() (in module fugue.extensions.transformer.convert) register_outputter() (in module fugue.extensions.outputter.convert) register_processor() (in module fugue.extensions.processor.convert) register_raw_df_type() (in module fugue.workflow.input) register_sql_engine() (in module fugue.execution.factory) register_transformer() (in module fugue.extensions.transformer.convert) rename() (fugue.dataframe.array_dataframe.ArrayDataFrame method) (fugue.dataframe.arrow_dataframe.ArrowDataFrame method) (fugue.dataframe.dataframe.DataFrame method) (fugue.dataframe.dataframe_iterable_dataframe.LocalDataFrameIterableDataFrame method) (fugue.dataframe.iterable_dataframe.IterableDataFrame method) (fugue.dataframe.pandas_dataframe.PandasDataFrame method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.dataframe.DaskDataFrame method) (fugue_duckdb.dataframe.DuckDataFrame method) (fugue_ibis.dataframe.IbisDataFrame method) (fugue_ray.dataframe.RayDataFrame method) (fugue_spark.dataframe.SparkDataFrame method) (in module fugue.api) repartition() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.dask.DuckDaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ray.execution_engine.RayExecutionEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) (in module fugue.api) (in module fugue.execution.api) replace_wildcard() (fugue.column.sql.SelectColumns method) repr() (fugue.dataset.dataset.DatasetDisplay method) repr_html() (fugue.dataset.dataset.DatasetDisplay method) reset_metadata() (fugue.dataset.dataset.Dataset method) result (fugue.dataframe.dataframe.YieldedDataFrame property) (fugue.workflow.workflow.WorkflowDataFrame property) right_outer_join() (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) (in module fugue.execution.api) row (fugue.collections.partition.PartitionCursor property) row_schema (fugue.collections.partition.PartitionCursor property) rpc_server (fugue.extensions.context.ExtensionContext property) RPCClient (class in fugue.rpc.base) RPCFunc (class in fugue.rpc.base) RPCHandler (class in fugue.rpc.base) RPCServer (class in fugue.rpc.base) run() (fugue.dataframe.function_wrapper.DataFrameFunctionWrapper method) (fugue.workflow.workflow.FugueWorkflow method) run_engine_function() (in module fugue.api) (in module fugue.execution.api) run_ibis() (in module fugue_ibis.extensions) running (fugue.rpc.base.RPCHandler property) S sample() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ibis.execution_engine.IbisSQLEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) (in module fugue.api) (in module fugue.execution.api) save() (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) (in module fugue.execution.api) save_and_use() (fugue.workflow.workflow.WorkflowDataFrame method) save_df() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.dask.DuckDaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ray.execution_engine.RayExecutionEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) save_table() (fugue.execution.execution_engine.SQLEngine method) (fugue_duckdb.execution_engine.DuckDBEngine method) (fugue_ibis.execution_engine.IbisSQLEngine method) schema (fugue.dataframe.dataframe.DataFrame property) (fugue.workflow.workflow.WorkflowDataFrame property) schema_discovered (fugue.dataframe.dataframe.DataFrame property) select() (fugue.column.sql.SQLExpressionGenerator method) (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.execution_engine.SQLEngine method) (fugue.execution.native_execution_engine.QPDPandasEngine method) (fugue.workflow.workflow.FugueWorkflow method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.execution_engine.QPDDaskEngine method) (fugue_dask.ibis_engine.DaskIbisEngine method) (fugue_duckdb.execution_engine.DuckDBEngine method) (fugue_duckdb.ibis_engine.DuckDBIbisEngine method) (fugue_ibis.execution.ibis_engine.IbisEngine method) (fugue_ibis.execution.pandas_backend.PandasIbisEngine method) (fugue_ibis.execution_engine.IbisSQLEngine method) (fugue_spark.execution_engine.SparkSQLEngine method) (fugue_spark.ibis_engine.SparkIbisEngine method) (in module fugue.api) (in module fugue.execution.api) select_columns() (in module fugue.api) SelectColumns (class in fugue.column.sql) semi_join() (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) (in module fugue.execution.api) serialize_df() (in module fugue.dataframe.utils) set() (fugue.collections.partition.DatasetPartitionCursor method) (fugue.collections.partition.PartitionCursor method) set_global() (fugue.execution.execution_engine.ExecutionEngine method) set_global_engine() (in module fugue.api) (in module fugue.execution.api) set_op() (fugue.workflow.workflow.FugueWorkflow method) set_sql_engine() (fugue.execution.execution_engine.ExecutionEngine method) set_value() (fugue.collections.yielded.PhysicalYielded method) (fugue.dataframe.dataframe.YieldedDataFrame method) show() (fugue.bag.bag.BagDisplay method) (fugue.dataframe.dataframe.DataFrameDisplay method) (fugue.dataset.dataset.Dataset method) (fugue.dataset.dataset.DatasetDisplay method) (fugue.workflow.workflow.FugueWorkflow method) (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) (in module fugue.dataset.api) simple (fugue.column.sql.SelectColumns property) simple_cols (fugue.column.sql.SelectColumns property) slice_no (fugue.collections.partition.DatasetPartitionCursor property) spark_session (fugue_spark.execution_engine.SparkExecutionEngine property) SparkDataFrame (class in fugue_spark.dataframe) SparkExecutionEngine (class in fugue_spark.execution_engine) SparkIbisEngine (class in fugue_spark.ibis_engine) SparkMapEngine (class in fugue_spark.execution_engine) SparkSQLEngine (class in fugue_spark.execution_engine) spec_uuid() (fugue.workflow.workflow.FugueWorkflow method) (fugue.workflow.workflow.WorkflowDataFrame method) sql_engine (fugue.execution.execution_engine.ExecutionEngine property) sql_vars (fugue.sql.workflow.FugueSQLWorkflow property) SQLEngine (class in fugue.execution.execution_engine) SQLExpressionGenerator (class in fugue.column.sql) start() (fugue.rpc.base.RPCHandler method) start_handler() (fugue.rpc.base.RPCHandler method) (fugue.rpc.base.RPCServer method) start_server() (fugue.rpc.base.NativeRPCServer method) (fugue.rpc.base.RPCServer method) (fugue.rpc.flask.FlaskRPCServer method) stop() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.rpc.base.RPCHandler method) stop_engine() (fugue.execution.execution_engine.ExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) stop_handler() (fugue.rpc.base.RPCHandler method) (fugue.rpc.base.RPCServer method) stop_server() (fugue.rpc.base.NativeRPCServer method) (fugue.rpc.base.RPCServer method) (fugue.rpc.flask.FlaskRPCServer method) storage_type (fugue.collections.yielded.PhysicalYielded property) strong_checkpoint() (fugue.workflow.workflow.WorkflowDataFrame method) StructuredRawSQL (class in fugue.collections.sql) subtract() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue.workflow.workflow.FugueWorkflow method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ibis.execution_engine.IbisSQLEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) (in module fugue.api) (in module fugue.execution.api) sum() (in module fugue.column.functions) T table_exists() (fugue.execution.execution_engine.SQLEngine method) (fugue_duckdb.execution_engine.DuckDBEngine method) (fugue_ibis.execution_engine.IbisSQLEngine method) take() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ibis.execution_engine.IbisSQLEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) (in module fugue.api) (in module fugue.execution.api) TempTableName (class in fugue.collections.sql) to_dask_engine_df() (in module fugue_dask.execution_engine) to_df() (fugue.execution.execution_engine.EngineFacet method) (fugue.execution.execution_engine.FugueEngineBase method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue.execution.native_execution_engine.PandasMapEngine method) (fugue.execution.native_execution_engine.QPDPandasEngine method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_dask.execution_engine.QPDDaskEngine method) (fugue_duckdb.dask.DuckDaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution.ibis_engine.IbisEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ray.execution_engine.RayExecutionEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) to_input() (fugue.execution.execution_engine.ExecutionEngineParam method) to_input_data() (fugue.dataframe.function_wrapper.DataFrameParam method) (fugue.dataframe.function_wrapper.LocalDataFrameParam method) to_output_df() (fugue.dataframe.function_wrapper.DataFrameParam method) (fugue.dataframe.function_wrapper.LocalDataFrameParam method) to_rpc_handler() (in module fugue.rpc.base) to_sql() (fugue_ibis.dataframe.IbisDataFrame method) transform() (fugue.extensions.transformer.transformer.CoTransformer method) (fugue.extensions.transformer.transformer.OutputCoTransformer method) (fugue.extensions.transformer.transformer.OutputTransformer method) (fugue.extensions.transformer.transformer.Transformer method) (fugue.workflow.workflow.FugueWorkflow method) (fugue.workflow.workflow.WorkflowDataFrame method) (in module fugue.api) (in module fugue.workflow.api) Transformer (class in fugue.extensions.transformer.transformer) transformer() (in module fugue.extensions.transformer.convert) try_get_context_execution_engine() (in module fugue.execution.factory) type_to_expr() (fugue.column.sql.SQLExpressionGenerator method) U union() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.execution.native_execution_engine.NativeExecutionEngine method) (fugue.workflow.workflow.FugueWorkflow method) (fugue.workflow.workflow.WorkflowDataFrame method) (fugue_dask.execution_engine.DaskExecutionEngine method) (fugue_duckdb.execution_engine.DuckExecutionEngine method) (fugue_ibis.execution_engine.IbisExecutionEngine method) (fugue_ibis.execution_engine.IbisSQLEngine method) (fugue_ray.execution_engine.RayExecutionEngine method) (fugue_spark.execution_engine.SparkExecutionEngine method) (in module fugue.api) (in module fugue.execution.api) unpickle_df() (in module fugue.dataframe.utils) V validate_on_compile() (fugue.extensions.context.ExtensionContext method) validate_on_runtime() (fugue.extensions.context.ExtensionContext method) validation_rules (fugue.extensions.context.ExtensionContext property) W weak_checkpoint() (fugue.workflow.workflow.WorkflowDataFrame method) where() (fugue.column.sql.SQLExpressionGenerator method) workflow (fugue.workflow.workflow.WorkflowDataFrame property) (fugue.workflow.workflow.WorkflowDataFrames property) workflow_conf (fugue.extensions.context.ExtensionContext property) WorkflowDataFrame (class in fugue.workflow.workflow) WorkflowDataFrames (class in fugue.workflow.workflow) Y yield_dataframe_as() (fugue.workflow.workflow.WorkflowDataFrame method) yield_file_as() (fugue.workflow.workflow.WorkflowDataFrame method) yield_table_as() (fugue.workflow.workflow.WorkflowDataFrame method) Yielded (class in fugue.collections.yielded) YieldedDataFrame (class in fugue.dataframe.dataframe) yields (fugue.workflow.workflow.FugueWorkflow property) (fugue.workflow.workflow.FugueWorkflowResult property) Z zip() (fugue.execution.execution_engine.ExecutionEngine method) (fugue.workflow.workflow.FugueWorkflow method) (fugue.workflow.workflow.WorkflowDataFrame method) zip_all() (fugue.execution.execution_engine.ExecutionEngine method)