apache_beam.dataframe.frames module

class apache_beam.dataframe.frames.DeferredSeries(expr)

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)

Bases: apache_beam.dataframe.frame_base.DeferredFrame

groupby(cols)

set_index(keys, **kwargs)

at(*args, **kwargs)

loc

filter(**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)