apache_beam.dataframe.frames module

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

Bases: apache_beam.dataframe.frame_base.DeferredFrame

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)
transform(**kwargs)
truediv(**kwargs)
class apache_beam.dataframe.frames.DeferredDataFrame(expr)[source]

Bases: apache_beam.dataframe.frame_base.DeferredFrame

T
transpose(dtype=None)[source]
groupby(cols)[source]
set_index(keys, **kwargs)[source]
at(*args, **kwargs)[source]
loc
aggregate(func, axis=0, *args, **kwargs)[source]
agg(func, axis=0, *args, **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)