Upgrading dask 0.6 to 0.7
Unknown0.6.1 → 0.7.6
UnknownUpgrade verdict
None of the 7 releases in this range publish notes, so breaking changes can't be ruled out.
In plain terms
- Some releases in this range publish no notes, so DepDelta can't rule out breaking changes.
- Their commits are listed with this comparison.
Must act Unknown for releases without notes
Releases without notes may still need changes. Check their commits before upgrading.
API changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- removed:
export do - removed:
export get - removed:
export istask - removed:
export set_options - removed:
export value
- added:
export array - added:
export compress - added:
export cov - added:
export dot - added:
export dstack - added:
export fft - added:
export from_imperative - added:
export from_npy_stack - added:
export hstack - added:
export ravel - added:
export reshape - added:
export to_npy_stack - added:
export vstack
- added:
function compute_broadcast(expr, *data, **kwargs) - added:
function compute_it(expr, leaves, *data, **kwargs) - added:
function compute_up(expr, data, **kwargs) - added:
function elemwise_array(expr, *data, **kwargs) - added:
function optimize_array(expr, *data)
- added:
function pytest_ignore_collect(path, config)
- removed:
function compute(*args, **kwargs) - removed:
function get(dsk, keys, get=…, **kwargs) - removed:
function many(a, b, binop=…, reduction=…, **kwargs) - removed:
method Array.compute(**kwargs) - removed:
variable concatenate_names - removed:
variable fromfunction_names - removed:
variable names - removed:
variable stacked_names - removed:
variable tokens - changed:
class Array(object) → class Array(Base) - changed:
function broadcast_dimensions(argpairs, numblocks, sentinels=…) → function broadcast_dimensions(argpairs, numblocks, sentinels=…, consolidate=…) - changed:
function map_blocks(func, *arrs, **kwargs) → function map_blocks(func, *args, **kwargs) - changed:
method Array.all(axis=…, keepdims=…) → method Array.all(axis=…, keepdims=…, split_every=…) - changed:
method Array.any(axis=…, keepdims=…) → method Array.any(axis=…, keepdims=…, split_every=…) - changed:
method Array.argmax(axis=…) → method Array.argmax(axis=…, split_every=…) - changed:
method Array.argmin(axis=…) → method Array.argmin(axis=…, split_every=…) - changed:
method Array.map_blocks(func, chunks=…, dtype=…) → method Array.map_blocks(func, *args, **kwargs) - changed:
method Array.max(axis=…, keepdims=…) → method Array.max(axis=…, keepdims=…, split_every=…) - changed:
method Array.mean(axis=…, dtype=…, keepdims=…) → method Array.mean(axis=…, dtype=…, keepdims=…, split_every=…) - changed:
method Array.min(axis=…, keepdims=…) → method Array.min(axis=…, keepdims=…, split_every=…) - changed:
method Array.moment(order, axis=…, dtype=…, keepdims=…, ddof=…) → method Array.moment(order, axis=…, dtype=…, keepdims=…, ddof=…, split_every=…) - changed:
method Array.prod(axis=…, dtype=…, keepdims=…) → method Array.prod(axis=…, dtype=…, keepdims=…, split_every=…) - changed:
method Array.std(axis=…, dtype=…, keepdims=…, ddof=…) → method Array.std(axis=…, dtype=…, keepdims=…, ddof=…, split_every=…) - changed:
method Array.sum(axis=…, dtype=…, keepdims=…) → method Array.sum(axis=…, dtype=…, keepdims=…, split_every=…) - changed:
method Array.var(axis=…, dtype=…, keepdims=…, ddof=…) → method Array.var(axis=…, dtype=…, keepdims=…, ddof=…, split_every=…) - changed:
method Array.vnorm(ord=…, axis=…, keepdims=…) → method Array.vnorm(ord=…, axis=…, keepdims=…, split_every=…) - added:
field Array.flatten - added:
function array(x, dtype=…, ndmin=…) - added:
function asarray(array) - added:
function atleast_2d(x) - added:
function atleast_3d(x) - added:
function broadcast_chunks(*chunkss) - added:
function broadcast_shapes(*shapes) - added:
function common_blockdim(blockdims) - added:
function compress(condition, a, axis=…) - added:
function cov(m, y=…, rowvar=…, bias=…, ddof=…) - added:
function dot(a, b) - added:
function dstack(tup) - added:
function ensure_int(f) - added:
function finalize(results) - added:
function from_imperative(value, shape, dtype=…, name=…) - added:
function from_npy_stack(dirname, mmap_mode=…) - added:
function hstack(tup) - added:
function interleave_none(a, b) - added:
function is_scalar_for_elemwise(arg) - added:
function keyname(name, i, okey) - added:
function ravel(array) - added:
function reshape(array, shape) - added:
function to_npy_stack(dirname, x, axis=…) - added:
function unify_chunks(*args) - added:
function unravel(array, shape) - added:
function vstack(tup) - added:
method Array.conj() - added:
method Array.ravel() - added:
method Array.reshape(*shape) - added:
method Array.view(dtype, order=…) - added:
property Array.imag - added:
property Array.real - added:
property Array.vindex
- added:
variable chunk_error - added:
variable fft - added:
variable fft_preamble - added:
variable hfft - added:
variable ifft - added:
variable ihfft - added:
variable irfft - added:
variable rfft
- removed:
variable ghost_names - added:
function add_dummy_padding(x, depth, boundary) - added:
function coerce_boundary(ndim, boundary) - added:
function coerce_depth(ndim, depth)
- added:
function add_leading_dimension(x) - added:
function imread(filename, imread=…, preprocess=…)
- added:
function array_to_dask(x, name=…, blockshape=…, **kwargs) - added:
function dask_to_float(x, **kwargs) - added:
function dask_to_numpy(x, **kwargs) - added:
function discover_dask_array(a, **kwargs) - added:
function resize(x, size) - added:
function store_Array_in_ooc_data(out, arr, inplace=…, **kwargs) - added:
variable arrays
- removed:
variable names - changed:
function compression_matrix(data, q, n_power_iter=…) → function compression_matrix(data, q, n_power_iter=…, seed=…) - changed:
function svd_compressed(a, k, n_power_iter=…, name=…) → function svd_compressed(a, k, n_power_iter=…, seed=…, name=…)
- changed:
function remove_full_slices(dsk) → function remove_full_slices(dsk, keys)
- removed:
method RandomState.choice(a, size=…, replace=…, p=…, chunks=…)
- removed:
variable rechunk_names
- removed:
function arg_aggregate(func, argfunc, dims, pairs) - removed:
function argmax(a, axis=…) - removed:
function argmin(a, axis=…) - removed:
function nanargmax(a, axis=…) - removed:
function nanargmin(a, axis=…) - changed:
function all(a, axis=…, keepdims=…) → function all(a, axis=…, keepdims=…, split_every=…) - changed:
function any(a, axis=…, keepdims=…) → function any(a, axis=…, keepdims=…, split_every=…) - changed:
function arg_reduction(a, func, argfunc, axis=…, dtype=…) → function arg_reduction(func, argfunc) - changed:
function max(a, axis=…, keepdims=…) → function max(a, axis=…, keepdims=…, split_every=…) - changed:
function mean(a, axis=…, dtype=…, keepdims=…) → function mean(a, axis=…, dtype=…, keepdims=…, split_every=…) - changed:
function min(a, axis=…, keepdims=…) → function min(a, axis=…, keepdims=…, split_every=…) - changed:
function moment(a, order, axis=…, dtype=…, keepdims=…, ddof=…) → function moment(a, order, axis=…, dtype=…, keepdims=…, ddof=…, split_every=…) - changed:
function moment_agg(data, order=…, ddof=…, dtype=…, **kwargs) → function moment_agg(data, order=…, ddof=…, dtype=…, sum=…, **kwargs) - changed:
function nanmax(a, axis=…, keepdims=…) → function nanmax(a, axis=…, keepdims=…, split_every=…) - changed:
function nanmean(a, axis=…, dtype=…, keepdims=…) → function nanmean(a, axis=…, dtype=…, keepdims=…, split_every=…) - changed:
function nanmin(a, axis=…, keepdims=…) → function nanmin(a, axis=…, keepdims=…, split_every=…) - changed:
function nanstd(a, axis=…, dtype=…, keepdims=…, ddof=…) → function nanstd(a, axis=…, dtype=…, keepdims=…, ddof=…, split_every=…) - changed:
function nansum(a, axis=…, dtype=…, keepdims=…) → function nansum(a, axis=…, dtype=…, keepdims=…, split_every=…) - changed:
function nanvar(a, axis=…, dtype=…, keepdims=…, ddof=…) → function nanvar(a, axis=…, dtype=…, keepdims=…, ddof=…, split_every=…) - changed:
function prod(a, axis=…, dtype=…, keepdims=…) → function prod(a, axis=…, dtype=…, keepdims=…, split_every=…) - changed:
function reduction(x, chunk, aggregate, axis=…, keepdims=…, dtype=…) → function reduction(x, chunk, aggregate, axis=…, keepdims=…, dtype=…, split_every=…, combine=…) - changed:
function std(a, axis=…, dtype=…, keepdims=…, ddof=…) → function std(a, axis=…, dtype=…, keepdims=…, ddof=…, split_every=…) - changed:
function sum(a, axis=…, dtype=…, keepdims=…) → function sum(a, axis=…, dtype=…, keepdims=…, split_every=…) - changed:
function var(a, axis=…, dtype=…, keepdims=…, ddof=…) → function var(a, axis=…, dtype=…, keepdims=…, ddof=…, split_every=…) - changed:
function vnorm(a, ord=…, axis=…, dtype=…, keepdims=…) → function vnorm(a, ord=…, axis=…, dtype=…, keepdims=…, split_every=…) - added:
function arg_agg(func, argfunc, data, axis=…, **kwargs) - added:
function arg_chunk(func, argfunc, x, axis=…, **kwargs) - added:
function arg_combine(func, argfunc, data, axis=…, **kwargs) - added:
function mean_combine(pair, sum=…, numel=…, dtype=…, **kwargs) - added:
function moment_combine(data, order=…, ddof=…, dtype=…, sum=…, **kwargs) - added:
function partial_reduce(func, x, split_every, keepdims=…, dtype=…, name=…) - added:
variable argmax - added:
variable argmin - added:
variable nanargmax - added:
variable nanargmin
- removed:
function sanitize_index_elements(ind) - removed:
variable slice_names - added:
function sanitize_index(ind)
- removed:
variable names
- changed:
function get_async(apply_async, num_workers, dsk, result, cache=…, queue=…, get_id=…, raise_on_exception=…, start_callback=…, end_callback=…, rerun_exceptions_locally=…, **kwargs) → function get_async(apply_async, num_workers, dsk, result, cache=…, queue=…, get_id=…, raise_on_exception=…, rerun_exceptions_locally=…, callbacks=…, **kwargs) - changed:
function nested_get(ind, coll, lazy=…) → function nested_get(ind, coll) - added:
class RemoteException(Exception) - added:
constructor RemoteException(exception, traceback) - added:
function remote_exception(exc, tb) - added:
variable exceptions
- added:
export compute - added:
export from_castra
- removed:
function get(dsk, keys, get=…, **kwargs) - removed:
function list2(seq) - removed:
function takes_multiple_arguments(func) - removed:
method Bag.compute(**kwargs) - removed:
method Item.compute(**kwargs) - removed:
variable opens - changed:
class Bag(object) → class Bag(Base) - changed:
class Item(object) → class Item(Base) - changed:
function from_filenames(filenames, chunkbytes=…) → function from_filenames(filenames, chunkbytes=…, compression=…, encoding=…, linesep=…) - changed:
function optimize(dsk, keys) → function optimize(dsk, keys, **kwargs) - changed:
function to_textfiles(b, path, name_function=…) → function to_textfiles(b, path, name_function=…, compression=…, encoding=…) - changed:
function write(data, filename) → function write(data, filename, compression, encoding) - changed:
method Bag.to_textfiles(path, name_function=…) → method Bag.to_textfiles(path, name_function=…, compression=…, encoding=…) - added:
function finalize(results) - added:
function finalize_item(results) - added:
function from_castra(x, columns=…, index=…) - added:
function load_castra_partition(castra, part, columns, index)
- added:
function bag_to_iterator(x, **kwargs)
- added:
class Base(object) - added:
function compute(*args, **kwargs) - added:
function tokenize(*args, **kwargs) - added:
function visualize(*args, **kwargs) - added:
method Base.compute(**kwargs) - added:
method Base.visualize(filename=…, format=…, optimize_graph=…, **kwargs) - added:
variable normalize_token
- added:
class Cache(Callback) - added:
constructor Cache(cache, *args, **kwargs) - added:
variable overhead
- added:
class Callback(object) - added:
class add_callbacks(object) - added:
constructor Callback(start=…, pretask=…, posttask=…, finish=…) - added:
constructor add_callbacks(*args) - added:
method Callback.register() - added:
method Callback.unregister()
- added:
class BZ2File(BufferedIOBase) - added:
class GzipFile(BufferedIOBase) - added:
constructor BZ2File(*args, **kwargs) - added:
constructor GzipFile(*args, **kwargs) - added:
function bind_method(cls, name, func) - added:
function getargspec(func) - added:
method BZ2File.close() - added:
method BZ2File.flush() - added:
method BZ2File.isatty() - added:
method BZ2File.read(*args, **kwargs) - added:
method BZ2File.read1(*args, **kwargs) - added:
method BZ2File.readable() - added:
method BZ2File.readline(*args, **kwargs) - added:
method BZ2File.readlines(*args, **kwargs) - added:
method BZ2File.seek(*args, **kwargs) - added:
method BZ2File.seekable() - added:
method BZ2File.tell() - added:
method BZ2File.truncate(*args, **kwargs) - added:
method BZ2File.writable() - added:
method BZ2File.write(*args, **kwargs) - added:
method BZ2File.writelines(*args, **kwargs) - added:
method GzipFile.close() - added:
method GzipFile.flush(*args, **kwargs) - added:
method GzipFile.isatty() - added:
method GzipFile.read(*args, **kwargs) - added:
method GzipFile.read1(*args, **kwargs) - added:
method GzipFile.readable() - added:
method GzipFile.readline(*args, **kwargs) - added:
method GzipFile.readlines(*args, **kwargs) - added:
method GzipFile.seek(*args, **kwargs) - added:
method GzipFile.seekable() - added:
method GzipFile.tell() - added:
method GzipFile.truncate(*args, **kwargs) - added:
method GzipFile.writable() - added:
method GzipFile.write(*args, **kwargs) - added:
method GzipFile.writelines(*args, **kwargs) - added:
property BZ2File.closed - added:
property GzipFile.closed - added:
variable BZ2File - added:
variable GzipFile - added:
variable operator_div
- changed:
function get(d, key, get=…, concrete=…, **kwargs) → function get(d, key, get=…, **kwargs) - added:
function list2(L) - added:
function quote(x)
- added:
export compute - added:
export demo - added:
export from_castra - added:
export rolling_apply - added:
export rolling_count - added:
export rolling_kurt - added:
export rolling_max - added:
export rolling_mean - added:
export rolling_median - added:
export rolling_min - added:
export rolling_quantile - added:
export rolling_skew - added:
export rolling_std - added:
export rolling_sum - added:
export rolling_var - added:
export rolling_window
- added:
class Accessor(object) - added:
class DataFrame(_Frame) - added:
class DatetimeAccessor(Accessor) - added:
class GroupBy(_GroupBy) - added:
class Index(Series) - added:
class Scalar(Base) - added:
class Series(_Frame) - added:
class SeriesGroupBy(_GroupBy) - added:
class StringAccessor(Accessor) - added:
constructor Accessor(series) - added:
constructor GroupBy(df, index=…, key=…, **kwargs) - added:
constructor Scalar(dsk, _name, name=…, divisions=…) - added:
constructor SeriesGroupBy(df, index, key=…, **kwargs) - added:
field DatetimeAccessor.ns - added:
field StringAccessor.ns - added:
function apply_concat_apply(args, chunk=…, aggregate=…, columns=…, token=…) - added:
function categorize(df, columns=…, **kwargs) - added:
function categorize_block(df, categories) - added:
function elemwise(op, *args, **kwargs) - added:
function elemwise_property(attr, s) - added:
function empty_safe(func, arg) - added:
function finalize(results) - added:
function map_partitions(func, columns, *args, **kwargs) - added:
function nlargest(df, n=…, columns=…) - added:
function optimize(dsk, keys, **kwargs) - added:
function pd_split(df, p, random_state=…) - added:
function quantile(df, q) - added:
function reduction(x, chunk, aggregate, token=…) - added:
function remove_empties(seq) - added:
function repartition(df, divisions, force=…) - added:
function repartition_divisions(a, b, name, out1, out2, force=…) - added:
method DataFrame.append(other) - added:
method DataFrame.apply(func, axis=…, args=…, columns=…, **kwds) - added:
method DataFrame.assign(**kwargs) - added:
method DataFrame.categorize(columns=…, **kwargs) - added:
method DataFrame.drop(labels, axis=…) - added:
method DataFrame.dropna(how=…, subset=…) - added:
method DataFrame.groupby(key, **kwargs) - added:
method DataFrame.iterrows() - added:
method DataFrame.itertuples() - added:
method DataFrame.join(other, on=…, how=…, lsuffix=…, rsuffix=…, npartitions=…) - added:
method DataFrame.merge(right, how=…, on=…, left_on=…, right_on=…, left_index=…, right_index=…, suffixes=…, npartitions=…) - added:
method DataFrame.nlargest(n=…, columns=…) - added:
method DataFrame.query(expr, **kwargs) - added:
method DataFrame.rename(index=…, columns=…) - added:
method DataFrame.reset_index() - added:
method DataFrame.set_index(other, **kwargs) - added:
method DataFrame.set_partition(column, divisions, **kwargs) - added:
method DataFrame.to_bag(index=…) - added:
method DataFrame.to_castra(fn=…, categories=…, sorted_index_column=…, compute=…) - added:
method GroupBy.apply(func, columns=…) - added:
method Index.count() - added:
method Index.max() - added:
method Index.min() - added:
method Index.nunique() - added:
method Series.apply(func, convert_dtype=…, name=…, args=…, **kwds) - added:
method Series.astype(dtype) - added:
method Series.between(left, right, inclusive=…) - added:
method Series.clip(lower=…, upper=…) - added:
method Series.count() - added:
method Series.cummax(axis=…, skipna=…) - added:
method Series.cummin(axis=…, skipna=…) - added:
method Series.cumprod(axis=…, skipna=…) - added:
method Series.cumsum(axis=…, skipna=…) - added:
method Series.dropna() - added:
method Series.dt() - added:
method Series.groupby(index, **kwargs) - added:
method Series.isin(other) - added:
method Series.iteritems() - added:
method Series.map(arg, na_action=…) - added:
method Series.max(axis=…, skipna=…) - added:
method Series.mean(axis=…, skipna=…) - added:
method Series.min(axis=…, skipna=…) - added:
method Series.nlargest(n=…) - added:
method Series.notnull() - added:
method Series.nunique() - added:
method Series.quantile(q=…) - added:
method Series.resample(rule, how=…, axis=…, fill_method=…, closed=…, label=…, convention=…, kind=…, loffset=…, limit=…, base=…) - added:
method Series.std(axis=…, ddof=…, skipna=…) - added:
method Series.str() - added:
method Series.sum(axis=…, skipna=…) - added:
method Series.to_bag(index=…) - added:
method Series.to_frame(name=…) - added:
method Series.value_counts() - added:
method Series.var(axis=…, ddof=…, skipna=…) - added:
method SeriesGroupBy.apply(func, columns=…) - added:
method SeriesGroupBy.nunique() - added:
property DataFrame.column_info - added:
property DataFrame.dtypes - added:
property DataFrame.ndim - added:
property GroupBy.column_info - added:
property Index.index - added:
property Series.column_info - added:
property Series.columns - added:
property Series.dtype - added:
property Series.nbytes - added:
property Series.ndim - added:
property SeriesGroupBy.column_info - added:
static method DatetimeAccessor.call(obj, attr, *args) - added:
static method DatetimeAccessor.getattr(obj, attr) - added:
static method StringAccessor.call(obj, attr, *args) - added:
static method StringAccessor.getattr(obj, attr) - added:
variable Cache - added:
variable aca - added:
variable no_default - added:
variable return_scalar
- added:
function make_timeseries(start, end, dtypes, freq, partition_freq, seed=…)
- removed:
function categories_and_quantiles(fn, args, kwargs, index=…, categorize=…, chunkbytes=…) - removed:
function csv_names(fn, encoding=…, compression=…, names=…, parse_dates=…, usecols=…, dtype=…, **kwargs) - removed:
function dataframe_from_ctable(x, slc, columns=…, categories=…) - removed:
function fill_kwargs(fn, args, kwargs) - removed:
function from_array(x, chunksize=…, columns=…) - removed:
function from_bcolz(x, chunksize=…, categorize=…, index=…, **kwargs) - removed:
function from_dask_array(x, columns=…) - removed:
function from_pandas(data, npartitions) - removed:
function infer_header(fn, encoding=…, compression=…, **kwargs) - removed:
function read_csv(fn, *args, **kwargs) - removed:
function read_hdf(path_or_buf, key, start=…, stop=…, columns=…, chunksize=…) - removed:
function to_castra(df, fn=…, categories=…) - removed:
function to_csv(df, filename, **kwargs) - removed:
function to_hdf(df, path_or_buf, key, mode=…, append=…, complevel=…, complib=…, fletcher32=…, **kwargs) - removed:
variable csv_defaults - removed:
variable dont_use_fixed_error_message
- changed:
function concat_indexed_dataframes(dfs, join=…) → function concat_indexed_dataframes(dfs, axis=…, join=…) - changed:
function hash_join(lhs, on_left, rhs, on_right, how=…, npartitions=…, suffixes=…) → function hash_join(lhs, left_on, rhs, right_on, how=…, npartitions=…, suffixes=…) - changed:
function pdmerge(left, right, *args, **kwargs) → function pdmerge(left, right, how, left_on, right_on, left_index, right_index, suffixes, default_left_columns, default_right_columns) - added:
function concat(dfs, axis=…, join=…, interleave_partitions=…)
- removed:
variable a - removed:
variable b - removed:
variable c - removed:
variable d - removed:
variable e - removed:
variable fast_functions - removed:
variable rewrite_rules - removed:
variable rules - added:
function fuse_castra_index(dsk)
- added:
function rolling_chunk(func, part1, part2, window, *args) - added:
function wrap_rolling(func) - added:
variable rolling_apply - added:
variable rolling_count - added:
variable rolling_kurt - added:
variable rolling_max - added:
variable rolling_mean - added:
variable rolling_median - added:
variable rolling_min - added:
variable rolling_quantile - added:
variable rolling_skew - added:
variable rolling_std - added:
variable rolling_sum - added:
variable rolling_var - added:
variable rolling_window
- removed:
function get_categories(df) - removed:
function iscategorical(dt) - removed:
function shard_df_on_index(df, divisions) - removed:
function strip_categories(df) - removed:
function unique(divisions)
- removed:
export multiprocessing - removed:
export threaded - removed:
variable process_prof - removed:
variable thread_prof - added:
export CacheProfiler - added:
export ProgressBar - added:
export ResourceProfiler - added:
export visualize
- removed:
method Profiler.get(dsk, result, **kwargs) - removed:
method Profiler.results() - changed:
class Profiler(object) → class Profiler(Callback) - changed:
constructor Profiler(get) → constructor Profiler() - added:
class CacheProfiler(Callback) - added:
class ResourceProfiler(Callback) - added:
constructor CacheProfiler(metric=…, metric_name=…) - added:
constructor ResourceProfiler(dt=…) - added:
method CacheProfiler.clear() - added:
method CacheProfiler.visualize(**kwargs) - added:
method ResourceProfiler.clear() - added:
method ResourceProfiler.close() - added:
method ResourceProfiler.visualize(**kwargs) - added:
variable CacheData - added:
variable ResourceData
- changed:
function pprint_task(task, keys) → function pprint_task(task, keys, label_size=…) - changed:
function visualize(results, dsk, palette=…, file_path=…, show=…, **kwargs) → function visualize(profilers, file_path=…, show=…, save=…, **kwargs) - added:
function plot_cache(results, dsk, start_time, metric_name, palette=…, label_size=…, **kwargs) - added:
function plot_resources(results, palette=…, **kwargs) - added:
function plot_tasks(results, dsk, palette=…, label_size=…, **kwargs) - added:
function unquote(expr)
- added:
class ProgressBar(Callback) - added:
constructor ProgressBar(minimum=…, width=…, dt=…) - added:
function format_time(t)
- changed:
method Client.get(dsk, keys) → method Client.get(dsk, keys, keep_results=…)
- removed:
function funcname(func) - changed:
function dot_graph(dsk, filename=…, **kwargs) → function dot_graph(dsk, filename=…, format=…, **kwargs) - changed:
function to_graphviz(dsk, data_attributes=…, function_attributes=…) → function to_graphviz(dsk, data_attributes=…, function_attributes=…, **kwargs) - added:
function label(x, cache=…) - added:
variable IPYTHON_IMAGE_FORMATS - added:
variable IPYTHON_NO_DISPLAY_FORMATS
- removed:
method Value.compute(**kwargs) - removed:
method Value.visualize(optimize_graph=…, **kwargs) - changed:
class Value(object) → class Value(base.Base) - added:
function compute(*args, **kwargs)
- changed:
function dealias(dsk) → function dealias(dsk, keys=…) - changed:
function inline_functions(dsk, fast_functions=…, inline_constants=…) → function inline_functions(dsk, output, fast_functions=…, inline_constants=…) - added:
function fuse_getitem(dsk, func, place) - added:
function fuse_selections(dsk, head1, head2, merge) - added:
function identity(x)
- removed:
function getargspec(func) - changed:
function pseudorandom(n, p, key) → function pseudorandom(n, p, random_state=…) - changed:
function textblock(file, start, stop, compression=…) → function textblock(filename, start, end, compression=…, encoding=…, linesep=…, buffersize=…) - changed:
function tmpfile(extension=…) → function tmpfile(extension=…, dir=…) - added:
class Dispatch(object) - added:
constructor Dispatch() - added:
function derived_from(original_klass, version=…, ua_args=…) - added:
function different_seeds(n, random_state=…) - added:
function ensure_not_exists(filename) - added:
function funcname(func) - added:
function get_bin_linesep(encoding, linesep) - added:
function get_bom(fn, compression=…) - added:
function infer_compression(filename) - added:
function open(filename, mode=…, compression=…, **kwargs) - added:
function takes_multiple_arguments(func) - added:
method Dispatch.register(type, func) - added:
variable MULTI_ARITY_BUILTINS - added:
variable ONE_ARITY_BUILTINS - added:
variable compressions - added:
variable system_encoding
- added:
export PBag - added:
export dump - added:
export load
- added:
class PBag(object) - added:
constructor PBag(grouper, npartitions, path=…, open=…, dump=…, load=…) - added:
function isempty(seq) - added:
function partition_all(n, seq) - added:
method PBag.drop() - added:
method PBag.extend(seq) - added:
method PBag.extend_chunk(seq) - added:
method PBag.get_partition(i) - added:
method PBag.partition_of(item) - added:
variable global_chunksize
- added:
variable dump
- added:
export cframe - added:
export from_blocks - added:
export pframe - added:
export to_blocks
- added:
function categorical_metadata(df) - added:
function reapply_categories(df, metadata) - added:
function strip_categories(df)
- added:
class cframe(object) - added:
constructor cframe(df, rootdir=…, chunklen=…, **kwargs) - added:
method cframe.append(df) - added:
method cframe.drop() - added:
method cframe.flush() - added:
method cframe.head(n=…) - added:
method cframe.to_dataframe(columns=…) - added:
property cframe.cbytes - added:
property cframe.nbytes
- added:
function from_blocks(blocks, index, columns, placement) - added:
function to_blocks(df)
- added:
class pframe(object) - added:
constructor pframe(like, divisions, path=…, **kwargs) - added:
function shard_df_on_index(df, divisions) - added:
method pframe.append(df) - added:
method pframe.drop() - added:
method pframe.flush() - added:
method pframe.get_partition(i, columns=…, has_lock=…) - added:
method pframe.head(n=…) - added:
method pframe.to_dataframe() - added:
property pframe.cbytes - added:
property pframe.nbytes - added:
property pframe.npartitions
- added:
function ignoring(*exc) - added:
function raises(exc, lamda)