HBASE-1215 fix for jon currently migrating
git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@796939 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
91abbb4793
commit
924cc198b9
|
@ -123,10 +123,14 @@ public class HStoreFileToStoreFile {
|
|||
throw new IOException(family.toString() + " has " + familyStatus.length +
|
||||
" files.");
|
||||
}
|
||||
// If we got here, then this is good. Add the mapfile to out
|
||||
String str = familyStatus[0].getPath().makeQualified(fs).toString();
|
||||
LOG.info(str);
|
||||
out.write(Bytes.toBytes(str + "\n"));
|
||||
if (familyStatus.length == 1) {
|
||||
// If we got here, then this is good. Add the mapfile to out
|
||||
String str = familyStatus[0].getPath().makeQualified(fs).toString();
|
||||
LOG.info(str);
|
||||
out.write(Bytes.toBytes(str + "\n"));
|
||||
} else {
|
||||
LOG.warn("Empty store " + family.toString());
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
@ -154,4 +158,4 @@ public class HStoreFileToStoreFile {
|
|||
FileOutputFormat.setOutputPath(job, output);
|
||||
System.exit(job.waitForCompletion(true) ? 0 : 1);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
@ -70,10 +70,6 @@ import org.apache.hadoop.hbase.util.Hash;
|
|||
* contract <a href="http://www.one-lab.org">European Commission One-Lab Project 034819</a>.
|
||||
*
|
||||
* @version 1.0 - 2 Feb. 07
|
||||
*
|
||||
* @see org.onelab.filter.Filter The general behavior of a filter
|
||||
*
|
||||
* @see <a href="http://portal.acm.org/citation.cfm?id=362692&dl=ACM&coll=portal">Space/Time Trade-Offs in Hash Coding with Allowable Errors</a>
|
||||
*/
|
||||
public class BloomFilter extends Filter {
|
||||
private static final byte[] bitvalues = new byte[] {
|
||||
|
|
|
@ -66,9 +66,6 @@ import org.apache.hadoop.hbase.util.Hash;
|
|||
*
|
||||
* @version 1.1 - 19 Jan. 08
|
||||
*
|
||||
* @see org.onelab.filter.Filter The general behavior of a filter
|
||||
*
|
||||
* @see <a href="http://portal.acm.org/citation.cfm?id=343571.343572">Summary cache: a scalable wide-area web cache sharing protocol</a>
|
||||
*/
|
||||
public final class CountingBloomFilter extends Filter {
|
||||
/** Storage for the counting buckets */
|
||||
|
|
|
@ -81,10 +81,6 @@ import org.apache.hadoop.hbase.util.Hash;
|
|||
*
|
||||
* @version 1.0 - 6 Feb. 07
|
||||
*
|
||||
* @see org.onelab.filter.Filter The general behavior of a filter
|
||||
* @see org.onelab.filter.BloomFilter A Bloom filter
|
||||
*
|
||||
* @see <a href="http://www.cse.fau.edu/~jie/research/publications/Publication_files/infocom2006.pdf">Theory and Network Applications of Dynamic Bloom Filters</a>
|
||||
*/
|
||||
public class DynamicBloomFilter extends Filter {
|
||||
/**
|
||||
|
|
|
@ -69,12 +69,7 @@ import org.apache.hadoop.io.Writable;
|
|||
* <p>
|
||||
* It must be extended in order to define the real behavior.
|
||||
*
|
||||
* @see org.onelab.filter.Filter The general behavior of a filter
|
||||
*
|
||||
* @version 1.0 - 2 Feb. 07
|
||||
*
|
||||
* @see org.onelab.filter.Key The general behavior of a key
|
||||
* @see org.onelab.filter.HashFunction A hash function
|
||||
*/
|
||||
public abstract class Filter implements Writable {
|
||||
private static final int VERSION = -1; // negative to accommodate for old format
|
||||
|
|
|
@ -56,14 +56,7 @@ import org.apache.hadoop.hbase.util.Hash;
|
|||
* <p>
|
||||
* It is based on the SHA-1 algorithm.
|
||||
*
|
||||
* @see org.onelab.filter.Filter The general behavior of a filter
|
||||
*
|
||||
* @version 1.0 - 2 Feb. 07
|
||||
*
|
||||
* @see org.onelab.filter.Key The general behavior of a key being stored in a filter
|
||||
* @see org.onelab.filter.Filter The general behavior of a filter
|
||||
*
|
||||
* @see <a href="http://www.itl.nist.gov/fipspubs/fip180-1.htm">SHA-1 algorithm</a>
|
||||
*/
|
||||
public final class HashFunction {
|
||||
/** The number of hashed values. */
|
||||
|
|
|
@ -55,8 +55,6 @@ import org.apache.hadoop.io.WritableComparable;
|
|||
|
||||
/**
|
||||
* The general behavior of a key that must be stored in a filter.
|
||||
*
|
||||
* @see org.onelab.filter.Filter The general behavior of a filter
|
||||
*/
|
||||
public class Key implements WritableComparable {
|
||||
/** Byte value of key */
|
||||
|
|
|
@ -69,11 +69,6 @@ import org.apache.hadoop.hbase.util.Hash;
|
|||
*
|
||||
* @version 1.0 - 7 Feb. 07
|
||||
*
|
||||
* @see org.onelab.filter.Filter The general behavior of a filter
|
||||
* @see org.onelab.filter.BloomFilter A Bloom filter
|
||||
* @see org.onelab.filter.RemoveScheme The different selective clearing algorithms
|
||||
*
|
||||
* @see <a href="http://www-rp.lip6.fr/site_npa/site_rp/_publications/740-rbf_cameraready.pdf">Retouched Bloom Filters: Allowing Networked Applications to Trade Off Selected False Positives Against False Negatives</a>
|
||||
*/
|
||||
public final class RetouchedBloomFilter extends BloomFilter
|
||||
implements RemoveScheme {
|
||||
|
|
Loading…
Reference in New Issue