Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/deepseek-ai/smallpond
/ functions
Functions
992 in github.com/deepseek-ai/smallpond
⨍
Functions
992
◇
Types & classes
154
↳
Endpoints
2
Method
self_contained_output
(self)
smallpond/execution/task.py:1792
Method
self_contained_output
(self)
smallpond/execution/task.py:3307
Method
self_contained_output
(self)
smallpond/execution/task.py:3369
Method
setUp
(self)
tests/test_fabric.py:84
Method
setUp
(self)
tests/test_workqueue.py:105
Method
setUp
(self)
tests/test_workqueue.py:115
Method
setup_worker
()
smallpond/session.py:59
Method
shutdown
Shutdown the session.
smallpond/session.py:150
Method
size
(self)
smallpond/execution/workqueue.py:312
Method
skip_when_any_input_empty
(self)
smallpond/execution/task.py:718
Method
slow_iterator
(iter: Iterable[int], sleep_ms: int)
tests/test_utility.py:13
Function
sort_records
( runtime_ctx: RuntimeContext, input_datasets: List[DataSet], output_path: str, sort_engine="p
benchmarks/gray_sort_benchmark.py:103
Method
sorted_table
(t: arrow.Table)
tests/test_fabric.py:281
Function
sp
A smallpond session for each test
tests/conftest.py:22
Method
spawn
(self, *args, **kwargs)
smallpond/contrib/log_dataset.py:34
Method
spawn
(self, *args, **kwargs)
smallpond/logical/node.py:918
Method
spawn
(self, *args, **kwargs)
smallpond/logical/node.py:932
Method
spawn
(self, *args, **kwargs)
smallpond/logical/node.py:946
Method
spawn
(self, *args, **kwargs)
tests/test_scheduler.py:60
Method
spawn
(self, *args, **kwargs)
tests/test_execution.py:81
Function
split_url
(urls: arrow.array)
tests/test_execution.py:229
Method
sql_query_fragment
( self, filesystem: fsspec.AbstractFileSystem = None, conn: duckdb.DuckDBPyConnection
smallpond/logical/dataset.py:490
Method
sql_query_fragment
( self, filesystem: fsspec.AbstractFileSystem = None, conn: duckdb.DuckDBPyConnection
smallpond/logical/dataset.py:550
Method
sql_query_fragment
( self, filesystem: fsspec.AbstractFileSystem = None, conn: duckdb.DuckDBPyConnection
smallpond/logical/dataset.py:702
Method
sql_query_fragment
( self, filesystem: fsspec.AbstractFileSystem = None, conn: duckdb.DuckDBPyConnection
smallpond/logical/dataset.py:1053
Method
sql_query_fragment
( self, filesystem: fsspec.AbstractFileSystem = None, conn: duckdb.DuckDBPyConnection
smallpond/logical/dataset.py:1091
Method
staging_root
If the task has a special output directory, its runtime output directory will be under it.
smallpond/execution/task.py:740
Method
start_job
Start a job on the platform. Return the job ids.
smallpond/platform/base.py:25
Method
stop
(self)
smallpond/execution/executor.py:144
Method
stop
(self)
smallpond/execution/scheduler.py:237
Method
stopped
(self)
smallpond/execution/scheduler.py:119
Method
stopped_executors
(self)
smallpond/execution/scheduler.py:552
Method
stopping
(self)
smallpond/execution/scheduler.py:115
Method
stopping_executors
(self)
smallpond/execution/scheduler.py:556
Method
succeeded_task_ids
(self)
smallpond/execution/scheduler.py:506
Method
successful
(self)
smallpond/execution/task.py:3554
Method
sum_children_metrics
(obj: Dict, metric: str)
smallpond/execution/task.py:1321
Method
take
Return up to `limit` rows. This operation will trigger execution of the lazy transformations performed on this DataFrame.
smallpond/dataframe.py:664
Method
task
(self)
smallpond/execution/task.py:314
Method
task_factory
(task_builder)
smallpond/logical/node.py:259
Method
tasks
(self)
smallpond/execution/task.py:3572
Method
tearDown
(self)
tests/test_fabric.py:100
Method
temp_abspath
(self)
smallpond/execution/task.py:776
Method
temp_output
Whether the output of this node is stored in a temporary directory.
smallpond/execution/task.py:791
Function
test_arrow
(sp: Session)
tests/test_dataframe.py:16
Function
test_arrow_reader
(benchmark, reader: str, dataset_path: str)
tests/test_dataset.py:166
Method
test_arrow_schema_metadata
(self)
tests/test_arrow.py:131
Method
test_arrow_task
(self)
tests/test_execution.py:255
Method
test_arrow_type_in_udfs
(self)
tests/test_execution.py:512
Method
test_basics
(self)
tests/test_workqueue.py:73
Method
test_change_ordering_of_columns
(self)
tests/test_arrow.py:182
Method
test_concurrent_iter_no_error
(self)
tests/test_utility.py:12
Method
test_concurrent_iter_with_error
(self)
tests/test_utility.py:23
Function
test_count
(sp: Session)
tests/test_dataframe.py:134
Function
test_csv
(sp: Session)
tests/test_dataframe.py:29
Method
test_data_sink_avoid_filename_conflicts
(self)
tests/test_execution.py:785
Method
test_delete_update
(self)
tests/test_deltalake.py:51
Method
test_dump_load_empty_table
(self)
tests/test_arrow.py:75
Method
test_dump_to_parquet_files
(self)
tests/test_arrow.py:57
Method
test_empty_dataset_partition
(self)
tests/test_partition.py:81
Method
test_empty_hash_partition
(self)
tests/test_partition.py:185
Method
test_enforce_memory_limit
(self)
tests/test_execution.py:623
Function
test_error_message
(sp: Session)
tests/test_dataframe.py:176
Method
test_execute_command
(self)
tests/test_utility.py:43
Method
test_failed_executors
(self)
tests/test_scheduler.py:109
Method
test_file_io_benchmark
(self)
tests/test_bench.py:17
Function
test_filter
(sp: Session)
tests/test_dataframe.py:87
Function
test_flat_map
(sp: Session)
tests/test_dataframe.py:64
Function
test_fstest
(sp: Session)
tests/test_plan.py:56
Method
test_get_nth_partition
(self)
tests/test_common.py:13
Method
test_gray_sort_benchmark
(self)
tests/test_bench.py:39
Method
test_hash_partition
(self)
tests/test_partition.py:115
Method
test_hash_partition_benchmark
(self)
tests/test_bench.py:79
Function
test_items
(sp: Session)
tests/test_dataframe.py:22
Method
test_join_chunkmeta_inodes
(self)
tests/test_logical.py:21
Function
test_limit
(sp: Session)
tests/test_dataframe.py:139
Function
test_limit_large
(sp: Session)
tests/test_dataframe.py:146
Method
test_literal_datasets_as_data_sources
(self)
tests/test_execution.py:828
Method
test_load_from_parquet_files
(self)
tests/test_arrow.py:21
Method
test_load_mixed_large_dtypes
(self)
tests/test_deltalake.py:30
Method
test_load_mixed_string_types
(self)
tests/test_arrow.py:159
Method
test_load_not_exist_column
(self)
tests/test_arrow.py:177
Method
test_load_parquet_row_ranges
(self)
tests/test_arrow.py:32
Method
test_load_partitioned_datasets
(self)
tests/test_partition.py:310
Method
test_local_gpu_rank
(self)
tests/test_execution.py:572
Function
test_log
(sp: Session)
tests/test_dataframe.py:204
Method
test_manifest_only_data_sink
(self)
tests/test_execution.py:668
Method
test_many_file_partitions
(self)
tests/test_partition.py:44
Method
test_many_producers_and_partitions
(self)
tests/test_execution.py:552
Method
test_many_row_partitions
(self)
tests/test_partition.py:61
Method
test_many_simple_tasks
(self)
tests/test_execution.py:535
Function
test_map
(sp: Session)
tests/test_dataframe.py:49
Function
test_map_batches
(sp: Session)
tests/test_dataframe.py:78
Method
test_multi_consumers
(self)
tests/test_workqueue.py:85
Method
test_multiple_sql_queries
(self)
tests/test_execution.py:710
Method
test_nested_partition
(self)
tests/test_partition.py:428
Method
test_npartitions_not_compatible
(self)
tests/test_logical.py:72
Method
test_num_rows
(self)
tests/test_dataset.py:71
Method
test_override_output_path
(self)
tests/test_execution.py:756
Function
test_pandas
(sp: Session)
tests/test_dataframe.py:10
← previous
next →
801–900 of 992, ranked by callers