apache_beam.dataframe.frames module

apache_beam.dataframe.frames.populate_not_implemented(pd_type)

class apache_beam.dataframe.frames.DeferredDataFrameOrSeries(expr)

Bases: apache_beam.dataframe.frame_base.DeferredFrame

droplevel(level, axis)

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

ffill(**kwargs)

pad(**kwargs)

groupby(by, level, axis, as_index, group_keys, **kwargs)

abs(**kwargs)

astype(**kwargs)

copy(**kwargs)

dtype

dtypes

index

class apache_beam.dataframe.frames.DeferredSeries(expr)

Bases: apache_beam.dataframe.frames.DeferredDataFrameOrSeries

align(other, join, axis, level, method, **kwargs)

array

between(**kwargs)

dot(other)

std(axis, skipna, level, ddof, **kwargs)

corr(other, method, min_periods)

cov(other, min_periods, ddof)

dropna(**kwargs)

items(*args, **kwargs)

iteritems(*args, **kwargs)

isin(**kwargs)

isna(**kwargs)

notnull(**kwargs)

notna(**kwargs)

to_numpy(*args, **kwargs)

to_string(*args, **kwargs)

transform(**kwargs)

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

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

axes

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

filter(**kwargs)

memory_usage(*args, **kwargs)

nlargest(keep, **kwargs)

nsmallest(keep, **kwargs)

plot

pop(*args, **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

T

add(**kwargs)

add_prefix(*args, **kwargs)

add_suffix(*args, **kwargs)

and(**kwargs)

append(*args, **kwargs)

apply(**kwargs)

argmax(*args, **kwargs)

argmin(*args, **kwargs)

argsort(*args, **kwargs)

asfreq(*args, **kwargs)

asof(*args, **kwargs)

at

at_time(*args, **kwargs)

attrs

autocorr(*args, **kwargs)

backfill(*args, **kwargs)

between_time(*args, **kwargs)

bfill(*args, **kwargs)

bool(*args, **kwargs)

cat

combine(*args, **kwargs)

combine_first(*args, **kwargs)

compare(*args, **kwargs)

convert_dtypes(*args, **kwargs)

count(*args, **kwargs)

describe(*args, **kwargs)

div(**kwargs)

divide(*args, **kwargs)

divmod(**kwargs)

drop(*args, **kwargs)

drop_duplicates(*args, **kwargs)

dt

duplicated(*args, **kwargs)

empty

eq(*args, **kwargs)

equals(*args, **kwargs)

ewm(*args, **kwargs)

expanding(*args, **kwargs)

explode(*args, **kwargs)

factorize(*args, **kwargs)

first(*args, **kwargs)

first_valid_index(*args, **kwargs)

floordiv(**kwargs)

ge(*args, **kwargs)

get(*args, **kwargs)

gt(*args, **kwargs)

hasnans

hist(*args, **kwargs)

iat

idxmax(*args, **kwargs)

idxmin(*args, **kwargs)

iloc

infer_objects(*args, **kwargs)

interpolate(*args, **kwargs)

is_monotonic

is_monotonic_decreasing

is_monotonic_increasing

is_unique

isnull(*args, **kwargs)

item(*args, **kwargs)

keys(*args, **kwargs)

kurt(*args, **kwargs)

kurtosis(*args, **kwargs)

last(*args, **kwargs)

last_valid_index(*args, **kwargs)

le(*args, **kwargs)

loc

lt(*args, **kwargs)

mad(*args, **kwargs)

map(**kwargs)

mask(*args, **kwargs)

mean(*args, **kwargs)

median(*args, **kwargs)

mod(**kwargs)

mode(*args, **kwargs)

mul(**kwargs)

multiply(**kwargs)

name

nbytes

ndim

ne(*args, **kwargs)

nunique(*args, **kwargs)

or(**kwargs)

pct_change(*args, **kwargs)

pipe(*args, **kwargs)

pow(**kwargs)

quantile(*args, **kwargs)

radd(**kwargs)

rand(**kwargs)

rank(*args, **kwargs)

ravel(*args, **kwargs)

rdiv(**kwargs)

rdivmod(**kwargs)

reindex(*args, **kwargs)

reindex_like(*args, **kwargs)

rename(*args, **kwargs)

reorder_levels(*args, **kwargs)

repeat(*args, **kwargs)

resample(*args, **kwargs)

reset_index(*args, **kwargs)

rfloordiv(**kwargs)

rmod(**kwargs)

rmul(**kwargs)

rolling(*args, **kwargs)

ror(**kwargs)

rpow(**kwargs)

rsub(**kwargs)

rtruediv(**kwargs)

sample(*args, **kwargs)

sem(*args, **kwargs)

set_axis(*args, **kwargs)

shape

size

skew(*args, **kwargs)

slice_shift(*args, **kwargs)

sort_index(*args, **kwargs)

sort_values(*args, **kwargs)

sparse

squeeze(*args, **kwargs)

sub(**kwargs)

subtract(*args, **kwargs)

swapaxes(*args, **kwargs)

swaplevel(*args, **kwargs)

to_clipboard(*args, **kwargs)

to_csv(*args, **kwargs)

to_excel(*args, **kwargs)

to_hdf(*args, **kwargs)

to_json(*args, **kwargs)

to_latex(*args, **kwargs)

to_list(*args, **kwargs)

to_markdown(*args, **kwargs)

to_period(*args, **kwargs)

to_pickle(*args, **kwargs)

to_sql(*args, **kwargs)

to_timestamp(*args, **kwargs)

to_xarray(*args, **kwargs)

tolist(*args, **kwargs)

transpose(*args, **kwargs)

truediv(**kwargs)

truncate(*args, **kwargs)

tshift(*args, **kwargs)

tz_convert(*args, **kwargs)

tz_localize(*args, **kwargs)

value_counts(*args, **kwargs)

var(*args, **kwargs)

where(*args, **kwargs)

xs(*args, **kwargs)

class apache_beam.dataframe.frames.DeferredDataFrame(expr)

Bases: apache_beam.dataframe.frames.DeferredDataFrameOrSeries

T

columns

align(other, join, axis, copy, level, method, **kwargs)

set_index(keys, **kwargs)

loc

iloc

axes

dtypes

assign(**kwargs)

explode(column, ignore_index)

drop(labels, axis, index, columns, errors, **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)

clip(**kwargs)

corr(method, min_periods)

cov(min_periods, ddof)

corrwith(other, axis, drop, method)

cummax(*args, **kwargs)

cummin(*args, **kwargs)

cumsum(*args, **kwargs)

cumprod(*args, **kwargs)

diff(*args, **kwargs)

dot(other)

head(*args, **kwargs)

tail(*args, **kwargs)

max(*args, **kwargs)

min(*args, **kwargs)

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

dropna(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)

plot

pop(item)

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)

values

add(**kwargs)

add_prefix(*args, **kwargs)

add_suffix(*args, **kwargs)

and(**kwargs)

append(*args, **kwargs)

apply(*args, **kwargs)

asfreq(*args, **kwargs)

asof(*args, **kwargs)

at

at_time(*args, **kwargs)

attrs

backfill(*args, **kwargs)

between_time(*args, **kwargs)

bfill(*args, **kwargs)

bool(*args, **kwargs)

boxplot(*args, **kwargs)

combine(*args, **kwargs)

combine_first(*args, **kwargs)

compare(*args, **kwargs)

convert_dtypes(*args, **kwargs)

count(*args, **kwargs)

describe(*args, **kwargs)

div(**kwargs)

divide(*args, **kwargs)

divmod(**kwargs)

drop_duplicates(*args, **kwargs)

duplicated(*args, **kwargs)

empty

eq(*args, **kwargs)

equals(*args, **kwargs)

eval(*args, **kwargs)

ewm(*args, **kwargs)

expanding(*args, **kwargs)

filter(**kwargs)

first(*args, **kwargs)

first_valid_index(*args, **kwargs)

floordiv(**kwargs)

from_dict(*args, **kwargs)

from_records(*args, **kwargs)

ge(*args, **kwargs)

get(*args, **kwargs)

gt(*args, **kwargs)

hist(*args, **kwargs)

iat

idxmax(*args, **kwargs)

idxmin(*args, **kwargs)

infer_objects(*args, **kwargs)

insert(*args, **kwargs)

interpolate(*args, **kwargs)

isin(*args, **kwargs)

isnull(*args, **kwargs)

keys(*args, **kwargs)

kurt(*args, **kwargs)

kurtosis(*args, **kwargs)

last(*args, **kwargs)

last_valid_index(*args, **kwargs)

le(*args, **kwargs)

lookup(*args, **kwargs)

lt(*args, **kwargs)

mad(*args, **kwargs)

mask(*args, **kwargs)

mean(*args, **kwargs)

median(*args, **kwargs)

melt(*args, **kwargs)

mod(**kwargs)

mul(**kwargs)

multiply(**kwargs)

ndim

ne(*args, **kwargs)

or(**kwargs)

pct_change(*args, **kwargs)

pipe(*args, **kwargs)

pivot(*args, **kwargs)

pivot_table(*args, **kwargs)

pow(**kwargs)

radd(**kwargs)

rand(**kwargs)

rank(*args, **kwargs)

rdiv(**kwargs)

rdivmod(**kwargs)

reindex(*args, **kwargs)

reindex_like(*args, **kwargs)

reorder_levels(*args, **kwargs)

resample(*args, **kwargs)

rfloordiv(**kwargs)

rmod(**kwargs)

rmul(**kwargs)

rolling(*args, **kwargs)

ror(**kwargs)

rpow(**kwargs)

rsub(**kwargs)

rtruediv(**kwargs)

sample(*args, **kwargs)

sem(*args, **kwargs)

set_axis(*args, **kwargs)

size

skew(*args, **kwargs)

slice_shift(*args, **kwargs)

sort_index(*args, **kwargs)

sparse

squeeze(*args, **kwargs)

std(*args, **kwargs)

style

sub(**kwargs)

subtract(*args, **kwargs)

swapaxes(*args, **kwargs)

swaplevel(*args, **kwargs)

to_clipboard(*args, **kwargs)

to_csv(path, *args, **kwargs)

to_excel(path, *args, **kwargs)

to_feather(path, *args, **kwargs)

to_gbq(*args, **kwargs)

to_hdf(*args, **kwargs)

to_html(path, *args, **kwargs)

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

to_latex(*args, **kwargs)

to_markdown(*args, **kwargs)

to_msgpack(*args, **kwargs)

to_parquet(path, *args, **kwargs)

to_period(*args, **kwargs)

to_pickle(*args, **kwargs)

to_sql(*args, **kwargs)

to_stata(path, *args, **kwargs)

to_timestamp(*args, **kwargs)

to_xarray(*args, **kwargs)

truediv(**kwargs)

truncate(*args, **kwargs)

tshift(*args, **kwargs)

tz_convert(*args, **kwargs)

tz_localize(*args, **kwargs)

value_counts(*args, **kwargs)

var(*args, **kwargs)

where(*args, **kwargs)

xs(*args, **kwargs)

class apache_beam.dataframe.frames.DeferredGroupBy(expr, kwargs)

Bases: apache_beam.dataframe.frame_base.DeferredFrame

agg(fn)

aggregate(fn)

first(*args, **kwargs)

last(*args, **kwargs)

head(*args, **kwargs)

tail(*args, **kwargs)

groups

all(*args, **kwargs)

any(*args, **kwargs)

apply(*args, **kwargs)

backfill(*args, **kwargs)

bfill(*args, **kwargs)

boxplot(*args, **kwargs)

corr

corrwith

count(*args, **kwargs)

cov

cumcount(*args, **kwargs)

cummax(*args, **kwargs)

cummin(*args, **kwargs)

cumprod(*args, **kwargs)

cumsum(*args, **kwargs)

describe(*args, **kwargs)

diff

expanding(*args, **kwargs)

ffill(*args, **kwargs)

fillna

filter(*args, **kwargs)

get_group(*args, **kwargs)

hist

idxmax

idxmin

indices

mad

max(*args, **kwargs)

mean(*args, **kwargs)

median(*args, **kwargs)

min(*args, **kwargs)

ngroup(*args, **kwargs)

ngroups

nth(*args, **kwargs)

nunique(*args, **kwargs)

ohlc(*args, **kwargs)

pad(*args, **kwargs)

pct_change(*args, **kwargs)

pipe(*args, **kwargs)

plot

prod(*args, **kwargs)

quantile(*args, **kwargs)

rank(*args, **kwargs)

resample(*args, **kwargs)

rolling(*args, **kwargs)

sample(*args, **kwargs)

sem(*args, **kwargs)

shift(*args, **kwargs)

size(*args, **kwargs)

skew

std(*args, **kwargs)

sum(*args, **kwargs)

take

transform(*args, **kwargs)

tshift

var(*args, **kwargs)

apache_beam.dataframe.frames.make_str_func(method)