apache_beam.dataframe.frames module

class apache_beam.dataframe.frames.DeferredSeries(expr)

Bases: apache_beam.dataframe.frame_base.DeferredFrame

astype(**kwargs)

between(**kwargs)

dropna(**kwargs)

items(*args, **kwargs)

iteritems(*args, **kwargs)

isin(**kwargs)

isna(**kwargs)

notnull(**kwargs)

notna(**kwargs)

fillna(value, method)

reindex(*args, **kwargs)

to_numpy(*args, **kwargs)

to_string(*args, **kwargs)

transform(**kwargs)

aggregate(func, axis=0, *args, **kwargs)

agg(func, axis=0, *args, **kwargs)

all(*args, **kwargs)

any(*args, **kwargs)

min(*args, **kwargs)

max(*args, **kwargs)

prod(*args, **kwargs)

product(*args, **kwargs)

sum(*args, **kwargs)

cummax(*args, **kwargs)

cummin(*args, **kwargs)

cumsum(*args, **kwargs)

cumprod(*args, **kwargs)

diff(*args, **kwargs)

head(*args, **kwargs)

tail(*args, **kwargs)

memory_usage(*args, **kwargs)

nlargest(keep, **kwargs)

nsmallest(keep, **kwargs)

rename_axis(**kwargs)

replace(limit, **kwargs)

round(**kwargs)

searchsorted(*args, **kwargs)

shift(*args, **kwargs)

take(*args, **kwargs)

to_dict(*args, **kwargs)

to_frame(**kwargs)

unique(as_series=False)

update(other)

unstack(*args, **kwargs)

values

view(*args, **kwargs)

str

add(**kwargs)

and(**kwargs)

apply(**kwargs)

div(**kwargs)

floordiv(**kwargs)

map(**kwargs)

mod(**kwargs)

mul(**kwargs)

or(**kwargs)

pow(**kwargs)

radd(**kwargs)

rand(**kwargs)

rdiv(**kwargs)

rfloordiv(**kwargs)

rmod(**kwargs)

rmul(**kwargs)

ror(**kwargs)

rpow(**kwargs)

rsub(**kwargs)

rtruediv(**kwargs)

sub(**kwargs)

truediv(**kwargs)

class apache_beam.dataframe.frames.DeferredDataFrame(expr)

Bases: apache_beam.dataframe.frame_base.DeferredFrame

T

columns

groupby(by)

set_index(keys, **kwargs)

at(*args, **kwargs)

loc

index

axes

apply(*args, **kwargs)

explode(*args, **kwargs)

isin(*args, **kwargs)

assign(*args, **kwargs)

append(*args, **kwargs)

combine(*args, **kwargs)

combine_first(*args, **kwargs)

cov(*args, **kwargs)

corr(*args, **kwargs)

count(*args, **kwargs)

dot(*args, **kwargs)

drop(*args, **kwargs)

eval(*args, **kwargs)

reindex(*args, **kwargs)

melt(*args, **kwargs)

pivot(*args, **kwargs)

pivot_table(*args, **kwargs)

aggregate(func, axis=0, *args, **kwargs)

agg(func, axis=0, *args, **kwargs)

applymap(**kwargs)

memory_usage(*args, **kwargs)

info(*args, **kwargs)

all(*args, **kwargs)

any(*args, **kwargs)

cummax(*args, **kwargs)

cummin(*args, **kwargs)

cumsum(*args, **kwargs)

cumprod(*args, **kwargs)

diff(*args, **kwargs)

head(*args, **kwargs)

tail(*args, **kwargs)

max(*args, **kwargs)

min(*args, **kwargs)

mode(axis=0, *args, **kwargs)

dropna(axis, **kwargs)

fillna(value, method, axis, **kwargs)

isna(**kwargs)

notnull(**kwargs)

notna(**kwargs)

items(*args, **kwargs)

itertuples(*args, **kwargs)

iterrows(*args, **kwargs)

iteritems(*args, **kwargs)

join(other, on, **kwargs)

merge(right, on, left_on, right_on, left_index, right_index, **kwargs)

nlargest(keep, **kwargs)

nsmallest(keep, **kwargs)

nunique(**kwargs)

prod(*args, **kwargs)

product(*args, **kwargs)

quantile(axis, **kwargs)

query(**kwargs)

rename(**kwargs)

rename_axis(**kwargs)

replace(limit, **kwargs)

reset_index(level=None, **kwargs)

round(**kwargs)

select_dtypes(**kwargs)

shift(axis, **kwargs)

shape

sort_values(axis, **kwargs)

stack(**kwargs)

sum(*args, **kwargs)

take(*args, **kwargs)

to_records(*args, **kwargs)

to_dict(*args, **kwargs)

to_numpy(*args, **kwargs)

to_string(*args, **kwargs)

to_sparse(*args, **kwargs)

transform(**kwargs)

transpose(*args, **kwargs)

unstack(*args, **kwargs)

update(**kwargs)

add(**kwargs)

and(**kwargs)

div(**kwargs)

filter(**kwargs)

floordiv(**kwargs)

mod(**kwargs)

mul(**kwargs)

or(**kwargs)

pow(**kwargs)

radd(**kwargs)

rand(**kwargs)

rdiv(**kwargs)

rfloordiv(**kwargs)

rmod(**kwargs)

rmul(**kwargs)

ror(**kwargs)

rpow(**kwargs)

rsub(**kwargs)

rtruediv(**kwargs)

sub(**kwargs)

to_clipboard(*args, **kwargs)

to_csv(path, *args, **kwargs)

to_excel(path, *args, **kwargs)

to_feather(path, *args, **kwargs)

to_hdf(*args, **kwargs)

to_html(path, *args, **kwargs)

to_json(path, orient=None, *args, **kwargs)

to_msgpack(*args, **kwargs)

to_parquet(path, *args, **kwargs)

to_stata(path, *args, **kwargs)

truediv(**kwargs)

class apache_beam.dataframe.frames.DeferredGroupBy(expr)

Bases: apache_beam.dataframe.frame_base.DeferredFrame

agg(fn)

all(*args, **kargs)

any(*args, **kargs)

max(*args, **kargs)

mean(*args, **kargs)

median(*args, **kargs)

min(*args, **kargs)

prod(*args, **kargs)

size(*args, **kargs)

std(*args, **kargs)

sum(*args, **kargs)

var(*args, **kargs)