MCPcopy Create free account

hub / github.com/amplab/training-scripts / functions

Functions38 in github.com/amplab/training-scripts

↓ 19 callersFunctionssh
(host, opts, command)
spark_ec2.py:703
↓ 9 callersFunctionget_existing_cluster
(conn, opts, cluster_name, die_on_error=True)
spark_ec2.py:365
↓ 3 callersFunctioncopy_ampcamp_data_from_ebs
(master_nodes, opts)
spark_ec2.py:468
↓ 3 callersFunctionget_or_make_group
(conn, name)
spark_ec2.py:141
↓ 3 callersFunctionwait_for_instances
(conn, instances)
spark_ec2.py:153
↓ 3 callersFunctionwait_for_spark_cluster
(master_nodes, opts)
spark_ec2.py:733
↓ 2 callersFunctioncheck_spark_cluster
(master_nodes, opts)
spark_ec2.py:450
↓ 2 callersFunctioncheck_spark_master
(master_hostname)
check_spark.py:39
↓ 2 callersFunctionget_cluster_masters
(prefix="")
get_masters.py:23
↓ 2 callersFunctionget_partition
(total, num_partitions, current_partitions)
spark_ec2.py:727
↓ 2 callersFunctionget_zones
(conn, opts)
spark_ec2.py:718
↓ 2 callersFunctionsetup_cluster
(conn, master_nodes, slave_nodes, zoo_nodes, opts, deploy_ssh_key)
spark_ec2.py:402
↓ 2 callersFunctionwait_and_check
(subprocesses, cluster_names, opts)
launch_ampcamp4_cluster.py:113
↓ 2 callersFunctionwait_for_cluster
(conn, wait_secs, master_nodes, slave_nodes, zoo_nodes)
spark_ec2.py:567
↓ 1 callersFunctioncheck_all_masters
()
check_spark.py:23
↓ 1 callersFunctioncheck_spark_json
(spark_json)
check_spark.py:50
↓ 1 callersFunctioncheck_spark_json
(spark_json, opts)
spark_ec2.py:432
↓ 1 callersFunctiondeploy_files
(conn, root_dir, opts, master_nodes, slave_nodes, zoo_nodes, modules)
spark_ec2.py:632
↓ 1 callersFunctionget_num_cpus
(instance_type)
spark_ec2.py:604
↓ 1 callersFunctionget_num_disks
(instance_type)
spark_ec2.py:579
↓ 1 callersFunctionget_s3_keys
()
spark_ec2.py:554
↓ 1 callersFunctionget_s3_kv
(bucket, key)
set_ampcamp_ami.py:29
↓ 1 callersFunctionis_active
(instance)
check_spark.py:11
↓ 1 callersFunctionis_active
(instance)
spark_ec2.py:166
↓ 1 callersFunctionis_active
(instance)
get_masters.py:11
↓ 1 callersFunctionlaunch_cluster
(conn, opts, cluster_name)
spark_ec2.py:175
↓ 1 callersFunctionmain
()
launch_ampcamp4_cluster.py:57
↓ 1 callersFunctionmain
()
check_spark.py:14
↓ 1 callersFunctionmain
()
set_ampcamp_ami.py:8
↓ 1 callersFunctionmain
()
spark_ec2.py:746
↓ 1 callersFunctionmain
()
get_masters.py:14
↓ 1 callersFunctionparse_args
()
launch_ampcamp4_cluster.py:12
↓ 1 callersFunctionparse_args
()
spark_ec2.py:43
↓ 1 callersFunctionscp
(host, opts, local_file, dest_file)
spark_ec2.py:696
↓ 1 callersFunctionset_s3_keys_in_hdfs
(master, opts, s3_access_key, s3_secret_key)
spark_ec2.py:544
↓ 1 callersFunctionset_s3_kv
(bucket, key, value)
set_ampcamp_ami.py:19
↓ 1 callersFunctionsetup_spark_cluster
(master, opts)
spark_ec2.py:428
Functioncopy_ampcamp_data_from_s3
(master_nodes, opts)
spark_ec2.py:487