apache_beam.utils.plugin module

A BeamPlugin base class.

class apache_beam.utils.plugin.BeamPlugin

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

Get all the subclasses of the BeamPlugin class.

classmethod get_all_plugin_paths()

Get full import paths of the BeamPlugin subclass.