8706

Build # 8706

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/a833171d071533f66e5f3eda9d6aaeb71596e4c8">a833171d0<a href="https://github.com/apache/carbondata/commit/a833171d071533f66e5f3eda9d6aaeb71596e4c8">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/7b34abbe14e213207a10f62bdcc16c0e36fa9375">7b34abbe1</a>">7b34abbe1</a><a href="https://github.com/apache/carbondata/commit/a833171d071533f66e5f3eda9d6aaeb71596e4c8"> into e3eb03054">e3eb03054</a>

Run Details

25 of 25 new or added lines in 5 files covered. (100.0%)

59874 of 74258 relevant lines covered (80.63%)

1.07 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

70.37

/datamap/bloom/src/main/java/org/apache/carbondata/datamap/bloom/BloomIndexFileStore.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.apache.carbondata.datamap.bloom;

import java.io.*;
import java.nio.charset.Charset;
import java.util.ArrayList;
import java.util.List;

import org.apache.carbondata.common.annotations.InterfaceAudience;
import org.apache.carbondata.common.logging.LogService;
import org.apache.carbondata.common.logging.LogServiceFactory;
import org.apache.carbondata.core.datastore.filesystem.CarbonFile;
import org.apache.carbondata.core.datastore.filesystem.CarbonFileFilter;
import org.apache.carbondata.core.datastore.impl.FileFactory;
import org.apache.carbondata.core.util.CarbonUtil;

import org.apache.hadoop.fs.Path;
import org.apache.hadoop.util.bloom.CarbonBloomFilter;

/**
 * This class works for merging and loading bloom index
 */
@InterfaceAudience.Internal
public class BloomIndexFileStore {

  private static final LogService LOGGER =
          LogServiceFactory.getLogService(BloomIndexFileStore.class.getName());

  // suffix of original generated file
  public static final String BLOOM_INDEX_SUFFIX = ".bloomindex";
  // suffix of merged bloom index file
  public static final String MERGE_BLOOM_INDEX_SUFFIX = ".bloomindexmerge";
  // directory to store merged bloom index files
  public static final String MERGE_BLOOM_INDEX_SHARD_NAME = "mergeShard";
  // prefix for the bloom index file name, the file name looks like 'version_1.5.0', means that the
  // bloom index file is generated by carbon 1.5.0 afterwards. The corresponding file is empty,
  // the file name indicates the version of file. This file is new since 1.5.0 for compatibility.
  public static final String BLOOM_INDEX_VERSION_PREFIX = "version_";
  /**
   * flag file for merging
   * if flag file exists, query won't use mergeShard
   * if flag file not exists and mergeShard generated, query will use mergeShard
   */
  public static final String MERGE_INPROGRESS_FILE = "mergeShard.inprogress";


  public static void mergeBloomIndexFile(String dmSegmentPathString, List<String> indexCols) {
    // get all shard paths of old store
    CarbonFile segmentPath = FileFactory.getCarbonFile(dmSegmentPathString,
            FileFactory.getFileType(dmSegmentPathString));
    CarbonFile[] shardPaths = segmentPath.listFiles(new CarbonFileFilter() {
      @Override
      public boolean accept(CarbonFile file) {
        return file.isDirectory() && !file.getName().equals(MERGE_BLOOM_INDEX_SHARD_NAME);
      }
    });

    String mergeShardPath = dmSegmentPathString + File.separator + MERGE_BLOOM_INDEX_SHARD_NAME;
    String mergeInprogressFile = dmSegmentPathString + File.separator + MERGE_INPROGRESS_FILE;
    try {
      // delete mergeShard folder if exists
      if (FileFactory.isFileExist(mergeShardPath)) {
        FileFactory.deleteFile(mergeShardPath, FileFactory.getFileType(mergeShardPath));
      }
      // create flag file before creating mergeShard folder
      if (!FileFactory.isFileExist(mergeInprogressFile)) {
        FileFactory.createNewFile(
            mergeInprogressFile, FileFactory.getFileType(mergeInprogressFile));
      }
      // create mergeShard output folder
      if (!FileFactory.mkdirs(mergeShardPath, FileFactory.getFileType(mergeShardPath))) {
        throw new RuntimeException("Failed to create directory " + mergeShardPath);
      }
    } catch (IOException e) {
      LOGGER.error(e, "Error occurs while create directory " + mergeShardPath);
      throw new RuntimeException("Error occurs while create directory " + mergeShardPath);
    }

    // for each index column, merge the bloomindex files from all shards into one
    for (String indexCol: indexCols) {
      String mergeIndexFile = getMergeBloomIndexFile(mergeShardPath, indexCol);
      DataInputStream dataInputStream = null;
      DataOutputStream dataOutputStream = null;
      try {
        FileFactory.createNewFile(mergeIndexFile, FileFactory.getFileType(mergeIndexFile));
        dataOutputStream = FileFactory.getDataOutputStream(
            mergeIndexFile, FileFactory.getFileType(mergeIndexFile));
        for (CarbonFile shardPath : shardPaths) {
          String bloomIndexFile = getBloomIndexFile(shardPath.getCanonicalPath(), indexCol);
          dataInputStream = FileFactory.getDataInputStream(
              bloomIndexFile, FileFactory.getFileType(bloomIndexFile));
          byte[] fileData = new byte[(int) FileFactory.getCarbonFile(bloomIndexFile).getSize()];
          dataInputStream.readFully(fileData);
          byte[] shardName = shardPath.getName().getBytes(Charset.forName("UTF-8"));
          dataOutputStream.writeInt(shardName.length);
          dataOutputStream.write(shardName);
          dataOutputStream.writeInt(fileData.length);
          dataOutputStream.write(fileData);
          CarbonUtil.closeStream(dataInputStream);
        }
      } catch (IOException e) {
        LOGGER.error(e, "Error occurs while merge bloom index file of column: " + indexCol);
        // delete merge shard of bloom index for this segment when failed
        FileFactory.deleteAllCarbonFilesOfDir(FileFactory.getCarbonFile(mergeShardPath));
        throw new RuntimeException(
            "Error occurs while merge bloom index file of column: " + indexCol);
      } finally {
        CarbonUtil.closeStreams(dataInputStream, dataOutputStream);
      }
    }
    // delete flag file and mergeShard can be used
    try {
      FileFactory.deleteFile(mergeInprogressFile, FileFactory.getFileType(mergeInprogressFile));
    } catch (IOException e) {
      LOGGER.error(e, "Error occurs while deleting file " + mergeInprogressFile);
      throw new RuntimeException("Error occurs while deleting file " + mergeInprogressFile);
    }
    // remove old store
    for (CarbonFile shardpath: shardPaths) {
      FileFactory.deleteAllCarbonFilesOfDir(shardpath);
    }
  }

  /**
   * write index version file under the segment folder.
   * before 1.5.0, the file does not exist.
   */
  public static void writeBloomIndexVersionFile(String dmSegmentPath) throws IOException {
    String indexVersionFile = dmSegmentPath + File.separator + BLOOM_INDEX_VERSION_PREFIX + "1.5.0";
    if (!FileFactory.isFileExist(indexVersionFile, FileFactory.getFileType(indexVersionFile))) {
      FileFactory.createNewFile(indexVersionFile, FileFactory.getFileType(indexVersionFile));
    }
  }
  /**
   * load bloom filter from bloom index file
   */
  public static List<CarbonBloomFilter> loadBloomFilterFromFile(
          String shardPath, String colName) {
    if (shardPath.endsWith(MERGE_BLOOM_INDEX_SHARD_NAME)) {
      return loadMergeBloomIndex(shardPath, colName);
    } else {
      return loadBloomIndex(shardPath, colName);
    }
  }

  /**
   * load bloom filter of {@code colName} from {@code shardPath}
   */
  public static List<CarbonBloomFilter> loadBloomIndex(
          String shardPath, String colName) {
    DataInputStream dataInStream = null;
    List<CarbonBloomFilter> bloomFilters = new ArrayList<>();
    try {
      String indexFile = getBloomIndexFile(shardPath, colName);
      dataInStream = FileFactory.getDataInputStream(indexFile, FileFactory.getFileType(indexFile));
      while (dataInStream.available() > 0) {
        CarbonBloomFilter bloomFilter = new CarbonBloomFilter();
        bloomFilter.readFields(dataInStream);
        bloomFilter.setShardName(new Path(shardPath).getName());
        bloomFilters.add(bloomFilter);
      }
      LOGGER.info(String.format("Read %d bloom indices from %s", bloomFilters.size(), indexFile));

      return bloomFilters;
    } catch (IOException e) {
      LOGGER.error(e, "Error occurs while reading bloom index");
      throw new RuntimeException("Error occurs while reading bloom index", e);
    } finally {
      CarbonUtil.closeStreams(dataInStream);
    }
  }


  /**
   * load bloom filter of {@code colName} from {@code mergeShardPath}
   */
  public static List<CarbonBloomFilter> loadMergeBloomIndex(
          String mergeShardPath, String colName) {
    String mergeIndexFile = getMergeBloomIndexFile(mergeShardPath, colName);
    DataInputStream mergeIndexInStream = null;
    List<CarbonBloomFilter> bloomFilters = new ArrayList<>();
    try {
      mergeIndexInStream = FileFactory.getDataInputStream(
          mergeIndexFile, FileFactory.getFileType(mergeIndexFile));
      while (mergeIndexInStream.available() > 0) {
        // read shard name
        int shardNameByteLength = mergeIndexInStream.readInt();
        byte[] shardNameBytes = new byte[shardNameByteLength];
        mergeIndexInStream.readFully(shardNameBytes);
        String shardName = new String(shardNameBytes, Charset.forName("UTF-8"));
        // read bloom index file data
        int indexFileByteLength = mergeIndexInStream.readInt();
        byte[] indexFileBytes = new byte[indexFileByteLength];
        mergeIndexInStream.readFully(indexFileBytes);
        // warp byte array as input stream to get bloom filters
        ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(indexFileBytes);
        DataInputStream indexDataInStream = new DataInputStream(byteArrayInputStream);
        while (indexDataInStream.available() > 0) {
          CarbonBloomFilter bloomFilter = new CarbonBloomFilter();
          bloomFilter.readFields(indexDataInStream);
          bloomFilter.setShardName(shardName);
          bloomFilters.add(bloomFilter);
        }
      }
      LOGGER.info(
          String.format("Read %d bloom indices from %s", bloomFilters.size(), mergeIndexFile));
      return bloomFilters;
    } catch (IOException e) {
      LOGGER.error(e, "Error occurs while reading merge bloom index");
      throw new RuntimeException("Error occurs while reading merge bloom index", e);
    } finally {
      CarbonUtil.closeStreams(mergeIndexInStream);
    }
  }

  /**
   * get bloom index file
   */
  public static String getBloomIndexFile(String shardPath, String colName) {
    return shardPath.concat(File.separator).concat(colName).concat(BLOOM_INDEX_SUFFIX);
  }

  /**
   * get merge bloom index file
   */
  public static String getMergeBloomIndexFile(String mergeShardPath, String colName) {
    return mergeShardPath.concat(File.separator).concat(colName).concat(MERGE_BLOOM_INDEX_SUFFIX);
  }
}

1	/*
2	* Licensed to the Apache Software Foundation (ASF) under one or more
3	* contributor license agreements. See the NOTICE file distributed with
4	* this work for additional information regarding copyright ownership.
5	* The ASF licenses this file to You under the Apache License, Version 2.0
6	* (the "License"); you may not use this file except in compliance with
7	* the License. You may obtain a copy of the License at
8	*
9	* http://www.apache.org/licenses/LICENSE-2.0
10	*
11	* Unless required by applicable law or agreed to in writing, software
12	* distributed under the License is distributed on an "AS IS" BASIS,
13	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14	* See the License for the specific language governing permissions and
15	* limitations under the License.
16	*/
17	package org.apache.carbondata.datamap.bloom;
18
19	import java.io.*;
20	import java.nio.charset.Charset;
21	import java.util.ArrayList;
22	import java.util.List;
23
24	import org.apache.carbondata.common.annotations.InterfaceAudience;
25	import org.apache.carbondata.common.logging.LogService;
26	import org.apache.carbondata.common.logging.LogServiceFactory;
27	import org.apache.carbondata.core.datastore.filesystem.CarbonFile;
28	import org.apache.carbondata.core.datastore.filesystem.CarbonFileFilter;
29	import org.apache.carbondata.core.datastore.impl.FileFactory;
30	import org.apache.carbondata.core.util.CarbonUtil;
31
32	import org.apache.hadoop.fs.Path;
33	import org.apache.hadoop.util.bloom.CarbonBloomFilter;
34
35	/**
36	* This class works for merging and loading bloom index
37	*/
38	@InterfaceAudience.Internal
39	public class BloomIndexFileStore {	×
40
41	private static final LogService LOGGER =	1✔
42	LogServiceFactory.getLogService(BloomIndexFileStore.class.getName());	1✔
43
44	// suffix of original generated file
45	public static final String BLOOM_INDEX_SUFFIX = ".bloomindex";
46	// suffix of merged bloom index file
47	public static final String MERGE_BLOOM_INDEX_SUFFIX = ".bloomindexmerge";
48	// directory to store merged bloom index files
49	public static final String MERGE_BLOOM_INDEX_SHARD_NAME = "mergeShard";
50	// prefix for the bloom index file name, the file name looks like 'version_1.5.0', means that the
51	// bloom index file is generated by carbon 1.5.0 afterwards. The corresponding file is empty,
52	// the file name indicates the version of file. This file is new since 1.5.0 for compatibility.
53	public static final String BLOOM_INDEX_VERSION_PREFIX = "version_";
54	/**
55	* flag file for merging
56	* if flag file exists, query won't use mergeShard
57	* if flag file not exists and mergeShard generated, query will use mergeShard
58	*/
59	public static final String MERGE_INPROGRESS_FILE = "mergeShard.inprogress";
60
61
62	public static void mergeBloomIndexFile(String dmSegmentPathString, List<String> indexCols) {
63	// get all shard paths of old store
64	CarbonFile segmentPath = FileFactory.getCarbonFile(dmSegmentPathString,	1✔
65	FileFactory.getFileType(dmSegmentPathString));	1✔
66	CarbonFile[] shardPaths = segmentPath.listFiles(new CarbonFileFilter() {	1✔
67	@Override
68	public boolean accept(CarbonFile file) {
69	return file.isDirectory() && !file.getName().equals(MERGE_BLOOM_INDEX_SHARD_NAME);	1✔
70	}
71	});
72
73	String mergeShardPath = dmSegmentPathString + File.separator + MERGE_BLOOM_INDEX_SHARD_NAME;	1✔
74	String mergeInprogressFile = dmSegmentPathString + File.separator + MERGE_INPROGRESS_FILE;	1✔
75	try {
76	// delete mergeShard folder if exists
77	if (FileFactory.isFileExist(mergeShardPath)) {	1✔
78	FileFactory.deleteFile(mergeShardPath, FileFactory.getFileType(mergeShardPath));	1✔
79	}
80	// create flag file before creating mergeShard folder
81	if (!FileFactory.isFileExist(mergeInprogressFile)) {	1✔
82	FileFactory.createNewFile(	1✔
83	mergeInprogressFile, FileFactory.getFileType(mergeInprogressFile));	1✔
84	}
85	// create mergeShard output folder
86	if (!FileFactory.mkdirs(mergeShardPath, FileFactory.getFileType(mergeShardPath))) {	1✔
87	throw new RuntimeException("Failed to create directory " + mergeShardPath);	×
88	}
89	} catch (IOException e) {	×
90	LOGGER.error(e, "Error occurs while create directory " + mergeShardPath);	×
91	throw new RuntimeException("Error occurs while create directory " + mergeShardPath);	×
92	}	1✔
93
94	// for each index column, merge the bloomindex files from all shards into one
95	for (String indexCol: indexCols) {	1✔
96	String mergeIndexFile = getMergeBloomIndexFile(mergeShardPath, indexCol);	1✔
97	DataInputStream dataInputStream = null;	1✔
98	DataOutputStream dataOutputStream = null;	1✔
99	try {
100	FileFactory.createNewFile(mergeIndexFile, FileFactory.getFileType(mergeIndexFile));	1✔
101	dataOutputStream = FileFactory.getDataOutputStream(	1✔
102	mergeIndexFile, FileFactory.getFileType(mergeIndexFile));	1✔
103	for (CarbonFile shardPath : shardPaths) {	1✔
104	String bloomIndexFile = getBloomIndexFile(shardPath.getCanonicalPath(), indexCol);	1✔
105	dataInputStream = FileFactory.getDataInputStream(	1✔
106	bloomIndexFile, FileFactory.getFileType(bloomIndexFile));	1✔
107	byte[] fileData = new byte[(int) FileFactory.getCarbonFile(bloomIndexFile).getSize()];	1✔
108	dataInputStream.readFully(fileData);	1✔
109	byte[] shardName = shardPath.getName().getBytes(Charset.forName("UTF-8"));	1✔
110	dataOutputStream.writeInt(shardName.length);	1✔
111	dataOutputStream.write(shardName);	1✔
112	dataOutputStream.writeInt(fileData.length);	1✔
113	dataOutputStream.write(fileData);	1✔
114	CarbonUtil.closeStream(dataInputStream);	1✔
115	}
116	} catch (IOException e) {	×
117	LOGGER.error(e, "Error occurs while merge bloom index file of column: " + indexCol);	×
118	// delete merge shard of bloom index for this segment when failed
119	FileFactory.deleteAllCarbonFilesOfDir(FileFactory.getCarbonFile(mergeShardPath));	×
120	throw new RuntimeException(	×
121	"Error occurs while merge bloom index file of column: " + indexCol);
122	} finally {
123	CarbonUtil.closeStreams(dataInputStream, dataOutputStream);	1✔
124	}	1✔
125	}	1✔
126	// delete flag file and mergeShard can be used
127	try {
128	FileFactory.deleteFile(mergeInprogressFile, FileFactory.getFileType(mergeInprogressFile));	1✔
129	} catch (IOException e) {	×
130	LOGGER.error(e, "Error occurs while deleting file " + mergeInprogressFile);	×
131	throw new RuntimeException("Error occurs while deleting file " + mergeInprogressFile);	×
132	}	1✔
133	// remove old store
134	for (CarbonFile shardpath: shardPaths) {	1✔
135	FileFactory.deleteAllCarbonFilesOfDir(shardpath);	1✔
136	}
137	}	1✔
138
139	/**
140	* write index version file under the segment folder.
141	* before 1.5.0, the file does not exist.
142	*/
143	public static void writeBloomIndexVersionFile(String dmSegmentPath) throws IOException {
144	String indexVersionFile = dmSegmentPath + File.separator + BLOOM_INDEX_VERSION_PREFIX + "1.5.0";	1✔
145	if (!FileFactory.isFileExist(indexVersionFile, FileFactory.getFileType(indexVersionFile))) {	1✔
146	FileFactory.createNewFile(indexVersionFile, FileFactory.getFileType(indexVersionFile));	1✔
147	}
148	}	1✔
149	/**
150	* load bloom filter from bloom index file
151	*/
152	public static List<CarbonBloomFilter> loadBloomFilterFromFile(
153	String shardPath, String colName) {
154	if (shardPath.endsWith(MERGE_BLOOM_INDEX_SHARD_NAME)) {	1✔
155	return loadMergeBloomIndex(shardPath, colName);	1✔
156	} else {
157	return loadBloomIndex(shardPath, colName);	×
158	}
159	}
160
161	/**
162	* load bloom filter of {@code colName} from {@code shardPath}
163	*/
164	public static List<CarbonBloomFilter> loadBloomIndex(
165	String shardPath, String colName) {
166	DataInputStream dataInStream = null;	×
167	List<CarbonBloomFilter> bloomFilters = new ArrayList<>();	×
168	try {
169	String indexFile = getBloomIndexFile(shardPath, colName);	×
170	dataInStream = FileFactory.getDataInputStream(indexFile, FileFactory.getFileType(indexFile));	×
171	while (dataInStream.available() > 0) {	×
172	CarbonBloomFilter bloomFilter = new CarbonBloomFilter();	×
173	bloomFilter.readFields(dataInStream);	×
174	bloomFilter.setShardName(new Path(shardPath).getName());	×
175	bloomFilters.add(bloomFilter);	×
176	}	×
177	LOGGER.info(String.format("Read %d bloom indices from %s", bloomFilters.size(), indexFile));	×
178
179	return bloomFilters;	×
180	} catch (IOException e) {	×
181	LOGGER.error(e, "Error occurs while reading bloom index");	×
182	throw new RuntimeException("Error occurs while reading bloom index", e);	×
183	} finally {
184	CarbonUtil.closeStreams(dataInStream);	×
185	}
186	}
187
188
189	/**
190	* load bloom filter of {@code colName} from {@code mergeShardPath}
191	*/
192	public static List<CarbonBloomFilter> loadMergeBloomIndex(
193	String mergeShardPath, String colName) {
194	String mergeIndexFile = getMergeBloomIndexFile(mergeShardPath, colName);	1✔
195	DataInputStream mergeIndexInStream = null;	1✔
196	List<CarbonBloomFilter> bloomFilters = new ArrayList<>();	1✔
197	try {
198	mergeIndexInStream = FileFactory.getDataInputStream(	1✔
199	mergeIndexFile, FileFactory.getFileType(mergeIndexFile));	1✔
200	while (mergeIndexInStream.available() > 0) {	1✔
201	// read shard name
202	int shardNameByteLength = mergeIndexInStream.readInt();	1✔
203	byte[] shardNameBytes = new byte[shardNameByteLength];	1✔
204	mergeIndexInStream.readFully(shardNameBytes);	1✔
205	String shardName = new String(shardNameBytes, Charset.forName("UTF-8"));	1✔
206	// read bloom index file data
207	int indexFileByteLength = mergeIndexInStream.readInt();	1✔
208	byte[] indexFileBytes = new byte[indexFileByteLength];	1✔
209	mergeIndexInStream.readFully(indexFileBytes);	1✔
210	// warp byte array as input stream to get bloom filters
211	ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(indexFileBytes);	1✔
212	DataInputStream indexDataInStream = new DataInputStream(byteArrayInputStream);	1✔
213	while (indexDataInStream.available() > 0) {	1✔
214	CarbonBloomFilter bloomFilter = new CarbonBloomFilter();	1✔
215	bloomFilter.readFields(indexDataInStream);	1✔
216	bloomFilter.setShardName(shardName);	1✔
217	bloomFilters.add(bloomFilter);	1✔
218	}	1✔
219	}	1✔
220	LOGGER.info(	1✔
221	String.format("Read %d bloom indices from %s", bloomFilters.size(), mergeIndexFile));	1✔
222	return bloomFilters;	1✔
223	} catch (IOException e) {	×
224	LOGGER.error(e, "Error occurs while reading merge bloom index");	×
225	throw new RuntimeException("Error occurs while reading merge bloom index", e);	×
226	} finally {
227	CarbonUtil.closeStreams(mergeIndexInStream);	1✔
228	}
229	}
230
231	/**
232	* get bloom index file
233	*/
234	public static String getBloomIndexFile(String shardPath, String colName) {
235	return shardPath.concat(File.separator).concat(colName).concat(BLOOM_INDEX_SUFFIX);	1✔
236	}
237
238	/**
239	* get merge bloom index file
240	*/
241	public static String getMergeBloomIndexFile(String mergeShardPath, String colName) {
242	return mergeShardPath.concat(File.separator).concat(colName).concat(MERGE_BLOOM_INDEX_SUFFIX);	1✔
243	}
244	}

apache / carbondata / 8706

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous