Index _ | A | C | D | E | F | H | I | J | L | M | N | P | R | S | T | U | W _ __init__() (smallpond.execution.driver.Driver method) (smallpond.execution.executor.Executor method) (smallpond.execution.manager.JobManager method) (smallpond.execution.scheduler.Scheduler method) (smallpond.execution.task.ArrowBatchTask method) (smallpond.execution.task.ArrowComputeTask method) (smallpond.execution.task.ArrowStreamTask method) (smallpond.execution.task.DataSinkTask method) (smallpond.execution.task.DataSourceTask method) (smallpond.execution.task.EvenlyDistributedPartitionProducerTask method) (smallpond.execution.task.ExecutionPlan method) (smallpond.execution.task.HashPartitionArrowTask method) (smallpond.execution.task.HashPartitionDuckDbTask method) (smallpond.execution.task.HashPartitionTask method) (smallpond.execution.task.JobId method) (smallpond.execution.task.LoadPartitionedDataSetProducerTask method) (smallpond.execution.task.MergeDataSetsTask method) (smallpond.execution.task.PandasBatchTask method) (smallpond.execution.task.PandasComputeTask method) (smallpond.execution.task.PartitionConsumerTask method) (smallpond.execution.task.PartitionInfo method) (smallpond.execution.task.PartitionProducerTask method) (smallpond.execution.task.PerfStats method) (smallpond.execution.task.ProjectionTask method) (smallpond.execution.task.PythonScriptTask method) (smallpond.execution.task.RangePartitionTask method) (smallpond.execution.task.RepeatPartitionProducerTask method) (smallpond.execution.task.RootTask method) (smallpond.execution.task.RuntimeContext method) (smallpond.execution.task.SplitDataSetTask method) (smallpond.execution.task.SqlEngineTask method) (smallpond.execution.task.Task method) (smallpond.execution.task.TaskId method) (smallpond.execution.task.TaskRuntimeId method) (smallpond.execution.task.UserDefinedPartitionProducerTask method) (smallpond.logical.dataset.ArrowTableDataSet method) (smallpond.logical.dataset.CsvDataSet method) (smallpond.logical.dataset.DataSet method) (smallpond.logical.dataset.FileSet method) (smallpond.logical.dataset.JsonDataSet method) (smallpond.logical.dataset.PandasDataSet method) (smallpond.logical.dataset.ParquetDataSet method) (smallpond.logical.dataset.PartitionedDataSet method) (smallpond.logical.dataset.SqlQueryDataSet method) (smallpond.logical.node.ArrowBatchNode method) (smallpond.logical.node.ArrowComputeNode method) (smallpond.logical.node.ArrowStreamNode method) (smallpond.logical.node.ConsolidateNode method) (smallpond.logical.node.Context method) (smallpond.logical.node.DataSinkNode method) (smallpond.logical.node.DataSourceNode method) (smallpond.logical.node.EvenlyDistributedPartitionNode method) (smallpond.logical.node.HashPartitionNode method) (smallpond.logical.node.LimitNode method) (smallpond.logical.node.LoadPartitionedDataSetNode method) (smallpond.logical.node.LogicalPlan method) (smallpond.logical.node.LogicalPlanVisitor method) (smallpond.logical.node.Node method) (smallpond.logical.node.NodeId method) (smallpond.logical.node.PandasBatchNode method) (smallpond.logical.node.PandasComputeNode method) (smallpond.logical.node.PartitionNode method) (smallpond.logical.node.ProjectionNode method) (smallpond.logical.node.PythonScriptNode method) (smallpond.logical.node.RangePartitionNode method) (smallpond.logical.node.RepeatPartitionNode method) (smallpond.logical.node.RootNode method) (smallpond.logical.node.ShuffleNode method) (smallpond.logical.node.SqlEngineNode method) (smallpond.logical.node.UnionNode method) (smallpond.logical.node.UserDefinedPartitionNode method) (smallpond.logical.node.UserPartitionedDataSourceNode method) (smallpond.platform.MPI method) (smallpond.platform.Platform method) A ArrowBatchNode (class in smallpond.logical.node) ArrowBatchTask (class in smallpond.execution.task) ArrowComputeNode (class in smallpond.logical.node) ArrowComputeTask (class in smallpond.execution.task) ArrowStreamNode (class in smallpond.logical.node) ArrowStreamTask (class in smallpond.execution.task) ArrowTableDataSet (class in smallpond.logical.dataset) C compute() (smallpond.dataframe.DataFrame method) ConsolidateNode (class in smallpond.logical.node) Context (class in smallpond.logical.node) count() (smallpond.dataframe.DataFrame method) CsvDataSet (class in smallpond.logical.dataset) D DataSet (class in smallpond.logical.dataset) DataSetPartitionNode() (in module smallpond.logical.node) DataSinkNode (class in smallpond.logical.node) DataSinkTask (class in smallpond.execution.task) DataSourceNode (class in smallpond.logical.node) DataSourceTask (class in smallpond.execution.task) Driver (class in smallpond.execution.driver) E EvenlyDistributedPartitionNode (class in smallpond.logical.node) EvenlyDistributedPartitionProducerTask (class in smallpond.execution.task) ExecutionPlan (class in smallpond.execution.task) Executor (class in smallpond.execution.executor) F FileSet (class in smallpond.logical.dataset) filter() (smallpond.dataframe.DataFrame method) flat_map() (smallpond.dataframe.DataFrame method) from_arrow() (smallpond.dataframe.Session method) from_items() (smallpond.dataframe.Session method) from_pandas() (smallpond.dataframe.Session method) H HashPartitionArrowTask (class in smallpond.execution.task) HashPartitionDuckDbTask (class in smallpond.execution.task) HashPartitionNode (class in smallpond.logical.node) HashPartitionTask (class in smallpond.execution.task) I init() (in module smallpond) is_computed() (smallpond.dataframe.DataFrame method) J JobId (class in smallpond.execution.task) JobManager (class in smallpond.execution.manager) JsonDataSet (class in smallpond.logical.dataset) L limit() (smallpond.dataframe.DataFrame method) LimitNode (class in smallpond.logical.node) LoadPartitionedDataSetNode (class in smallpond.logical.node) LoadPartitionedDataSetProducerTask (class in smallpond.execution.task) LogicalPlan (class in smallpond.logical.node) LogicalPlanVisitor (class in smallpond.logical.node) M map() (smallpond.dataframe.DataFrame method) map_batches() (smallpond.dataframe.DataFrame method) MergeDataSetsTask (class in smallpond.execution.task) MPI (class in smallpond.platform) N Node (class in smallpond.logical.node) NodeId (class in smallpond.logical.node) P PandasBatchNode (class in smallpond.logical.node) PandasBatchTask (class in smallpond.execution.task) PandasComputeNode (class in smallpond.logical.node) PandasComputeTask (class in smallpond.execution.task) PandasDataSet (class in smallpond.logical.dataset) ParquetDataSet (class in smallpond.logical.dataset) partial_sort() (smallpond.dataframe.DataFrame method) partial_sql() (smallpond.dataframe.Session method) PartitionConsumerTask (class in smallpond.execution.task) PartitionedDataSet (class in smallpond.logical.dataset) PartitionInfo (class in smallpond.execution.task) PartitionNode (class in smallpond.logical.node) PartitionProducerTask (class in smallpond.execution.task) PerfStats (class in smallpond.execution.task) Platform (class in smallpond.platform) ProjectionNode (class in smallpond.logical.node) ProjectionTask (class in smallpond.execution.task) PythonScriptNode (class in smallpond.logical.node) PythonScriptTask (class in smallpond.execution.task) R random_shuffle() (smallpond.dataframe.DataFrame method) RangePartitionNode (class in smallpond.logical.node) RangePartitionTask (class in smallpond.execution.task) read_csv() (smallpond.dataframe.Session method) read_json() (smallpond.dataframe.Session method) read_parquet() (smallpond.dataframe.Session method) recompute() (smallpond.dataframe.DataFrame method) repartition() (smallpond.dataframe.DataFrame method) RepeatPartitionNode (class in smallpond.logical.node) RepeatPartitionProducerTask (class in smallpond.execution.task) RootNode (class in smallpond.logical.node) RootTask (class in smallpond.execution.task) RuntimeContext (class in smallpond.execution.task) S Scheduler (class in smallpond.execution.scheduler) ShuffleNode (class in smallpond.logical.node) SplitDataSetTask (class in smallpond.execution.task) SqlEngineNode (class in smallpond.logical.node) SqlEngineTask (class in smallpond.execution.task) SqlQueryDataSet (class in smallpond.logical.dataset) T take() (smallpond.dataframe.DataFrame method) take_all() (smallpond.dataframe.DataFrame method) Task (class in smallpond.execution.task) TaskId (class in smallpond.execution.task) TaskRuntimeId (class in smallpond.execution.task) to_arrow() (smallpond.dataframe.DataFrame method) to_pandas() (smallpond.dataframe.DataFrame method) U UnionNode (class in smallpond.logical.node) UserDefinedPartitionNode (class in smallpond.logical.node) UserDefinedPartitionProducerTask (class in smallpond.execution.task) UserPartitionedDataSourceNode (class in smallpond.logical.node) W wait() (smallpond.dataframe.Session method) write_parquet() (smallpond.dataframe.DataFrame method) write_parquet_lazy() (smallpond.dataframe.DataFrame method)