MCPcopy Create free account

hub / github.com/dask/dask / functions

Functions9,157 in github.com/dask/dask

↓ 1 callersMethod_divisions
(self)
dask/dataframe/dask_expr/_expr.py:2652
↓ 1 callersMethod_divisions
(self)
dask/dataframe/dask_expr/_expr.py:3469
↓ 1 callersMethod_divisions
(self)
dask/dataframe/dask_expr/_cumulative.py:83
↓ 1 callersMethod_divisions
(self)
dask/dataframe/dask_expr/_shuffle.py:773
↓ 1 callersMethod_divisions
(self)
dask/dataframe/dask_expr/_concat.py:80
↓ 1 callersMethod_divisions
(self)
dask/dataframe/dask_expr/io/io.py:133
↓ 1 callersMethod_divisions
(self)
dask/dataframe/dask_expr/io/io.py:678
↓ 1 callersFunction_divisions_from_statistics
(aggregated_stats, index_name)
dask/dataframe/dask_expr/io/parquet.py:1838
↓ 1 callersFunction_elemwise_normalize_where
(where)
dask/array/core.py:5214
↓ 1 callersFunction_empty_series
(name, dtype, index=None)
dask/dataframe/utils.py:261
↓ 1 callersFunction_enforce_max_key_limit
(key_name)
dask/optimization.py:422
↓ 1 callersFunction_ensure_not_async
(client)
dask/base.py:1205
↓ 1 callersFunction_equal_var_ttest_denom
(v1, n1, v2, n2)
dask/array/stats.py:427
↓ 1 callersFunction_expander
(where)
dask/array/slicing.py:680
↓ 1 callersFunction_explain_dependencies
(expr: BaseExpr)
dask/dataframe/dask_expr/diagnostics/_explain.py:103
↓ 1 callersFunction_explain_details
(expr: BaseExpr)
dask/dataframe/dask_expr/diagnostics/_explain.py:86
↓ 1 callersFunction_extra_args
(typ: type)
dask/_task_spec.py:1214
↓ 1 callersFunction_extra_deps
(func, *args, extras=None, **kwargs)
dask/dataframe/io/sql.py:605
↓ 1 callersMethod_filter_passthrough_available
(self, parent, dependents)
dask/dataframe/dask_expr/_merge.py:100
↓ 1 callersMethod_filter_passthrough_available
(self, parent, dependents)
dask/dataframe/dask_expr/io/parquet.py:723
↓ 1 callersMethod_filtered_task
(self, name: Key, index: int)
dask/dataframe/dask_expr/_expr.py:3118
↓ 1 callersFunction_finalize_args_collections
(args, collections)
dask/delayed.py:77
↓ 1 callersFunction_finalize_var
( df, count_column, sum_column, sum2_column, adjust_arrow=True, **kwargs )
dask/dataframe/groupby.py:1108
↓ 1 callersFunction_find_layer_containing_key
(key)
dask/highlevelgraph.py:37
↓ 1 callersFunction_flat_set
(x)
dask/optimization.py:231
↓ 1 callersFunction_frag_subset
Create new fragment with row-group subset.
dask/dataframe/io/parquet/arrow.py:194
↓ 1 callersMethod_fragment_sort_index
(self)
dask/dataframe/dask_expr/io/parquet.py:1100
↓ 1 callersMethod_fragment_to_table
(fragment_wrapper, filters, columns, schema)
dask/dataframe/dask_expr/io/parquet.py:1198
↓ 1 callersMethod_from_collection
`from_collections` optimized for a single collection
dask/highlevelgraph.py:451
↓ 1 callersFunction_from_scalars
(scalars, meta, names)
dask/dataframe/dask_expr/_collection.py:6161
↓ 1 callersFunction_fuse_annotations
Given an iterable of annotations dictionaries, fuse them according to some simple rules.
dask/blockwise.py:1228
↓ 1 callersFunction_fusion_pass
(expr)
dask/dataframe/dask_expr/_expr.py:3257
↓ 1 callersFunction_gather_statistics
(frags)
dask/dataframe/dask_expr/io/parquet.py:1982
↓ 1 callersFunction_get_aggregation_depth
(aggregate_files, partition_names)
dask/dataframe/io/parquet/utils.py:609
↓ 1 callersFunction_get_attrs
(node)
conftest.py:79
↓ 1 callersMethod_get_binary_operator
Must return a method used by binary operator
dask/utils.py:1450
↓ 1 callersFunction_get_chunks
(n, chunksize)
dask/array/rechunk.py:826
↓ 1 callersMethod_get_culled_divisions
(self, divisions)
dask/dataframe/dask_expr/_shuffle.py:1238
↓ 1 callersFunction_get_dependencies
(obj: object)
dask/_task_spec.py:620
↓ 1 callersFunction_get_display_cls
Get the appropriate IPython display class for `format`. Returns `IPython.display.SVG` if format=='svg', otherwise `IPython.display.Image
dask/dot.py:210
↓ 1 callersFunction_get_divisions_map_partitions
Helper to get divisions for map_partitions and map_overlap output.
dask/dataframe/core.py:64
↓ 1 callersFunction_get_dt_meta_computed
( x, check_shape=True, check_graph=True, check_chunks=True, check_ndim=True, scheduler
dask/array/utils.py:260
↓ 1 callersFunction_get_gc_overhead
()
dask/tests/test_task_spec.py:686
↓ 1 callersFunction_get_keys_stops_divisions
Get the "keys" or group identifiers which match the given key, which can contain wildcards (see _expand_path). This uses the hdf file ide
dask/dataframe/io/hdf.py:515
↓ 1 callersMethod_get_lengths
(self)
dask/dataframe/dask_expr/io/io.py:496
↓ 1 callersMethod_get_lengths
Return known partition lengths using parquet statistics
dask/dataframe/dask_expr/io/parquet.py:1475
↓ 1 callersFunction_get_mem_usages
(frame)
dask/dataframe/dask_expr/_repartition.py:511
↓ 1 callersFunction_get_min_max_value
(x, func)
dask/dataframe/dask_expr/io/parquet.py:1949
↓ 1 callersMethod_get_original_predicate_columns
(self, predicate)
dask/dataframe/dask_expr/_merge.py:143
↓ 1 callersFunction_get_pandas_metadata
Get pandas-specific metadata from schema.
dask/dataframe/io/parquet/arrow.py:204
↓ 1 callersFunction_get_rg_statistics
Custom version of pyarrow's RowGroupInfo.statistics method (https://github.com/apache/arrow/blob/master/python/pyarrow/_dataset.pyx) We use c
dask/dataframe/io/parquet/arrow.py:278
↓ 1 callersFunction_get_symmat
(size)
dask/array/tests/test_cupy_linalg.py:398
↓ 1 callersMethod_get_unary_operator
Must return a method used by unary operator
dask/utils.py:1445
↓ 1 callersFunction_get_zarr_write_chunks
Get the appropriate chunk shape for writing to a Zarr array. For Zarr v3 arrays with sharding, returns the shard shape. For arrays without sh
dask/array/core.py:4127
↓ 1 callersFunction_groupby_aggregate
( df, aggfunc=None, levels=None, dropna=None, sort=False, observed=None, **kwargs )
dask/dataframe/groupby.py:258
↓ 1 callersFunction_groupby_aggregate_spec
A simpler version of _groupby_aggregate that just calls ``aggregate`` using the user-provided spec.
dask/dataframe/groupby.py:269
↓ 1 callersFunction_groupby_get_group
(df, by_key, get_key, columns)
dask/dataframe/groupby.py:175
↓ 1 callersFunction_groupby_slice_apply
( df, grouper, key, func, *args, group_keys=GROUP_KEYS_DEFAULT, dropna=None, o
dask/dataframe/groupby.py:104
↓ 1 callersFunction_groupby_slice_shift
( df, grouper, key, shuffled, group_keys=GROUP_KEYS_DEFAULT, dropna=None, observed
dask/dataframe/groupby.py:151
↓ 1 callersFunction_groupby_slice_transform
( df, grouper, key, func, *args, group_keys=GROUP_KEYS_DEFAULT, dropna=None, o
dask/dataframe/groupby.py:125
↓ 1 callersFunction_head_timedelta
Return rows of ``next_`` whose index is before the last observation in ``current`` + ``after``. Parameters ---------- current : DataF
dask/dataframe/rolling.py:35
↓ 1 callersFunction_hive_dirname
(name, val)
dask/dataframe/io/parquet/arrow.py:342
↓ 1 callersFunction_index_in_schema
Simple utility to check if all `index` columns are included in the known `schema`.
dask/dataframe/io/parquet/arrow.py:163
↓ 1 callersFunction_infer_split_row_groups
(row_group_sizes, blocksize, aggregate_files=False)
dask/dataframe/io/parquet/utils.py:754
↓ 1 callersFunction_initialize
()
dask/config.py:885
↓ 1 callersMethod_ipython_key_completions_
(self)
dask/dataframe/dask_expr/_collection.py:2802
↓ 1 callersFunction_is_aligned
Check if ``df`` and ``by`` have aligned indices
dask/dataframe/groupby.py:47
↓ 1 callersFunction_is_any_real_numeric_dtype
(arr_or_dtype)
dask/dataframe/dask_expr/_util.py:185
↓ 1 callersFunction_is_column_label_reference
(df, key)
dask/dataframe/multi.py:278
↓ 1 callersFunction_is_column_label_reference
Test whether a key is a column label reference To be considered a column label reference, `key` must match the name of at least one colu
dask/dataframe/dask_expr/_shuffle.py:658
↓ 1 callersFunction_is_getter_task
Check if a value in a Dask graph looks like a getter. 1. Is it a tuple with the first element a known getter. If a getter is found, it returns
dask/array/optimization.py:68
↓ 1 callersFunction_is_index_level_reference
(x, key)
dask/dataframe/multi.py:254
↓ 1 callersFunction_is_index_level_reference
Test whether a key is an index level reference To be considered an index level reference, `key` must match the index name and must NOT m
dask/dataframe/dask_expr/_shuffle.py:682
↓ 1 callersFunction_is_local_fs_pyarrow
Check if a pyarrow-based file-system is local
dask/dataframe/io/utils.py:27
↓ 1 callersFunction_isnonzero_vec
(v)
dask/array/routines.py:2117
↓ 1 callersFunction_join_path
(*path)
dask/dataframe/io/parquet/utils.py:369
↓ 1 callersFunction_key
(i, j)
dask/array/linalg.py:1160
↓ 1 callersMethod_layer
(self)
dask/dataframe/dask_expr/_indexing.py:296
↓ 1 callersMethod_layer
(self)
dask/dataframe/dask_expr/_shuffle.py:562
↓ 1 callersFunction_load
(x)
dask/dataframe/dask_expr/io/tests/test_delayed.py:65
↓ 1 callersFunction_load_config_file
A helper for loading a config file from a path, and erroring appropriately if the file is malformed.
dask/config.py:175
↓ 1 callersMethod_loc
(self, iindexer, cindexer)
dask/dataframe/dask_expr/_indexing.py:88
↓ 1 callersMethod_loc_array
(self, iindexer, cindexer)
dask/dataframe/dask_expr/_indexing.py:144
↓ 1 callersMethod_loc_element
(self, iindexer, cindexer)
dask/dataframe/dask_expr/_indexing.py:167
↓ 1 callersMethod_loc_slice
(self, iindexer, cindexer)
dask/dataframe/dask_expr/_indexing.py:157
↓ 1 callersFunction_local_functions
()
dask/tests/test_tokenize.py:402
↓ 1 callersMethod_lower
(self)
dask/_expr.py:529
↓ 1 callersMethod_lower
(self)
dask/dataframe/dask_expr/_groupby.py:448
↓ 1 callersMethod_lower
(self)
dask/dataframe/dask_expr/_repartition.py:84
↓ 1 callersMethod_lower
(self)
dask/dataframe/dask_expr/_merge.py:286
↓ 1 callersFunction_make_api
(attr)
dask/array/random.py:1054
↓ 1 callersFunction_make_api
(attr)
dask/array/_array_expr/random.py:1068
↓ 1 callersFunction_make_mimesis
Make a Dask Bag filled with data randomly generated by the mimesis project Parameters ---------- field: dict keyword argumen
dask/datasets.py:96
↓ 1 callersMethod_make_timeseries_part
(self)
dask/dataframe/dask_expr/datasets.py:73
↓ 1 callersFunction_match
Structural matching of term S to discrimination net node N.
dask/rewrite.py:374
↓ 1 callersFunction_max
(seq)
dask/utils.py:2095
↓ 1 callersFunction_maybe_adjust_cpu_count
()
dask/dataframe/dask_expr/io/parquet.py:81
↓ 1 callersFunction_maybe_len
(l)
dask/array/tests/test_routines.py:1451
↓ 1 callersFunction_maybe_partial_time_string
Convert indexer for partial string selection if data has DatetimeIndex/PeriodIndex
dask/dataframe/indexing.py:80
↓ 1 callersMethod_maybe_partial_time_string
Convert index-indexer for partial time string slicing if obj.index is DatetimeIndex / PeriodIndex
dask/dataframe/dask_expr/_indexing.py:148
← previousnext →1,301–1,400 of 9,157, ranked by callers