API Reference

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