apache_beam.dataframe.frames module

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

Bases: apache_beam.dataframe.frame_base.DeferredFrame

isna(**kwargs)
notnull(**kwargs)
notna(**kwargs)
transform(**kwargs)
agg(*args, **kwargs)[source]
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)
replace(limit, **kwargs)[source]
unstack(*args, **kwargs)[source]
add(**kwargs)
apply(**kwargs)
div(**kwargs)
floordiv(**kwargs)
map(**kwargs)
mod(**kwargs)
mul(**kwargs)
pow(**kwargs)
radd(**kwargs)
rdiv(**kwargs)
rfloordiv(**kwargs)
rmod(**kwargs)
rmul(**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
groupby(cols)[source]
set_index(keys, **kwargs)[source]
at(*args, **kwargs)[source]
loc
aggregate(axis, **kwargs)[source]
agg(axis, **kwargs)
applymap(**kwargs)
memory_usage(*args, **kwargs)
all(*args, **kwargs)
any(*args, **kwargs)
cummax(*args, **kwargs)
cummin(*args, **kwargs)
cumsum(*args, **kwargs)
cumprod(*args, **kwargs)
diff(*args, **kwargs)
max(*args, **kwargs)
min(*args, **kwargs)
mode(*args, **kwargs)
dropna(axis, **kwargs)[source]
items(*args, **kwargs)
itertuples(*args, **kwargs)
iterrows(*args, **kwargs)
iteritems(*args, **kwargs)
isna(**kwargs)
notnull(**kwargs)
notna(**kwargs)
prod(*args, **kwargs)
product(*args, **kwargs)
quantile(axis, **kwargs)[source]
query(**kwargs)
replace(limit, **kwargs)[source]
reset_index(level, **kwargs)[source]
round(**kwargs)
select_dtypes(**kwargs)
shift(axis, **kwargs)[source]
shape
sort_values(axis, **kwargs)[source]
stack(**kwargs)
sum(*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)[source]
unstack(*args, **kwargs)[source]
update(**kwargs)
filter(**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)