apache_beam.runners.interactive.dataproc package

Submodules

• apache_beam.runners.interactive.dataproc.dataproc_cluster_manager module
  • DataprocClusterManager
    • DataprocClusterManager.stage_init_action()
    • DataprocClusterManager.create_cluster()
    • DataprocClusterManager.create_flink_cluster()
    • DataprocClusterManager.cleanup()
    • DataprocClusterManager.get_cluster_details()
    • DataprocClusterManager.wait_for_cluster_to_provision()
    • DataprocClusterManager.get_staging_location()
    • DataprocClusterManager.parse_master_url_and_dashboard()
    • DataprocClusterManager.get_master_url_and_dashboard()
    • DataprocClusterManager.cleanup_staging_files()
• apache_beam.runners.interactive.dataproc.types module
  • ClusterMetadata
    • ClusterMetadata.project_id
    • ClusterMetadata.region
    • ClusterMetadata.cluster_name
    • ClusterMetadata.subnetwork
    • ClusterMetadata.num_workers
    • ClusterMetadata.machine_type
    • ClusterMetadata.master_url
    • ClusterMetadata.dashboard
    • ClusterMetadata.reset_name()