apache_beam.dataframe.frame_base module

class apache_beam.dataframe.frame_base.DeferredBase(expr)

Bases: object

classmethod wrap(expr, split_tuples=True)

class apache_beam.dataframe.frame_base.UnusableUnpickledDeferredBase(name)

Bases: object

Placeholder object used to break the transitive pickling chain in case a DeferredBase accidentially gets pickled (e.g. as part of globals).

Trying to use this object after unpickling is a bug and will result in an error.

class apache_beam.dataframe.frame_base.DeferredFrame(expr)

Bases: apache_beam.dataframe.frame_base.DeferredBase

dtypes

apache_beam.dataframe.frame_base.name_and_func(method)

apache_beam.dataframe.frame_base.wont_implement_method(msg)

apache_beam.dataframe.frame_base.not_implemented_method(op, jira='BEAM-9547')

apache_beam.dataframe.frame_base.copy_and_mutate(func)

apache_beam.dataframe.frame_base.maybe_inplace(func)

apache_beam.dataframe.frame_base.args_to_kwargs(base_type)

apache_beam.dataframe.frame_base.populate_defaults(base_type)

exception apache_beam.dataframe.frame_base.WontImplementError

Bases: NotImplementedError

An subclass of NotImplementedError to raise indicating that implementing the given method is infeasible.

Raising this error will also prevent this doctests from being validated when run with the beam dataframe validation doctest runner.