apache_beam.dataframe.frames module

apache_beam.dataframe.frames.populate_not_implemented(pd_type)[source]
class apache_beam.dataframe.frames.DeferredDataFrameOrSeries(expr)[source]

Bases: apache_beam.dataframe.frame_base.DeferredFrame

droplevel(level, axis)[source]
fillna(value, method, axis, **kwargs)[source]
ffill(**kwargs)[source]
pad(**kwargs)
groupby(by, level, axis, as_index, group_keys, **kwargs)[source]
abs(**kwargs)
astype(**kwargs)
copy(**kwargs)
dtype
dtypes
index
class apache_beam.dataframe.frames.DeferredSeries(expr)[source]

Bases: apache_beam.dataframe.frames.DeferredDataFrameOrSeries

align(other, join, axis, level, method, **kwargs)[source]
array
rename(**kwargs)
between(**kwargs)
dot(other)[source]
std(axis, skipna, level, ddof, **kwargs)[source]
corr(other, method, min_periods)[source]
cov(other, min_periods, ddof)[source]
dropna(**kwargs)[source]
items(**kwargs)
iteritems(**kwargs)
isin(**kwargs)
isna(**kwargs)
notnull(**kwargs)
notna(**kwargs)
to_numpy(**kwargs)
to_string(**kwargs)
transform(**kwargs)
aggregate(func, axis=0, *args, **kwargs)[source]
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(**kwargs)
cummin(**kwargs)
cumsum(**kwargs)
cumprod(**kwargs)
diff(**kwargs)
head(**kwargs)
tail(**kwargs)
filter(**kwargs)
memory_usage(**kwargs)
nlargest(keep, **kwargs)[source]
nsmallest(keep, **kwargs)[source]
plot
pop(**kwargs)
rename_axis(**kwargs)
replace(limit, **kwargs)[source]
round(**kwargs)
searchsorted(**kwargs)
shift(**kwargs)
take(**kwargs)
to_dict(**kwargs)
to_frame(**kwargs)
unique(as_series=False)[source]
update(other)[source]
unstack(**kwargs)
values
view(**kwargs)
str
T
add(**kwargs)
add_prefix(**kwargs)
add_suffix(**kwargs)
and(**kwargs)
append(**kwargs)
apply(**kwargs)
argmax(**kwargs)
argmin(**kwargs)
argsort(**kwargs)
asfreq(**kwargs)
asof(**kwargs)
at
at_time(**kwargs)
attrs
autocorr(**kwargs)
backfill(**kwargs)
between_time(**kwargs)
bfill(**kwargs)
bool(**kwargs)
cat
combine(**kwargs)
combine_first(**kwargs)
compare(**kwargs)
convert_dtypes(**kwargs)
count(**kwargs)
describe(**kwargs)
div(**kwargs)
divide(**kwargs)
divmod(**kwargs)
drop(**kwargs)
drop_duplicates(**kwargs)
dt
duplicated(**kwargs)
empty
eq(**kwargs)
equals(**kwargs)
ewm(**kwargs)
expanding(**kwargs)
explode(**kwargs)
factorize(**kwargs)
first(**kwargs)
first_valid_index(**kwargs)
floordiv(**kwargs)
ge(**kwargs)
get(**kwargs)
gt(**kwargs)
hasnans
hist(**kwargs)
iat
idxmax(**kwargs)
idxmin(**kwargs)
iloc
infer_objects(**kwargs)
interpolate(**kwargs)
is_monotonic
is_monotonic_decreasing
is_monotonic_increasing
is_unique
isnull(**kwargs)
item(**kwargs)
keys(**kwargs)
kurt(**kwargs)
kurtosis(**kwargs)
last(**kwargs)
last_valid_index(**kwargs)
le(**kwargs)
loc
lt(**kwargs)
mad(**kwargs)
map(**kwargs)
mask(**kwargs)
mean(**kwargs)
median(**kwargs)
mod(**kwargs)
mode(**kwargs)
mul(**kwargs)
multiply(**kwargs)
name
nbytes
ndim
ne(**kwargs)
nunique(**kwargs)
or(**kwargs)
pct_change(**kwargs)
pipe(**kwargs)
pow(**kwargs)
quantile(**kwargs)
radd(**kwargs)
rand(**kwargs)
rank(**kwargs)
ravel(**kwargs)
rdiv(**kwargs)
rdivmod(**kwargs)
reindex(**kwargs)
reindex_like(**kwargs)
reorder_levels(**kwargs)
repeat(**kwargs)
resample(**kwargs)
reset_index(**kwargs)
rfloordiv(**kwargs)
rmod(**kwargs)
rmul(**kwargs)
rolling(**kwargs)
ror(**kwargs)
rpow(**kwargs)
rsub(**kwargs)
rtruediv(**kwargs)
sample(**kwargs)
sem(**kwargs)
set_axis(**kwargs)
shape
size
skew(**kwargs)
slice_shift(**kwargs)
sort_index(**kwargs)
sort_values(**kwargs)
sparse
squeeze(**kwargs)
sub(**kwargs)
subtract(**kwargs)
swapaxes(**kwargs)
swaplevel(**kwargs)
to_clipboard(**kwargs)
to_csv(**kwargs)
to_excel(**kwargs)
to_hdf(**kwargs)
to_json(**kwargs)
to_latex(**kwargs)
to_list(**kwargs)
to_markdown(**kwargs)
to_period(**kwargs)
to_pickle(**kwargs)
to_sql(**kwargs)
to_timestamp(**kwargs)
to_xarray(**kwargs)
tolist(**kwargs)
transpose(**kwargs)
truediv(**kwargs)
truncate(**kwargs)
tshift(**kwargs)
tz_convert(**kwargs)
tz_localize(**kwargs)
value_counts(**kwargs)
var(**kwargs)
where(**kwargs)
xs(**kwargs)
class apache_beam.dataframe.frames.DeferredDataFrame(expr)[source]

Bases: apache_beam.dataframe.frames.DeferredDataFrameOrSeries

T
columns
align(other, join, axis, copy, level, method, **kwargs)[source]
set_index(keys, **kwargs)[source]
loc
iloc
axes
dtypes
assign(**kwargs)[source]
explode(column, ignore_index)[source]
drop(labels, axis, index, columns, errors, **kwargs)[source]
aggregate(func, axis=0, *args, **kwargs)[source]
agg(func, axis=0, *args, **kwargs)
applymap(**kwargs)
memory_usage(**kwargs)
info(**kwargs)
all(*args, **kwargs)
any(*args, **kwargs)
clip(**kwargs)
corr(method, min_periods)[source]
cov(min_periods, ddof)[source]
corrwith(other, axis, drop, method)[source]
cummax(**kwargs)
cummin(**kwargs)
cumsum(**kwargs)
cumprod(**kwargs)
diff(**kwargs)
dot(other)[source]
head(**kwargs)
tail(**kwargs)
max(*args, **kwargs)
min(*args, **kwargs)
mode(axis=0, *args, **kwargs)[source]
dropna(axis, **kwargs)[source]
eval(expr, inplace, **kwargs)[source]
query(expr, inplace, **kwargs)[source]
isna(**kwargs)
notnull(**kwargs)
notna(**kwargs)
items(**kwargs)
itertuples(**kwargs)
iterrows(**kwargs)
iteritems(**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]
plot
pop(item)[source]
prod(*args, **kwargs)
product(*args, **kwargs)
quantile(axis, **kwargs)[source]
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(**kwargs)
to_records(**kwargs)
to_dict(**kwargs)
to_numpy(**kwargs)
to_string(**kwargs)
to_sparse(**kwargs)
transform(**kwargs)
transpose(**kwargs)
unstack(*args, **kwargs)[source]
update(**kwargs)
values
add(**kwargs)
add_prefix(**kwargs)
add_suffix(**kwargs)
and(**kwargs)
append(**kwargs)
apply(**kwargs)
asfreq(**kwargs)
asof(**kwargs)
at
at_time(**kwargs)
attrs
backfill(**kwargs)
between_time(**kwargs)
bfill(**kwargs)
bool(**kwargs)
boxplot(**kwargs)
combine(**kwargs)
combine_first(**kwargs)
compare(**kwargs)
convert_dtypes(**kwargs)
count(**kwargs)
describe(**kwargs)
div(**kwargs)
divide(**kwargs)
divmod(**kwargs)
drop_duplicates(**kwargs)
duplicated(**kwargs)
empty
eq(**kwargs)
equals(**kwargs)
ewm(**kwargs)
expanding(**kwargs)
filter(**kwargs)
first(**kwargs)
first_valid_index(**kwargs)
floordiv(**kwargs)
from_dict(**kwargs)
from_records(**kwargs)
ge(**kwargs)
get(**kwargs)
gt(**kwargs)
hist(**kwargs)
iat
idxmax(**kwargs)
idxmin(**kwargs)
infer_objects(**kwargs)
insert(**kwargs)
interpolate(**kwargs)
isin(**kwargs)
isnull(**kwargs)
keys(**kwargs)
kurt(**kwargs)
kurtosis(**kwargs)
last(**kwargs)
last_valid_index(**kwargs)
le(**kwargs)
lookup(**kwargs)
lt(**kwargs)
mad(**kwargs)
mask(**kwargs)
mean(**kwargs)
median(**kwargs)
melt(**kwargs)
mod(**kwargs)
mul(**kwargs)
multiply(**kwargs)
ndim
ne(**kwargs)
or(**kwargs)
pct_change(**kwargs)
pipe(**kwargs)
pivot(**kwargs)
pivot_table(**kwargs)
pow(**kwargs)
radd(**kwargs)
rand(**kwargs)
rank(**kwargs)
rdiv(**kwargs)
rdivmod(**kwargs)
reindex(**kwargs)
reindex_like(**kwargs)
reorder_levels(**kwargs)
resample(**kwargs)
rfloordiv(**kwargs)
rmod(**kwargs)
rmul(**kwargs)
rolling(**kwargs)
ror(**kwargs)
rpow(**kwargs)
rsub(**kwargs)
rtruediv(**kwargs)
sample(**kwargs)
sem(**kwargs)
set_axis(**kwargs)
size
skew(**kwargs)
slice_shift(**kwargs)
sort_index(**kwargs)
sparse
squeeze(**kwargs)
std(**kwargs)
style
sub(**kwargs)
subtract(**kwargs)
swapaxes(**kwargs)
swaplevel(**kwargs)
to_clipboard(**kwargs)
to_csv(path, *args, **kwargs)
to_excel(path, *args, **kwargs)
to_feather(path, *args, **kwargs)
to_gbq(**kwargs)
to_hdf(**kwargs)
to_html(path, *args, **kwargs)
to_json(path, orient=None, *args, **kwargs)
to_latex(**kwargs)
to_markdown(**kwargs)
to_msgpack(**kwargs)
to_parquet(path, *args, **kwargs)
to_period(**kwargs)
to_pickle(**kwargs)
to_sql(**kwargs)
to_stata(path, *args, **kwargs)
to_timestamp(**kwargs)
to_xarray(**kwargs)
truediv(**kwargs)
truncate(**kwargs)
tshift(**kwargs)
tz_convert(**kwargs)
tz_localize(**kwargs)
value_counts(**kwargs)
var(**kwargs)
where(**kwargs)
xs(**kwargs)
class apache_beam.dataframe.frames.DeferredGroupBy(expr, kwargs)[source]

Bases: apache_beam.dataframe.frame_base.DeferredFrame

agg(fn)[source]
aggregate(fn)
first(**kwargs)
last(**kwargs)
head(**kwargs)
tail(**kwargs)
groups
all(*args, **kwargs)
any(*args, **kwargs)
apply(**kwargs)
backfill(**kwargs)
bfill(**kwargs)
boxplot(**kwargs)
corr
corrwith
count(*args, **kwargs)
cov
cumcount(**kwargs)
cummax(**kwargs)
cummin(**kwargs)
cumprod(**kwargs)
cumsum(**kwargs)
describe(**kwargs)
diff
expanding(**kwargs)
ffill(**kwargs)
fillna
filter(**kwargs)
get_group(**kwargs)
hist
idxmax
idxmin
indices
mad
max(*args, **kwargs)
mean(*args, **kwargs)
median(*args, **kwargs)
min(*args, **kwargs)
ngroup(**kwargs)
ngroups
nth(**kwargs)
nunique(**kwargs)
ohlc(**kwargs)
pad(**kwargs)
pct_change(**kwargs)
pipe(**kwargs)
plot
prod(*args, **kwargs)
quantile(**kwargs)
rank(**kwargs)
resample(**kwargs)
rolling(**kwargs)
sample(**kwargs)
sem(**kwargs)
shift(**kwargs)
size(*args, **kwargs)
skew
std(*args, **kwargs)
sum(*args, **kwargs)
take
transform(**kwargs)
tshift
var(*args, **kwargs)
apache_beam.dataframe.frames.make_str_func(method)[source]