From e7df293946031becaf4adf04feb31c7c80c4de73 Mon Sep 17 00:00:00 2001 From: Devin Petersohn Date: Tue, 27 Feb 2018 21:44:33 -0800 Subject: [PATCH] [DataFrames] Updating Error messages to encourage contribution. (#1623) --- python/ray/dataframe/__init__.py | 2 +- python/ray/dataframe/dataframe.py | 824 +++++++++++++++----- python/ray/dataframe/test/test_dataframe.py | 2 + 3 files changed, 621 insertions(+), 207 deletions(-) diff --git a/python/ray/dataframe/__init__.py b/python/ray/dataframe/__init__.py index 6edc2804d..0bce77403 100644 --- a/python/ray/dataframe/__init__.py +++ b/python/ray/dataframe/__init__.py @@ -3,7 +3,7 @@ from __future__ import division from __future__ import print_function import threading -DEFAULT_NPARTITIONS = 10 +DEFAULT_NPARTITIONS = 4 def set_npartition_default(n): diff --git a/python/ray/dataframe/dataframe.py b/python/ray/dataframe/dataframe.py index 32ea12d11..1b6a73a43 100644 --- a/python/ray/dataframe/dataframe.py +++ b/python/ray/dataframe/dataframe.py @@ -453,18 +453,26 @@ class DataFrame(object): raise ValueError(" not correctly set.") def add(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def agg(self, func, axis=0, *args, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def aggregate(self, func, axis=0, *args, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def align(self, other, join='outer', axis=None, level=None, copy=True, fill_value=None, method=None, limit=None, fill_axis=0, broadcast_axis=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def all(self, axis=None, bool_only=None, skipna=None, level=None, **kwargs): @@ -509,40 +517,62 @@ class DataFrame(object): return to_pandas(mapped) def append(self, other, ignore_index=False, verify_integrity=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def apply(self, func, axis=0, broadcast=False, raw=False, reduce=None, args=(), **kwds): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def as_blocks(self, copy=True): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def as_matrix(self, columns=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def asfreq(self, freq, method=None, how=None, normalize=False, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def asof(self, where, subset=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def assign(self, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def astype(self, dtype, copy=True, errors='raise', **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def at_time(self, time, asof=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def between_time(self, start_time, end_time, include_start=True, include_end=True): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def bfill(self, axis=None, inplace=False, limit=None, downcast=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def bool(self): """Return the bool of a single element PandasObject. @@ -564,39 +594,61 @@ class DataFrame(object): def boxplot(self, column=None, by=None, ax=None, fontsize=None, rot=0, grid=True, figsize=None, layout=None, return_type=None, **kwds): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def clip(self, lower=None, upper=None, axis=None, inplace=False, *args, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def clip_lower(self, threshold, axis=None, inplace=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def clip_upper(self, threshold, axis=None, inplace=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def combine(self, other, func, fill_value=None, overwrite=True): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def combine_first(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def compound(self, axis=None, skipna=None, level=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def consolidate(self, inplace=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def convert_objects(self, convert_dates=True, convert_numeric=False, convert_timedeltas=True, copy=True): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def corr(self, method='pearson', min_periods=1): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def corrwith(self, other, axis=0, drop=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def count(self, axis=0, level=None, numeric_only=False): if axis == 1: @@ -619,47 +671,75 @@ class DataFrame(object): return collapsed_df def cov(self, min_periods=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def cummax(self, axis=None, skipna=True, *args, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def cummin(self, axis=None, skipna=True, *args, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def cumprod(self, axis=None, skipna=True, *args, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def cumsum(self, axis=None, skipna=True, *args, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def describe(self, percentiles=None, include=None, exclude=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def diff(self, periods=1, axis=0): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def div(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def divide(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def dot(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def drop(self, labels=None, axis=0, index=None, columns=None, level=None, inplace=False, errors='raise'): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def drop_duplicates(self, subset=None, keep='first', inplace=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def duplicated(self, subset=None, keep='first'): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def eq(self, other, axis='columns', level=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def equals(self, other): """ @@ -695,55 +775,83 @@ class DataFrame(object): return True def eval(self, expr, inplace=False, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def ewm(self, com=None, span=None, halflife=None, alpha=None, min_periods=0, freq=None, adjust=True, ignore_na=False, axis=0): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def expanding(self, min_periods=1, freq=None, center=False, axis=0): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def ffill(self, axis=None, inplace=False, limit=None, downcast=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def fillna(self, value=None, method=None, axis=None, inplace=False, limit=None, downcast=None, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def filter(self, items=None, like=None, regex=None, axis=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def first(self, offset): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def first_valid_index(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def floordiv(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") @classmethod def from_csv(self, path, header=0, sep=', ', index_col=0, parse_dates=True, encoding=None, tupleize_cols=None, infer_datetime_format=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") @classmethod def from_dict(self, data, orient='columns', dtype=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") @classmethod def from_items(self, items, columns=None, orient='columns'): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") @classmethod def from_records(self, data, index=None, exclude=None, columns=None, coerce_float=False, nrows=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def ge(self, other, axis='columns', level=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def get(self, key, default=None): """Get item from object for given key (DataFrame column, Panel @@ -785,13 +893,19 @@ class DataFrame(object): ) def get_value(self, index, col, takeable=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def get_values(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def gt(self, other, axis='columns', level=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def head(self, n=5): """Get the first n rows of the dataframe. @@ -829,7 +943,9 @@ class DataFrame(object): def hist(self, data, column=None, by=None, grid=True, xlabelsize=None, xrot=None, ylabelsize=None, yrot=None, ax=None, sharex=False, sharey=False, figsize=None, layout=None, bins=10, **kwds): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def idxmax(self, axis=0, skipna=True): """Get the index of the first occurrence of the max value of the axis. @@ -874,11 +990,15 @@ class DataFrame(object): return self.T.idxmin(axis=1, skipna=skipna) def infer_objects(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def info(self, verbose=None, buf=None, max_cols=None, memory_usage=None, null_counts=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def insert(self, loc, column, value, allow_duplicates=False): """Insert column into DataFrame at specified location. @@ -930,7 +1050,9 @@ class DataFrame(object): def interpolate(self, method='linear', axis=0, limit=None, inplace=False, limit_direction='forward', downcast=None, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def iterrows(self): """Iterate over DataFrame rows as (index, Series) pairs. @@ -1020,37 +1142,57 @@ class DataFrame(object): def join(self, other, on=None, how='left', lsuffix='', rsuffix='', sort=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def kurt(self, axis=None, skipna=None, level=None, numeric_only=None, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def kurtosis(self, axis=None, skipna=None, level=None, numeric_only=None, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def last(self, offset): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def last_valid_index(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def le(self, other, axis='columns', level=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def lookup(self, row_labels, col_labels): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def lt(self, other, axis='columns', level=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def mad(self, axis=None, skipna=None, level=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def mask(self, cond, other=np.nan, inplace=False, axis=None, level=None, errors='raise', try_cast=False, raise_on_error=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def max(self, axis=None, skipna=None, level=None, numeric_only=None, **kwargs): @@ -1073,24 +1215,34 @@ class DataFrame(object): def mean(self, axis=None, skipna=None, level=None, numeric_only=None, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def median(self, axis=None, skipna=None, level=None, numeric_only=None, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def melt(self, id_vars=None, value_vars=None, var_name=None, value_name='value', col_level=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def memory_usage(self, index=True, deep=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def merge(self, right, how='inner', on=None, left_on=None, right_on=None, left_index=False, right_index=False, sort=False, suffixes=('_x', '_y'), copy=True, indicator=False, validate=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def min(self, axis=None, skipna=None, level=None, numeric_only=None, **kwargs): @@ -1112,22 +1264,34 @@ class DataFrame(object): numeric_only=numeric_only, **kwargs) def mod(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def mode(self, axis=0, numeric_only=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def mul(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def multiply(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def ne(self, other, axis='columns', level=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def nlargest(self, n, columns, keep='first'): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def notna(self): """Perform notna across the DataFrame. @@ -1154,25 +1318,37 @@ class DataFrame(object): return self._map_partitions(lambda df: df.notnull()) def nsmallest(self, n, columns, keep='first'): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def nunique(self, axis=0, dropna=True): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def pct_change(self, periods=1, fill_method='pad', limit=None, freq=None, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def pipe(self, func, *args, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def pivot(self, index=None, columns=None, values=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def pivot_table(self, values=None, index=None, columns=None, aggfunc='mean', fill_value=None, margins=False, dropna=True, margins_name='All'): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def plot(self, x=None, y=None, kind='line', ax=None, subplots=False, sharex=None, sharey=False, layout=None, figsize=None, @@ -1181,7 +1357,9 @@ class DataFrame(object): xlim=None, ylim=None, rot=None, fontsize=None, colormap=None, table=False, yerr=None, xerr=None, secondary_y=False, sort_columns=False, **kwds): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def pop(self, item): """Pops an item from this DataFrame and returns it. @@ -1200,19 +1378,27 @@ class DataFrame(object): return popped def pow(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def prod(self, axis=None, skipna=None, level=None, numeric_only=None, min_count=0, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def product(self, axis=None, skipna=None, level=None, numeric_only=None, min_count=0, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def quantile(self, q=0.5, axis=0, numeric_only=True, interpolation='linear'): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def query(self, expr, inplace=False, **kwargs): """Queries the Dataframe with a boolean expression @@ -1229,46 +1415,68 @@ class DataFrame(object): return DataFrame(new_dfs, self.columns) def radd(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def rank(self, axis=0, method='average', numeric_only=None, na_option='keep', ascending=True, pct=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def rdiv(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def reindex(self, labels=None, index=None, columns=None, axis=None, method=None, copy=True, level=None, fill_value=np.nan, limit=None, tolerance=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def reindex_axis(self, labels, axis=0, method=None, level=None, copy=True, limit=None, fill_value=np.nan): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def reindex_like(self, other, method=None, copy=True, limit=None, tolerance=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def rename(self, mapper=None, index=None, columns=None, axis=None, copy=True, inplace=False, level=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def rename_axis(self, mapper, axis=0, copy=True, inplace=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def reorder_levels(self, order, axis=0): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def replace(self, to_replace=None, value=None, inplace=False, limit=None, regex=False, method='pad', axis=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def resample(self, rule, how=None, axis=0, fill_method=None, closed=None, label=None, convention='start', kind=None, loffset=None, limit=None, base=0, on=None, level=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def reset_index(self, level=None, drop=False, inplace=False, col_level=0, col_fill=''): @@ -1372,17 +1580,25 @@ class DataFrame(object): return new_obj def rfloordiv(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def rmod(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def rmul(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def rolling(self, window, min_periods=None, freq=None, center=False, win_type=None, on=None, axis=0, closed=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def round(self, decimals=0, *args, **kwargs): return self._map_partitions(lambda df: df.round(decimals=decimals, @@ -1390,27 +1606,41 @@ class DataFrame(object): **kwargs)) def rpow(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def rsub(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def rtruediv(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def sample(self, n=None, frac=None, replace=False, weights=None, random_state=None, axis=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def select(self, crit, axis=0): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def select_dtypes(self, include=None, exclude=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def sem(self, axis=None, skipna=None, level=None, ddof=1, numeric_only=None, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def set_axis(self, labels, axis=0, inplace=None): """Assign desired index to given axis. @@ -1525,52 +1755,80 @@ class DataFrame(object): return frame def set_value(self, index, col, value, takeable=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def shift(self, periods=1, freq=None, axis=0): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def skew(self, axis=None, skipna=None, level=None, numeric_only=None, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def slice_shift(self, periods=1, axis=0): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def sort_index(self, axis=0, level=None, ascending=True, inplace=False, kind='quicksort', na_position='last', sort_remaining=True, by=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def sort_values(self, by, axis=0, ascending=True, inplace=False, kind='quicksort', na_position='last'): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def sortlevel(self, level=0, axis=0, ascending=True, inplace=False, sort_remaining=True): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def squeeze(self, axis=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def stack(self, level=-1, dropna=True): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def std(self, axis=None, skipna=None, level=None, ddof=1, numeric_only=None, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def sub(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def subtract(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def swapaxes(self, axis1, axis2, copy=True): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def swaplevel(self, i=-2, j=-1, axis=0): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def tail(self, n=5): """Get the last n rows of the dataframe. @@ -1608,10 +1866,14 @@ class DataFrame(object): return DataFrame(new_dfs, self.columns, index=index) def take(self, indices, axis=0, convert=None, is_copy=True, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_clipboard(self, excel=None, sep=None, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_csv(self, path_or_buf=None, sep=', ', na_rep='', float_format=None, columns=None, header=True, index=True, index_label=None, @@ -1619,31 +1881,45 @@ class DataFrame(object): quotechar='"', line_terminator='\n', chunksize=None, tupleize_cols=None, date_format=None, doublequote=True, escapechar=None, decimal='.'): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_dense(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_dict(self, orient='dict', into=dict): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_excel(self, excel_writer, sheet_name='Sheet1', na_rep='', float_format=None, columns=None, header=True, index=True, index_label=None, startrow=0, startcol=0, engine=None, merge_cells=True, encoding=None, inf_rep='inf', verbose=True, freeze_panes=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_feather(self, fname): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_gbq(self, destination_table, project_id, chunksize=10000, verbose=True, reauth=False, if_exists='fail', private_key=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_hdf(self, path_or_buf, key, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_html(self, buf=None, columns=None, col_space=None, header=True, index=True, na_rep='np.NaN', formatters=None, @@ -1651,12 +1927,16 @@ class DataFrame(object): justify=None, bold_rows=True, classes=None, escape=True, max_rows=None, max_cols=None, show_dimensions=False, notebook=False, decimal='.', border=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_json(self, path_or_buf=None, orient=None, date_format=None, double_precision=10, force_ascii=True, date_unit='ms', default_handler=None, lines=False, compression=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_latex(self, buf=None, columns=None, col_space=None, header=True, index=True, na_rep='np.NaN', formatters=None, @@ -1664,88 +1944,136 @@ class DataFrame(object): bold_rows=False, column_format=None, longtable=None, escape=None, encoding=None, decimal='.', multicolumn=None, multicolumn_format=None, multirow=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_msgpack(self, path_or_buf=None, encoding='utf-8', **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_panel(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_parquet(self, fname, engine='auto', compression='snappy', **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_period(self, freq=None, axis=0, copy=True): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_pickle(self, path, compression='infer', protocol=4): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_records(self, index=True, convert_datetime64=True): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_sparse(self, fill_value=None, kind='block'): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_sql(self, name, con, flavor=None, schema=None, if_exists='fail', index=True, index_label=None, chunksize=None, dtype=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_stata(self, fname, convert_dates=None, write_index=True, encoding='latin-1', byteorder=None, time_stamp=None, data_label=None, variable_labels=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_string(self, buf=None, columns=None, col_space=None, header=True, index=True, na_rep='np.NaN', formatters=None, float_format=None, sparsify=None, index_names=True, justify=None, line_width=None, max_rows=None, max_cols=None, show_dimensions=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_timestamp(self, freq=None, how='start', axis=0, copy=True): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def to_xarray(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def transform(self, func, *args, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def truediv(self, other, axis='columns', level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def truncate(self, before=None, after=None, axis=None, copy=True): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def tshift(self, periods=1, freq=None, axis=0): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def tz_convert(self, tz, axis=0, level=None, copy=True): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def tz_localize(self, tz, axis=0, level=None, copy=True, ambiguous='raise'): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def unstack(self, level=-1, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def update(self, other, join='left', overwrite=True, filter_func=None, raise_conflict=False): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def var(self, axis=None, skipna=None, level=None, ddof=1, numeric_only=None, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def where(self, cond, other=np.nan, inplace=False, axis=None, level=None, errors='raise', try_cast=False, raise_on_error=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def xs(self, key, axis=0, level=None, drop_level=True): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __getitem__(self, key): """Get the column specified by key for this DataFrame. @@ -1761,19 +2089,29 @@ class DataFrame(object): return to_pandas(result_column_chunks) def __setitem__(self, key, value): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __len__(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __unicode__(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __invert__(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __hash__(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __iter__(self): """Iterate over the columns @@ -1787,10 +2125,14 @@ class DataFrame(object): return key in self.columns def __nonzero__(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __bool__(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __abs__(self): """Creates a modified DataFrame by elementwise taking the absolute value @@ -1801,19 +2143,29 @@ class DataFrame(object): return self.abs() def __round__(self, decimals=0): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __array__(self, dtype=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __array_wrap__(self, result, context=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __getstate__(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __setstate__(self, state): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __delitem__(self, key): """Delete an item by key. `del a[key]` for example. @@ -1829,7 +2181,9 @@ class DataFrame(object): self.columns = self.columns.drop(key) def __finalize__(self, other, method=None, **kwargs): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __copy__(self, deep=True): """Make a copy using Ray.DataFrame.copy method @@ -1856,25 +2210,39 @@ class DataFrame(object): return self.copy(deep=True) def __and__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __or__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __xor__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __lt__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __le__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __gt__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __ge__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __eq__(self, other): """Computes the equality of this DataFrame with another @@ -1893,28 +2261,44 @@ class DataFrame(object): return not self.equals(other) def __add__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __iadd__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __mul__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __imul__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __pow__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __ipow__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __sub__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __isub__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __neg__(self): """Computes an element wise negative DataFrame @@ -1932,34 +2316,52 @@ class DataFrame(object): return self._map_partitions(lambda df: df.__neg__()) def __floordiv__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __truediv__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __mod__(self, other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __sizeof__(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") @property def __doc__(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") @property def blocks(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") @property def style(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def iat(axis=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __rsub__(other, axis=None, level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") @property def loc(self): @@ -1973,19 +2375,29 @@ class DataFrame(object): @property def is_copy(self): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __itruediv__(other): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def __div__(other, axis=None, level=None, fill_value=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def at(axis=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") def ix(axis=None): - raise NotImplementedError("Not Yet implemented.") + raise NotImplementedError( + "To contribute to Pandas on Ray, please visit " + "github.com/ray-project/ray.") @property def iloc(self): diff --git a/python/ray/dataframe/test/test_dataframe.py b/python/ray/dataframe/test/test_dataframe.py index 64567ffdf..a48387df4 100644 --- a/python/ray/dataframe/test/test_dataframe.py +++ b/python/ray/dataframe/test/test_dataframe.py @@ -7,6 +7,8 @@ import numpy as np import pandas as pd import ray.dataframe as rdf +ray.init() + @pytest.fixture def ray_df_equals_pandas(ray_df, pandas_df):