apache_beam.utils.plugin module¶

A BeamPlugin base class.

class apache_beam.utils.plugin.BeamPlugin[source]¶

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.