apache_beam.dataframe.frames module

class apache_beam.dataframe.frames.DeferredSeries(expr)[source]

Bases: apache_beam.dataframe.frame_base.DeferredFrame

astype(**kwargs)
between(**kwargs)
dropna(**kwargs)[source]
items(*args, **kwargs)
iteritems(*args, **kwargs)
isin(**kwargs)
isna(**kwargs)
notnull(**kwargs)
notna(**kwargs)
fillna(value, method)[source]
reindex(*args, **kwargs)
to_numpy(*args, **kwargs)
to_string(*args, **kwargs)
transform(**kwargs)
aggregate(func, axis=0, *args, **kwargs)[source]
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)[source]
nsmallest(keep, **kwargs)[source]
rename_axis(**kwargs)
replace(limit, **kwargs)[source]
round(**kwargs)
searchsorted(*args, **kwargs)
shift(*args, **kwargs)
take(*args, **kwargs)
to_dict(*args, **kwargs)
to_frame(**kwargs)
unique(as_series=False)[source]
update(other)[source]
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)[source]

Bases: apache_beam.dataframe.frame_base.DeferredFrame

T
columns
groupby(by)[source]
set_index(keys, **kwargs)[source]
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)[source]
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)[source]
dropna(axis, **kwargs)[source]
fillna(value, method, axis, **kwargs)[source]
isna(**kwargs)
notnull(**kwargs)
notna(**kwargs)
items(*args, **kwargs)
itertuples(*args, **kwargs)
iterrows(*args, **kwargs)
iteritems(*args, **kwargs)
join(other, on, **kwargs)[source]
merge(right, on, left_on, right_on, left_index, right_index, **kwargs)[source]
nlargest(keep, **kwargs)[source]
nsmallest(keep, **kwargs)[source]
nunique(**kwargs)[source]
prod(*args, **kwargs)
product(*args, **kwargs)
quantile(axis, **kwargs)[source]
query(**kwargs)
rename(**kwargs)[source]
rename_axis(**kwargs)
replace(limit, **kwargs)[source]
reset_index(level=None, **kwargs)[source]
round(**kwargs)
select_dtypes(**kwargs)
shift(axis, **kwargs)[source]
shape
sort_values(axis, **kwargs)[source]
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)[source]
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)[source]

Bases: apache_beam.dataframe.frame_base.DeferredFrame

agg(fn)[source]
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)