mirror of
https://github.com/wassname/ray.git
synced 2026-07-02 22:13:16 +08:00
Adding all DataFrame methods with NotImplementedErrors (#1403)
* Adding all DataFrame methods with NotImplementedErrors * Moving dataframe creation into function call
This commit is contained in:
Devin Petersohn
committed by
Robert Nishihara
Robert Nishihara
parent
1e0dfca2dc
commit
112ef07563
@@ -163,7 +163,7 @@ class DataFrame(object):
|
||||
assert(callable(func))
|
||||
return self.map_partitions(lambda df: df.applymap(lambda x: func(x)))
|
||||
|
||||
def copy(self):
|
||||
def copy(self, deep=True):
|
||||
"""Creates a shallow copy of the DataFrame.
|
||||
|
||||
Returns:
|
||||
@@ -171,13 +171,8 @@ class DataFrame(object):
|
||||
"""
|
||||
return DataFrame(self.df, self.columns)
|
||||
|
||||
def groupby(self,
|
||||
by=None,
|
||||
axis=0,
|
||||
level=None,
|
||||
as_index=True,
|
||||
group_keys=True,
|
||||
squeeze=False):
|
||||
def groupby(self, by=None, axis=0, level=None, as_index=True, sort=True,
|
||||
group_keys=True, squeeze=False, **kwargs):
|
||||
"""Apply a groupby to this DataFrame. See _groupby() remote task.
|
||||
|
||||
Args:
|
||||
@@ -227,7 +222,7 @@ class DataFrame(object):
|
||||
"""
|
||||
return self.groupby(axis=axis).map_partitions(func)
|
||||
|
||||
def sum(self, axis=None, skipna=True):
|
||||
def sum(self, axis=None, skipna=True, level=None, numeric_only=None):
|
||||
"""Perform a sum across the DataFrame.
|
||||
|
||||
Args:
|
||||
@@ -238,10 +233,12 @@ class DataFrame(object):
|
||||
The sum of the DataFrame.
|
||||
"""
|
||||
sum_of_partitions = self.map_partitions(
|
||||
lambda df: df.sum(axis=axis, skipna=skipna))
|
||||
lambda df: df.sum(axis=axis, skipna=skipna, level=level,
|
||||
numeric_only=numeric_only))
|
||||
|
||||
return sum_of_partitions.reduce_by_index(
|
||||
lambda df: df.sum(axis=axis, skipna=skipna))
|
||||
lambda df: df.sum(axis=axis, skipna=skipna, level=level,
|
||||
numeric_only=numeric_only))
|
||||
|
||||
def abs(self):
|
||||
"""Apply an absolute value function to all numberic columns.
|
||||
@@ -333,6 +330,746 @@ class DataFrame(object):
|
||||
if how != 'any' and how != 'all':
|
||||
raise ValueError("<how> not correctly set.")
|
||||
|
||||
def add(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def agg(self, func, axis=0, *args, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def aggregate(self, func, axis=0, *args, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
def all(self, axis=None, bool_only=None, skipna=None, level=None,
|
||||
**kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def any(self, axis=None, bool_only=None, skipna=None, level=None,
|
||||
**kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def append(self, other, ignore_index=False, verify_integrity=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def apply(self, func, axis=0, broadcast=False, raw=False, reduce=None,
|
||||
args=(), **kwds):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def as_blocks(self, copy=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def as_matrix(self, columns=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def asfreq(self, freq, method=None, how=None, normalize=False,
|
||||
fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def asof(self, where, subset=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def assign(self, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def astype(self, dtype, copy=True, errors='raise', **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def at_time(self, time, asof=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def between_time(self, start_time, end_time, include_start=True,
|
||||
include_end=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def bfill(self, axis=None, inplace=False, limit=None, downcast=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def bool(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
def clip(self, lower=None, upper=None, axis=None, inplace=False, *args,
|
||||
**kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def clip_lower(self, threshold, axis=None, inplace=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def clip_upper(self, threshold, axis=None, inplace=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def combine(self, other, func, fill_value=None, overwrite=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def combine_first(self, other):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def compound(self, axis=None, skipna=None, level=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def consolidate(self, inplace=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def convert_objects(self, convert_dates=True, convert_numeric=False,
|
||||
convert_timedeltas=True, copy=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def corr(self, method='pearson', min_periods=1):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def corrwith(self, other, axis=0, drop=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def count(self, axis=0, level=None, numeric_only=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def cov(self, min_periods=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def cummax(self, axis=None, skipna=True, *args, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def cummin(self, axis=None, skipna=True, *args, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def cumprod(self, axis=None, skipna=True, *args, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def cumsum(self, axis=None, skipna=True, *args, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def describe(self, percentiles=None, include=None, exclude=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def diff(self, periods=1, axis=0):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def div(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def divide(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def dot(self, other):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def drop(self, labels=None, axis=0, index=None, columns=None, level=None,
|
||||
inplace=False, errors='raise'):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def drop_duplicates(self, subset=None, keep='first', inplace=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def duplicated(self, subset=None, keep='first'):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def eq(self, other, axis='columns', level=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def equals(self, other):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def eval(self, expr, inplace=False, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
def expanding(self, min_periods=1, freq=None, center=False, axis=0):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def ffill(self, axis=None, inplace=False, limit=None, downcast=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def fillna(self, value=None, method=None, axis=None, inplace=False,
|
||||
limit=None, downcast=None, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def filter(self, items=None, like=None, regex=None, axis=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def first(self, offset):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def first_valid_index(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def floordiv(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
@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.")
|
||||
|
||||
@classmethod
|
||||
def from_dict(self, data, orient='columns', dtype=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
@classmethod
|
||||
def from_items(self, items, columns=None, orient='columns'):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
@classmethod
|
||||
def from_records(self, data, index=None, exclude=None, columns=None,
|
||||
coerce_float=False, nrows=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def ge(self, other, axis='columns', level=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def get(self, key, default=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def get_dtype_counts(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def get_ftype_counts(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def get_value(self, index, col, takeable=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def get_values(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def gt(self, other, axis='columns', level=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def head(self, n=5):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
def idxmax(self, axis=0, skipna=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def idxmin(self, axis=0, skipna=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def infer_objects(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def info(self, verbose=None, buf=None, max_cols=None, memory_usage=None,
|
||||
null_counts=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def insert(self, loc, column, value, allow_duplicates=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def interpolate(self, method='linear', axis=0, limit=None, inplace=False,
|
||||
limit_direction='forward', downcast=None, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def items(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def iteritems(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def iterrows(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def itertuples(self, index=True, name='Pandas'):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def join(self, other, on=None, how='left', lsuffix='', rsuffix='',
|
||||
sort=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def kurt(self, axis=None, skipna=None, level=None, numeric_only=None,
|
||||
**kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def kurtosis(self, axis=None, skipna=None, level=None, numeric_only=None,
|
||||
**kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def last(self, offset):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def last_valid_index(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def le(self, other, axis='columns', level=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def lookup(self, row_labels, col_labels):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def lt(self, other, axis='columns', level=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def mad(self, axis=None, skipna=None, level=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
def max(self, axis=None, skipna=None, level=None, numeric_only=None,
|
||||
**kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def mean(self, axis=None, skipna=None, level=None, numeric_only=None,
|
||||
**kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def median(self, axis=None, skipna=None, level=None, numeric_only=None,
|
||||
**kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def melt(self, id_vars=None, value_vars=None, var_name=None,
|
||||
value_name='value', col_level=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def memory_usage(self, index=True, deep=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
def min(self, axis=None, skipna=None, level=None, numeric_only=None,
|
||||
**kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def mod(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def mode(self, axis=0, numeric_only=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def mul(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def multiply(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def ne(self, other, axis='columns', level=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def nlargest(self, n, columns, keep='first'):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def notna(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def notnull(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def nsmallest(self, n, columns, keep='first'):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def nunique(self, axis=0, dropna=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def pct_change(self, periods=1, fill_method='pad', limit=None, freq=None,
|
||||
**kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def pipe(self, func, *args, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def pivot(self, index=None, columns=None, values=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
def plot(self, x=None, y=None, kind='line', ax=None, subplots=False,
|
||||
sharex=None, sharey=False, layout=None, figsize=None,
|
||||
use_index=True, title=None, grid=None, legend=True, style=None,
|
||||
logx=False, logy=False, loglog=False, xticks=None, yticks=None,
|
||||
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.")
|
||||
|
||||
def pop(self, item):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def pow(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def prod(self, axis=None, skipna=None, level=None, numeric_only=None,
|
||||
min_count=0, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def product(self, axis=None, skipna=None, level=None, numeric_only=None,
|
||||
min_count=0, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def quantile(self, q=0.5, axis=0, numeric_only=True,
|
||||
interpolation='linear'):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def query(self, expr, inplace=False, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def radd(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def rank(self, axis=0, method='average', numeric_only=None,
|
||||
na_option='keep', ascending=True, pct=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def rdiv(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
def reindex_axis(self, labels, axis=0, method=None, level=None, copy=True,
|
||||
limit=None, fill_value=np.nan):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def reindex_like(self, other, method=None, copy=True, limit=None,
|
||||
tolerance=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def rename(self, mapper=None, index=None, columns=None, axis=None,
|
||||
copy=True, inplace=False, level=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def rename_axis(self, mapper, axis=0, copy=True, inplace=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def reorder_levels(self, order, axis=0):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def replace(self, to_replace=None, value=None, inplace=False, limit=None,
|
||||
regex=False, method='pad', axis=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
def reset_index(self, level=None, drop=False, inplace=False, col_level=0,
|
||||
col_fill=''):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def rfloordiv(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def rmod(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def rmul(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
def round(self, decimals=0, *args, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def rpow(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def rsub(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def rtruediv(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def sample(self, n=None, frac=None, replace=False, weights=None,
|
||||
random_state=None, axis=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def select(self, crit, axis=0):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def select_dtypes(self, include=None, exclude=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def sem(self, axis=None, skipna=None, level=None, ddof=1,
|
||||
numeric_only=None, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def set_axis(self, labels, axis=0, inplace=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def set_index(self, keys, drop=True, append=False, inplace=False,
|
||||
verify_integrity=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def set_value(self, index, col, value, takeable=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def shift(self, periods=1, freq=None, axis=0):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def skew(self, axis=None, skipna=None, level=None, numeric_only=None,
|
||||
**kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def slice_shift(self, periods=1, axis=0):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
def sort_values(self, by, axis=0, ascending=True, inplace=False,
|
||||
kind='quicksort', na_position='last'):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def sortlevel(self, level=0, axis=0, ascending=True, inplace=False,
|
||||
sort_remaining=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def squeeze(self, axis=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def stack(self, level=-1, dropna=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def std(self, axis=None, skipna=None, level=None, ddof=1,
|
||||
numeric_only=None, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def sub(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def subtract(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def swapaxes(self, axis1, axis2, copy=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def swaplevel(self, i=-2, j=-1, axis=0):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def tail(self, n=5):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def take(self, indices, axis=0, convert=None, is_copy=True, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def to_clipboard(self, excel=None, sep=None, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def to_csv(self, path_or_buf=None, sep=', ', na_rep='', float_format=None,
|
||||
columns=None, header=True, index=True, index_label=None,
|
||||
mode='w', encoding=None, compression=None, quoting=None,
|
||||
quotechar='"', line_terminator='\n', chunksize=None,
|
||||
tupleize_cols=None, date_format=None, doublequote=True,
|
||||
escapechar=None, decimal='.'):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def to_dense(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def to_dict(self, orient='dict', into=dict):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
def to_feather(self, fname):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
def to_hdf(self, path_or_buf, key, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def to_html(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, 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.")
|
||||
|
||||
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.")
|
||||
|
||||
def to_latex(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,
|
||||
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.")
|
||||
|
||||
def to_msgpack(self, path_or_buf=None, encoding='utf-8', **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def to_panel(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def to_parquet(self, fname, engine='auto', compression='snappy',
|
||||
**kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def to_period(self, freq=None, axis=0, copy=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def to_pickle(self, path, compression='infer', protocol=4):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def to_records(self, index=True, convert_datetime64=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def to_sparse(self, fill_value=None, kind='block'):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
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.")
|
||||
|
||||
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.")
|
||||
|
||||
def to_timestamp(self, freq=None, how='start', axis=0, copy=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def to_xarray(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def transform(self, func, *args, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def truediv(self, other, axis='columns', level=None, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def truncate(self, before=None, after=None, axis=None, copy=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def tshift(self, periods=1, freq=None, axis=0):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def tz_convert(self, tz, axis=0, level=None, copy=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def tz_localize(self, tz, axis=0, level=None, copy=True,
|
||||
ambiguous='raise'):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def unstack(self, level=-1, fill_value=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def update(self, other, join='left', overwrite=True, filter_func=None,
|
||||
raise_conflict=False):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def var(self, axis=None, skipna=None, level=None, ddof=1,
|
||||
numeric_only=None, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
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.")
|
||||
|
||||
def xs(self, key, axis=0, level=None, drop_level=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __getitem__(self, key):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __setitem__(self, key, value):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __len__(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __unicode__(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __neg__(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __invert__(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __hash__(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __iter__(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __contains__(self, key):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __nonzero__(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __bool__(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __abs__(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __round__(self, decimals=0):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __array__(self, dtype=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __array_wrap__(self, result, context=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __getstate__(self):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __setstate__(self, state):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __delitem__(self, key):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __finalize__(self, other, method=None, **kwargs):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __copy__(self, deep=True):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
def __deepcopy__(self, memo=None):
|
||||
raise NotImplementedError("Not Yet implemented.")
|
||||
|
||||
|
||||
@ray.remote
|
||||
def _shuffle(df, indices, chunksize):
|
||||
|
||||
Reference in New Issue
Block a user