(args)
| 83 | f.close() |
| 84 | |
| 85 | def write_maters_slaves(args): |
| 86 | f = open(conf_path_prefix + 'masters', 'wb') |
| 87 | f.write(args.masters) |
| 88 | f.close() |
| 89 | |
| 90 | f = open(conf_path_prefix + 'slaves', 'wb') |
| 91 | slaves = '\n'.join(args.slaves) |
| 92 | f.write(slaves) |
| 93 | f.close() |
| 94 | |
| 95 | def start_hdfs(args): |
| 96 | cmd_prefix = '/opt/hadoop-1.2.1/bin/hadoop-daemon.sh --config /opt/hadoop-1.2.1/' |