diff --git a/modin/pandas/dataframe.py b/modin/pandas/dataframe.py index 830f41d051a..9159c365526 100644 --- a/modin/pandas/dataframe.py +++ b/modin/pandas/dataframe.py @@ -961,7 +961,7 @@ def _aggregate(self, arg, *args, **kwargs): elif isinstance(arg, dict): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") elif is_list_like(arg): return self.apply(arg, axis=_axis, args=args, **kwargs) elif callable(arg): @@ -1094,7 +1094,7 @@ def align(self, other, join='outer', axis=None, level=None, copy=True, broadcast_axis=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def all(self, axis=None, bool_only=None, skipna=None, level=None, **kwargs): @@ -1242,7 +1242,7 @@ def apply(self, func, axis=0, broadcast=False, raw=False, reduce=None, def as_blocks(self, copy=True): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def as_matrix(self, columns=None): """Convert the frame to its Numpy-array representation. @@ -1261,17 +1261,17 @@ def asfreq(self, freq, method=None, how=None, normalize=False, fill_value=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def asof(self, where, subset=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def assign(self, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def astype(self, dtype, copy=True, errors='raise', **kwargs): if isinstance(dtype, dict): @@ -1314,13 +1314,13 @@ def astype(self, dtype, copy=True, errors='raise', **kwargs): def at_time(self, time, asof=False): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def between_time(self, start_time, end_time, include_start=True, include_end=True): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def bfill(self, axis=None, inplace=False, limit=None, downcast=None): """Synonym for DataFrame.fillna(method='bfill') @@ -1355,59 +1355,59 @@ def boxplot(self, column=None, by=None, ax=None, fontsize=None, rot=0, **kwds): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def clip(self, lower=None, upper=None, axis=None, inplace=False, *args, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def clip_lower(self, threshold, axis=None, inplace=False): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def clip_upper(self, threshold, axis=None, inplace=False): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def combine(self, other, func, fill_value=None, overwrite=True): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def combine_first(self, other): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def compound(self, axis=None, skipna=None, level=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def consolidate(self, inplace=False): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def convert_objects(self, convert_dates=True, convert_numeric=False, convert_timedeltas=True, copy=True): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def corr(self, method='pearson', min_periods=1): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def corrwith(self, other, axis=0, drop=False): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def count(self, axis=0, level=None, numeric_only=False): """Get the count of non-null objects in the DataFrame. @@ -1429,7 +1429,7 @@ def remote_func(df): def cov(self, min_periods=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def _cumulative_helper(self, func, axis): axis = pandas.DataFrame()._get_axis_number(axis) if axis is not None \ @@ -1603,7 +1603,7 @@ def divide(self, other, axis='columns', level=None, fill_value=None): def dot(self, other): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def drop(self, labels=None, axis=0, index=None, columns=None, level=None, inplace=False, errors='raise'): @@ -1735,12 +1735,12 @@ def drop_helper(obj, axis, label): def drop_duplicates(self, subset=None, keep='first', inplace=False): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def duplicated(self, subset=None, keep='first'): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def eq(self, other, axis='columns', level=None): """Checks element-wise that this is equal to other. @@ -1860,12 +1860,12 @@ 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( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def expanding(self, min_periods=1, freq=None, center=False, axis=0): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def ffill(self, axis=None, inplace=False, limit=None, downcast=None): """Synonym for DataFrame.fillna(method='ffill') @@ -2035,7 +2035,7 @@ def f(x): def first(self, offset): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def first_valid_index(self): """Return index for first non-NA/null value. @@ -2066,26 +2066,26 @@ def from_csv(self, path, header=0, sep=', ', index_col=0, infer_datetime_format=False): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") @classmethod def from_dict(self, data, orient='columns', dtype=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") @classmethod def from_items(self, items, columns=None, orient='columns'): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") @classmethod def from_records(self, data, index=None, exclude=None, columns=None, coerce_float=False, nrows=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def ge(self, other, axis='columns', level=None): """Checks element-wise that this is greater than or equal to other. @@ -2138,12 +2138,12 @@ def get_ftype_counts(self): def get_value(self, index, col, takeable=False): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def get_values(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def gt(self, other, axis='columns', level=None): """Checks element-wise that this is greater than other. @@ -2185,7 +2185,7 @@ def hist(self, data, column=None, by=None, grid=True, xlabelsize=None, sharey=False, figsize=None, layout=None, bins=10, **kwds): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def idxmax(self, axis=0, skipna=True): """Get the index of the first occurrence of the max value of the axis. @@ -2234,7 +2234,7 @@ def remote_func(df): def infer_objects(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def info(self, verbose=None, buf=None, max_cols=None, memory_usage=None, null_counts=None): @@ -2372,7 +2372,7 @@ def interpolate(self, method='linear', axis=0, limit=None, inplace=False, limit_direction='forward', downcast=None, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def iterrows(self): """Iterate over DataFrame rows as (index, Series) pairs. @@ -2582,18 +2582,18 @@ def kurt(self, axis=None, skipna=None, level=None, numeric_only=None, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def kurtosis(self, axis=None, skipna=None, level=None, numeric_only=None, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def last(self, offset): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def last_valid_index(self): """Return index for last non-NA/null value. @@ -2619,7 +2619,7 @@ def le(self, other, axis='columns', level=None): def lookup(self, row_labels, col_labels): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def lt(self, other, axis='columns', level=None): """Checks element-wise that this is less than other. @@ -2637,13 +2637,13 @@ def lt(self, other, axis='columns', level=None): def mad(self, axis=None, skipna=None, level=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def mask(self, cond, other=np.nan, inplace=False, axis=None, level=None, errors='raise', try_cast=False, raise_on_error=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def max(self, axis=None, skipna=None, level=None, numeric_only=None, **kwargs): @@ -2700,7 +2700,7 @@ def melt(self, id_vars=None, value_vars=None, var_name=None, value_name='value', col_level=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def memory_usage(self, index=True, deep=False): @@ -2977,7 +2977,7 @@ def ne(self, other, axis='columns', level=None): def nlargest(self, n, columns, keep='first'): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def notna(self): """Perform notna across the DataFrame. @@ -3025,7 +3025,7 @@ def notnull(self): def nsmallest(self, n, columns, keep='first'): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def nunique(self, axis=0, dropna=True): """Return Series with number of distinct @@ -3047,7 +3047,7 @@ def pct_change(self, periods=1, fill_method='pad', limit=None, freq=None, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def pipe(self, func, *args, **kwargs): """Apply func(self, *args, **kwargs) @@ -3065,14 +3065,14 @@ def pipe(self, func, *args, **kwargs): def pivot(self, index=None, columns=None, values=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def pivot_table(self, values=None, index=None, columns=None, aggfunc='mean', fill_value=None, margins=False, dropna=True, margins_name='All'): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def plot(self, x=None, y=None, kind='line', ax=None, subplots=False, sharex=None, sharey=False, layout=None, figsize=None, @@ -3083,7 +3083,7 @@ def plot(self, x=None, y=None, kind='line', ax=None, subplots=False, sort_columns=False, **kwds): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def pop(self, item): """Pops an item from this DataFrame and returns it. @@ -3344,7 +3344,7 @@ def reindex(self, labels=None, index=None, columns=None, axis=None, raise NotImplementedError( "Multilevel Index not Implemented. " "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") axis = pandas.DataFrame()._get_axis_number(axis) if axis is not None \ else 0 @@ -3387,13 +3387,13 @@ def reindex_axis(self, labels, axis=0, method=None, level=None, copy=True, limit=None, fill_value=np.nan): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def reindex_like(self, other, method=None, copy=True, limit=None, tolerance=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def rename(self, mapper=None, index=None, columns=None, axis=None, copy=True, inplace=False, level=None): @@ -3470,20 +3470,20 @@ def _set_axis_name(self, name, axis=0, inplace=False): def reorder_levels(self, order, axis=0): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def replace(self, to_replace=None, value=None, inplace=False, limit=None, regex=False, method='pad', axis=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") 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( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def reset_index(self, level=None, drop=False, inplace=False, col_level=0, col_fill=''): @@ -3610,7 +3610,7 @@ def rolling(self, window, min_periods=None, freq=None, center=False, win_type=None, on=None, axis=0, closed=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def round(self, decimals=0, *args, **kwargs): new_block_partitions = np.array([_map_partitions( @@ -3802,7 +3802,7 @@ def sample(self, n=None, frac=None, replace=False, weights=None, def select(self, crit, axis=0): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def select_dtypes(self, include=None, exclude=None): # Validates arguments for whether both include and exclude are None or @@ -3846,7 +3846,7 @@ def sem(self, axis=None, skipna=None, level=None, ddof=1, numeric_only=None, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def set_axis(self, labels, axis=0, inplace=None): """Assign desired index to given axis. @@ -3963,12 +3963,12 @@ def set_index(self, keys, drop=True, append=False, inplace=False, def set_value(self, index, col, value, takeable=False): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def shift(self, periods=1, freq=None, axis=0): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def skew(self, axis=None, skipna=None, level=None, numeric_only=None, **kwargs): @@ -3993,7 +3993,7 @@ def remote_func(df): def slice_shift(self, periods=1, axis=0): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def sort_index(self, axis=0, level=None, ascending=True, inplace=False, kind='quicksort', na_position='last', sort_remaining=True, @@ -4174,17 +4174,17 @@ def sortlevel(self, level=0, axis=0, ascending=True, inplace=False, sort_remaining=True): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def squeeze(self, axis=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def stack(self, level=-1, dropna=True): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def std(self, axis=None, skipna=None, level=None, ddof=1, numeric_only=None, **kwargs): @@ -4236,12 +4236,12 @@ def subtract(self, other, axis='columns', level=None, fill_value=None): def swapaxes(self, axis1, axis2, copy=True): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def swaplevel(self, i=-2, j=-1, axis=0): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def tail(self, n=5): """Get the last n rows of the DataFrame. @@ -4267,7 +4267,7 @@ def tail(self, n=5): def take(self, indices, axis=0, convert=None, is_copy=True, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def to_clipboard(self, excel=None, sep=None, **kwargs): @@ -4359,12 +4359,12 @@ def get_csv_str(df, index, columns, header, kwargs): def to_dense(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def to_dict(self, orient='dict', into=dict): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def to_excel(self, excel_writer, sheet_name='Sheet1', na_rep='', float_format=None, columns=None, header=True, index=True, @@ -4395,7 +4395,7 @@ def to_gbq(self, destination_table, project_id, chunksize=10000, private_key=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def to_hdf(self, path_or_buf, key, **kwargs): @@ -4443,7 +4443,7 @@ def to_latex(self, buf=None, columns=None, col_space=None, header=True, multicolumn_format=None, multirow=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def to_msgpack(self, path_or_buf=None, encoding='utf-8', **kwargs): @@ -4456,7 +4456,7 @@ def to_msgpack(self, path_or_buf=None, encoding='utf-8', **kwargs): def to_panel(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def to_parquet(self, fname, engine='auto', compression='snappy', **kwargs): @@ -4470,7 +4470,7 @@ def to_parquet(self, fname, engine='auto', compression='snappy', def to_period(self, freq=None, axis=0, copy=True): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def to_pickle(self, path, compression='infer', protocol=pkl.HIGHEST_PROTOCOL): @@ -4484,12 +4484,12 @@ def to_pickle(self, path, compression='infer', def to_records(self, index=True, convert_datetime64=True): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def to_sparse(self, fill_value=None, kind='block'): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def to_sql(self, name, con, flavor=None, schema=None, if_exists='fail', index=True, index_label=None, chunksize=None, dtype=None): @@ -4520,17 +4520,17 @@ def to_string(self, buf=None, columns=None, col_space=None, header=True, show_dimensions=False): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def to_timestamp(self, freq=None, how='start', axis=0, copy=True): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def to_xarray(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def transform(self, func, *args, **kwargs): kwargs["is_transform"] = True @@ -4560,28 +4560,28 @@ def truediv(self, other, axis='columns', level=None, fill_value=None): def truncate(self, before=None, after=None, axis=None, copy=True): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def tshift(self, periods=1, freq=None, axis=0): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def tz_convert(self, tz, axis=0, level=None, copy=True): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def tz_localize(self, tz, axis=0, level=None, copy=True, ambiguous='raise'): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def unstack(self, level=-1, fill_value=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def update(self, other, join='left', overwrite=True, filter_func=None, raise_conflict=False): @@ -4602,7 +4602,7 @@ def update(self, other, join='left', overwrite=True, filter_func=None, raise NotImplementedError( "raise_conflict parameter not yet supported. " "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") if not isinstance(other, DataFrame): other = DataFrame(other) @@ -4739,7 +4739,7 @@ def where(self, cond, other=np.nan, inplace=False, axis=None, level=None, def xs(self, key, axis=0, level=None, drop_level=True): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __getitem__(self, key): """Get the column specified by key for this DataFrame. @@ -4769,11 +4769,11 @@ def __getitem__(self, key): return self._getitem_array(key) elif isinstance(key, DataFrame): raise NotImplementedError("To contribute to Pandas on Ray, please" - "visit github.com/ray-project/ray.") + "visit github.com/modin-project/modin.") # return self._getitem_frame(key) elif is_mi_columns: raise NotImplementedError("To contribute to Pandas on Ray, please" - "visit github.com/ray-project/ray.") + "visit github.com/modin-project/modin.") # return self._getitem_multilevel(key) else: return self._getitem_column(key) @@ -4864,7 +4864,7 @@ def __setitem__(self, key, value): if not isinstance(key, str): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") if key not in self.columns: self.insert(loc=len(self.columns), column=key, value=value) else: @@ -4883,17 +4883,17 @@ def __len__(self): def __unicode__(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __invert__(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __hash__(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __iter__(self): """Iterate over the columns @@ -4917,12 +4917,12 @@ def __contains__(self, key): def __nonzero__(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __bool__(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __abs__(self): """Creates a modified DataFrame by taking the absolute value. @@ -4935,7 +4935,7 @@ def __abs__(self): def __round__(self, decimals=0): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __array__(self, dtype=None): # TODO: This is very inefficient and needs fix, also see as_matrix @@ -4948,12 +4948,12 @@ def __array_wrap__(self, result, context=None): def __getstate__(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __setstate__(self, state): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __delitem__(self, key): """Delete a column by key. `del a[key]` for example. @@ -5008,7 +5008,7 @@ def del_helper(df, to_delete): def __finalize__(self, other, method=None, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __copy__(self, deep=True): """Make a copy using modin.DataFrame.copy method @@ -5037,17 +5037,17 @@ def __deepcopy__(self, memo=None): def __and__(self, other): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __or__(self, other): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __xor__(self, other): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __lt__(self, other): return self.lt(other) @@ -5161,30 +5161,30 @@ def __neg__(self): def __sizeof__(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") @property def __doc__(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") @property def blocks(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") @property def style(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def iat(self, axis=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") @property def loc(self): @@ -5200,17 +5200,17 @@ def loc(self): def is_copy(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def at(self, axis=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def ix(self, axis=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") @property def iloc(self): diff --git a/modin/pandas/groupby.py b/modin/pandas/groupby.py index 3fb6b8dc6d1..78ed9537916 100644 --- a/modin/pandas/groupby.py +++ b/modin/pandas/groupby.py @@ -59,7 +59,7 @@ def __getattr__(self, key): raise NotImplementedError( "SeriesGroupBy is not implemented." "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") raise e _index_grouped_cache = None @@ -144,7 +144,7 @@ def ffill(self, limit=None): def sem(self, ddof=1): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def mean(self, *args, **kwargs): return self._apply_agg_function( @@ -158,23 +158,23 @@ def any(self): def plot(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def ohlc(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __bytes__(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") @property def tshift(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") @property def groups(self): @@ -187,7 +187,7 @@ def min(self, **kwargs): def idxmax(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") @property def ndim(self): @@ -196,12 +196,12 @@ def ndim(self): def shift(self, periods=1, freq=None, axis=0): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def nth(self, n, dropna=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def cumsum(self, axis=0, *args, **kwargs): return self._apply_df_function(lambda df: df.cumsum(axis, @@ -215,12 +215,12 @@ def indices(self): def pct_change(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def filter(self, func, dropna=True, *args, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def cummax(self, axis=0, **kwargs): return self._apply_df_function(lambda df: df.cummax(axis, @@ -278,7 +278,7 @@ def dtypes(self): def first(self, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def backfill(self, limit=None): return self.bfill(limit) @@ -287,7 +287,7 @@ def __getitem__(self, key): # This operation requires a SeriesGroupBy Object raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def cummin(self, axis=0, **kwargs): return self._apply_df_function(lambda df: df.cummin(axis=axis, @@ -300,7 +300,7 @@ def bfill(self, limit=None): def idxmin(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def prod(self, **kwargs): return self._apply_agg_function( @@ -320,19 +320,19 @@ def aggregate(self, arg, *args, **kwargs): raise NotImplementedError( "This requires Multi-level index to be implemented. " "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") return self._apply_agg_function( lambda df: _agg_remote.remote(df, self._axis, arg, kwargs, *args)) def last(self, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def mad(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def rank(self): return self._apply_df_function(lambda df: df.rank(axis=self._axis)) @@ -341,12 +341,12 @@ def rank(self): def corrwith(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def pad(self, limit=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def max(self, **kwargs): return self._apply_agg_function( @@ -359,7 +359,7 @@ def var(self, ddof=1, *args, **kwargs): def get_group(self, name, obj=None): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def __len__(self): return len(self._index_grouped) @@ -378,18 +378,18 @@ def sum(self, **kwargs): def __unicode__(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def describe(self, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def boxplot(self, grouped, subplots=True, column=None, fontsize=None, rot=0, grid=True, ax=None, figsize=None, layout=None, **kwds): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def ngroup(self, ascending=True): return self._index_grouped.ngroup(ascending) @@ -401,7 +401,7 @@ def nunique(self, dropna=True): def resample(self, rule, *args, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def median(self, **kwargs): return self._apply_agg_function( @@ -410,7 +410,7 @@ def median(self, **kwargs): def head(self, n=5): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def cumprod(self, axis=0, *args, **kwargs): return self._apply_df_function(lambda df: df.cumprod(axis, @@ -426,7 +426,7 @@ def agg(self, arg, *args, **kwargs): def cov(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def transform(self, func, *args, **kwargs): return self._apply_df_function(lambda df: df.transform(func, @@ -436,7 +436,7 @@ def transform(self, func, *args, **kwargs): def corr(self, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def fillna(self, **kwargs): return self._apply_df_function(lambda df: df.fillna(axis=self._axis, @@ -452,36 +452,36 @@ def pipe(self, func, *args, **kwargs): def cumcount(self, ascending=True): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def tail(self, n=5): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") # expanding and rolling are unique cases and need to likely be handled # separately. They do not appear to be commonly used. def expanding(self, *args, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def rolling(self, *args, **kwargs): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def hist(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def quantile(self, q=0.5, **kwargs): if is_list_like(q): raise NotImplementedError( "This requires Multi-level index to be implemented. " "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") return self._apply_agg_function( lambda df: _quantile_remote.remote(df, self._axis, q, kwargs)) @@ -489,7 +489,7 @@ def quantile(self, q=0.5, **kwargs): def diff(self): raise NotImplementedError( "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") def take(self, **kwargs): return self._apply_df_function(lambda df: df.take(**kwargs)) diff --git a/modin/pandas/reshape.py b/modin/pandas/reshape.py index 9ba791ab90a..a3e14643bbf 100644 --- a/modin/pandas/reshape.py +++ b/modin/pandas/reshape.py @@ -40,7 +40,7 @@ def get_dummies(data, prefix=None, prefix_sep='_', dummy_na=False, raise NotImplementedError( "SparseDataFrame is not implemented. " "To contribute to Pandas on Ray, please visit " - "github.com/ray-project/ray.") + "github.com/modin-project/modin.") if columns is None: columns_to_encode = data.dtypes.isin([np.dtype("O"), 'category'])