apache_beam.utils.plugin module

A BeamPlugin base class.

class apache_beam.utils.plugin.BeamPlugin[source]

Bases: object

Plugin base class to be extended by dependent users such as FileSystem. Any instantiated subclass will be imported at worker startup time.

classmethod get_all_subclasses()[source]

Get all the subclasses of the BeamPlugin class.

classmethod get_all_plugin_paths()[source]

Get full import paths of the BeamPlugin subclass.