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.