def __init__(self, testfiles_path, start_cluster=True, nnport=None):
        self._testfiles_path = testfiles_path
        self._hadoop_home = os.environ['HADOOP_HOME']
        self._jobclient_jar = os.environ.get('HADOOP_JOBCLIENT_JAR')
        self._hadoop_cmd = "%s/bin/hadoop" % self._hadoop_home
        if start_cluster:
            self._start_mini_cluster(nnport)
            self.host = "localhost"
            self.port = self._get_namenode_port()
            self.hdfs_url = "hdfs://%s:%d" % (self.host, self.port)
        else:
            self.hdfs_url = "hdfs://"
Force each sample to have 3 GL's (0/0, 0/1, 1/1).
dataset/ETHPy150Open spotify/snakebite/snakebite/minicluster.py/MiniCluster.__init__--crossover with--dataset/ETHPy150Open arq5x/gemini/gemini/gemini_load_chunk.py/get_phred_lik