()
| 96 | s.run_cmd(tera_instance.ip, cmd) |
| 97 | |
| 98 | def main(): |
| 99 | args = parse_input() |
| 100 | zk_cluster, hdfs_cluster, tera_cluster = config(args) |
| 101 | s = SSH() |
| 102 | start_zk(args, zk_cluster, s) |
| 103 | start_hdfs(args, hdfs_cluster, s) |
| 104 | start_tera(args, tera_cluster, zk_cluster, hdfs_cluster, s) |
| 105 | |
| 106 | if __name__ == '__main__': |
| 107 | main() |
no test coverage detected