apache_beam.utils.plugin module
A BeamPlugin base class.
For experimental usage only; no backwards-compatibility guarantees.
-
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.