| 25 | return stdin, stdout, stderr |
| 26 | |
| 27 | def parse_input(): |
| 28 | parser = argparse.ArgumentParser() |
| 29 | parser.add_argument('--conf', type=str, help='A file describes the zk cluster') |
| 30 | parser.add_argument('--docker', type=str, default='lylei/tera:latest', help='ID of the docker image') |
| 31 | parser.add_argument('--zk', action='store_true', help='Launch zk') |
| 32 | parser.add_argument('--hdfs', action='store_true', help='Launch hdfs') |
| 33 | parser.add_argument('--tera', action='store_true', help='Launch tera') |
| 34 | args = parser.parse_args() |
| 35 | return args |
| 36 | |
| 37 | def config(args): |
| 38 | config = {} |