1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.util.BloomFilterWriter

Java 类org.apache.hadoop.hbase.util.BloomFilterWriter 实例源码

项目：ditb    文件：HFileWriterV2.java    
private void addBloomFilter(final BloomFilterWriter bfw,
    final BlockType blockType) {
  if (bfw.getKeyCount() <= 0)
    return;

  if (blockType != BlockType.GENERAL_BLOOM_META &&
      blockType != BlockType.DELETE_FAMILY_BLOOM_META) {
    throw new RuntimeException("Block Type: " + blockType.toString() +
        "is not supported");
  }
  additionalLoadOnOpenData.add(new BlockWritable() {
    @Override
    public BlockType getBlockType() {
      return blockType;
    }

    @Override
    public void writeToBlock(DataOutput out) throws IOException {
      bfw.getMetaWriter().write(out);
      Writable dataWriter = bfw.getDataWriter();
      if (dataWriter != null)
        dataWriter.write(out);
    }
  });
}
项目：LCIndex-HBase-0.94.16    文件：HFileWriterV2.java    
private void addBloomFilter(final BloomFilterWriter bfw,
    final BlockType blockType) {
  if (bfw.getKeyCount() <= 0)
    return;

  if (blockType != BlockType.GENERAL_BLOOM_META &&
      blockType != BlockType.DELETE_FAMILY_BLOOM_META) {
    throw new RuntimeException("Block Type: " + blockType.toString() +
        "is not supported");
  }
  additionalLoadOnOpenData.add(new BlockWritable() {
    @Override
    public BlockType getBlockType() {
      return blockType;
    }

    @Override
    public void writeToBlock(DataOutput out) throws IOException {
      bfw.getMetaWriter().write(out);
      Writable dataWriter = bfw.getDataWriter();
      if (dataWriter != null)
        dataWriter.write(out);
    }
  });
}
项目：pbase    文件：HFileWriterV2.java    
private void addBloomFilter(final BloomFilterWriter bfw,
    final BlockType blockType) {
  if (bfw.getKeyCount() <= 0)
    return;

  if (blockType != BlockType.GENERAL_BLOOM_META &&
      blockType != BlockType.DELETE_FAMILY_BLOOM_META) {
    throw new RuntimeException("Block Type: " + blockType.toString() +
        "is not supported");
  }
  additionalLoadOnOpenData.add(new BlockWritable() {
    @Override
    public BlockType getBlockType() {
      return blockType;
    }

    @Override
    public void writeToBlock(DataOutput out) throws IOException {
      bfw.getMetaWriter().write(out);
      Writable dataWriter = bfw.getDataWriter();
      if (dataWriter != null)
        dataWriter.write(out);
    }
  });
}
项目：HIndex    文件：HFileWriterV2.java    
private void addBloomFilter(final BloomFilterWriter bfw,
    final BlockType blockType) {
  if (bfw.getKeyCount() <= 0)
    return;

  if (blockType != BlockType.GENERAL_BLOOM_META &&
      blockType != BlockType.DELETE_FAMILY_BLOOM_META) {
    throw new RuntimeException("Block Type: " + blockType.toString() +
        "is not supported");
  }
  additionalLoadOnOpenData.add(new BlockWritable() {
    @Override
    public BlockType getBlockType() {
      return blockType;
    }

    @Override
    public void writeToBlock(DataOutput out) throws IOException {
      bfw.getMetaWriter().write(out);
      Writable dataWriter = bfw.getDataWriter();
      if (dataWriter != null)
        dataWriter.write(out);
    }
  });
}
项目：IRIndex    文件：HFileWriterV2.java    
private void addBloomFilter(final BloomFilterWriter bfw,
    final BlockType blockType) {
  if (bfw.getKeyCount() <= 0)
    return;

  if (blockType != BlockType.GENERAL_BLOOM_META &&
      blockType != BlockType.DELETE_FAMILY_BLOOM_META) {
    throw new RuntimeException("Block Type: " + blockType.toString() +
        "is not supported");
  }
  additionalLoadOnOpenData.add(new BlockWritable() {
    @Override
    public BlockType getBlockType() {
      return blockType;
    }

    @Override
    public void writeToBlock(DataOutput out) throws IOException {
      bfw.getMetaWriter().write(out);
      Writable dataWriter = bfw.getDataWriter();
      if (dataWriter != null)
        dataWriter.write(out);
    }
  });
}
项目：hbase    文件：HFileWriterImpl.java    
private void addBloomFilter(final BloomFilterWriter bfw,
    final BlockType blockType) {
  if (bfw.getKeyCount() <= 0)
    return;

  if (blockType != BlockType.GENERAL_BLOOM_META &&
      blockType != BlockType.DELETE_FAMILY_BLOOM_META) {
    throw new RuntimeException("Block Type: " + blockType.toString() +
        "is not supported");
  }
  additionalLoadOnOpenData.add(new BlockWritable() {
    @Override
    public BlockType getBlockType() {
      return blockType;
    }

    @Override
    public void writeToBlock(DataOutput out) throws IOException {
      bfw.getMetaWriter().write(out);
      Writable dataWriter = bfw.getDataWriter();
      if (dataWriter != null)
        dataWriter.write(out);
    }
  });
}
项目：RStore    文件：HFileWriterV2.java    
@Override
public void addBloomFilter(final BloomFilterWriter bfw) {
  if (bfw.getKeyCount() <= 0)
    return;

  additionalLoadOnOpenData.add(new BlockWritable() {
    @Override
    public BlockType getBlockType() {
      return BlockType.BLOOM_META;
    }

    @Override
    public void writeToBlock(DataOutput out) throws IOException {
      bfw.getMetaWriter().write(out);
      Writable dataWriter = bfw.getDataWriter();
      if (dataWriter != null)
        dataWriter.write(out);
    }
  });
}
项目：PyroDB    文件：HFileWriterV2.java    
private void addBloomFilter(final BloomFilterWriter bfw,
    final BlockType blockType) {
  if (bfw.getKeyCount() <= 0)
    return;

  if (blockType != BlockType.GENERAL_BLOOM_META &&
      blockType != BlockType.DELETE_FAMILY_BLOOM_META) {
    throw new RuntimeException("Block Type: " + blockType.toString() +
        "is not supported");
  }
  additionalLoadOnOpenData.add(new BlockWritable() {
    @Override
    public BlockType getBlockType() {
      return blockType;
    }

    @Override
    public void writeToBlock(DataOutput out) throws IOException {
      bfw.getMetaWriter().write(out);
      Writable dataWriter = bfw.getDataWriter();
      if (dataWriter != null)
        dataWriter.write(out);
    }
  });
}
项目：c5    文件：HFileWriterV2.java    
private void addBloomFilter(final BloomFilterWriter bfw,
    final BlockType blockType) {
  if (bfw.getKeyCount() <= 0)
    return;

  if (blockType != BlockType.GENERAL_BLOOM_META &&
      blockType != BlockType.DELETE_FAMILY_BLOOM_META) {
    throw new RuntimeException("Block Type: " + blockType.toString() +
        "is not supported");
  }
  additionalLoadOnOpenData.add(new BlockWritable() {
    @Override
    public BlockType getBlockType() {
      return blockType;
    }

    @Override
    public void writeToBlock(DataOutput out) throws IOException {
      bfw.getMetaWriter().write(out);
      Writable dataWriter = bfw.getDataWriter();
      if (dataWriter != null)
        dataWriter.write(out);
    }
  });
}
项目：HBase-Research    文件：HFileWriterV2.java    
private void addBloomFilter(final BloomFilterWriter bfw,
    final BlockType blockType) {
  if (bfw.getKeyCount() <= 0)
    return;

  if (blockType != BlockType.GENERAL_BLOOM_META &&
      blockType != BlockType.DELETE_FAMILY_BLOOM_META) {
    throw new RuntimeException("Block Type: " + blockType.toString() +
        "is not supported");
  }
  additionalLoadOnOpenData.add(new BlockWritable() {
    @Override
    public BlockType getBlockType() {
      return blockType;
    }

    @Override
    public void writeToBlock(DataOutput out) throws IOException {
      bfw.getMetaWriter().write(out);
      Writable dataWriter = bfw.getDataWriter();
      if (dataWriter != null)
        dataWriter.write(out);
    }
  });
}
项目：hbase-0.94.8-qod    文件：HFileWriterV2.java    
private void addBloomFilter(final BloomFilterWriter bfw,
    final BlockType blockType) {
  if (bfw.getKeyCount() <= 0)
    return;

  if (blockType != BlockType.GENERAL_BLOOM_META &&
      blockType != BlockType.DELETE_FAMILY_BLOOM_META) {
    throw new RuntimeException("Block Type: " + blockType.toString() +
        "is not supported");
  }
  additionalLoadOnOpenData.add(new BlockWritable() {
    @Override
    public BlockType getBlockType() {
      return blockType;
    }

    @Override
    public void writeToBlock(DataOutput out) throws IOException {
      bfw.getMetaWriter().write(out);
      Writable dataWriter = bfw.getDataWriter();
      if (dataWriter != null)
        dataWriter.write(out);
    }
  });
}
项目：hbase-0.94.8-qod    文件：HFileWriterV2.java    
private void addBloomFilter(final BloomFilterWriter bfw,
    final BlockType blockType) {
  if (bfw.getKeyCount() <= 0)
    return;

  if (blockType != BlockType.GENERAL_BLOOM_META &&
      blockType != BlockType.DELETE_FAMILY_BLOOM_META) {
    throw new RuntimeException("Block Type: " + blockType.toString() +
        "is not supported");
  }
  additionalLoadOnOpenData.add(new BlockWritable() {
    @Override
    public BlockType getBlockType() {
      return blockType;
    }

    @Override
    public void writeToBlock(DataOutput out) throws IOException {
      bfw.getMetaWriter().write(out);
      Writable dataWriter = bfw.getDataWriter();
      if (dataWriter != null)
        dataWriter.write(out);
    }
  });
}
项目：DominoHBase    文件：HFileWriterV2.java    
private void addBloomFilter(final BloomFilterWriter bfw,
    final BlockType blockType) {
  if (bfw.getKeyCount() <= 0)
    return;

  if (blockType != BlockType.GENERAL_BLOOM_META &&
      blockType != BlockType.DELETE_FAMILY_BLOOM_META) {
    throw new RuntimeException("Block Type: " + blockType.toString() +
        "is not supported");
  }
  additionalLoadOnOpenData.add(new BlockWritable() {
    @Override
    public BlockType getBlockType() {
      return blockType;
    }

    @Override
    public void writeToBlock(DataOutput out) throws IOException {
      bfw.getMetaWriter().write(out);
      Writable dataWriter = bfw.getDataWriter();
      if (dataWriter != null)
        dataWriter.write(out);
    }
  });
}
项目：hindex    文件：HFileWriterV2.java    
private void addBloomFilter(final BloomFilterWriter bfw,
    final BlockType blockType) {
  if (bfw.getKeyCount() <= 0)
    return;

  if (blockType != BlockType.GENERAL_BLOOM_META &&
      blockType != BlockType.DELETE_FAMILY_BLOOM_META) {
    throw new RuntimeException("Block Type: " + blockType.toString() +
        "is not supported");
  }
  additionalLoadOnOpenData.add(new BlockWritable() {
    @Override
    public BlockType getBlockType() {
      return blockType;
    }

    @Override
    public void writeToBlock(DataOutput out) throws IOException {
      bfw.getMetaWriter().write(out);
      Writable dataWriter = bfw.getDataWriter();
      if (dataWriter != null)
        dataWriter.write(out);
    }
  });
}
项目：ditb    文件：StoreFile.java    
private boolean closeBloomFilter(BloomFilterWriter bfw) throws IOException {
  boolean haveBloom = (bfw != null && bfw.getKeyCount() > 0);
  if (haveBloom) {
    bfw.compactBloom();
  }
  return haveBloom;
}
项目：LCIndex-HBase-0.94.16    文件：StoreFile.java    
private boolean closeBloomFilter(BloomFilterWriter bfw) throws IOException {
  boolean haveBloom = (bfw != null && bfw.getKeyCount() > 0);
  if (haveBloom) {
    bfw.compactBloom();
  }
  return haveBloom;
}
项目：LCIndex-HBase-0.94.16    文件：HFileWriterV1.java    
/**
 * Version 1 general Bloom filters are stored in two meta blocks with two different
 * keys.
 */
@Override
public void addGeneralBloomFilter(BloomFilterWriter bfw) {
  appendMetaBlock(BLOOM_FILTER_META_KEY,
      bfw.getMetaWriter());
  Writable dataWriter = bfw.getDataWriter();
  if (dataWriter != null) {
    appendMetaBlock(BLOOM_FILTER_DATA_KEY, dataWriter);
  }
}
项目：pbase    文件：StoreFile.java    
private boolean closeBloomFilter(BloomFilterWriter bfw) throws IOException {
    boolean haveBloom = (bfw != null && bfw.getKeyCount() > 0);
    if (haveBloom) {
        bfw.compactBloom();
    }
    return haveBloom;
}
项目：HIndex    文件：StoreFile.java    
private boolean closeBloomFilter(BloomFilterWriter bfw) throws IOException {
  boolean haveBloom = (bfw != null && bfw.getKeyCount() > 0);
  if (haveBloom) {
    bfw.compactBloom();
  }
  return haveBloom;
}
项目：IRIndex    文件：StoreFile.java    
private boolean closeBloomFilter(BloomFilterWriter bfw) throws IOException {
  boolean haveBloom = (bfw != null && bfw.getKeyCount() > 0);
  if (haveBloom) {
    bfw.compactBloom();
  }
  return haveBloom;
}
项目：IRIndex    文件：HFileWriterV1.java    
/**
 * Version 1 general Bloom filters are stored in two meta blocks with two different
 * keys.
 */
@Override
public void addGeneralBloomFilter(BloomFilterWriter bfw) {
  appendMetaBlock(BLOOM_FILTER_META_KEY,
      bfw.getMetaWriter());
  Writable dataWriter = bfw.getDataWriter();
  if (dataWriter != null) {
    appendMetaBlock(BLOOM_FILTER_DATA_KEY, dataWriter);
  }
}
项目：hbase    文件：StoreFileWriter.java    
private boolean closeBloomFilter(BloomFilterWriter bfw) throws IOException {
  boolean haveBloom = (bfw != null && bfw.getKeyCount() > 0);
  if (haveBloom) {
    bfw.compactBloom();
  }
  return haveBloom;
}
项目：RStore    文件：HFileWriterV1.java    
/**
 * Version 1 Bloom filters are stored in two meta blocks with two different
 * keys.
 */
@Override
public void addBloomFilter(BloomFilterWriter bfw) {
  appendMetaBlock(BLOOM_FILTER_META_KEY,
      bfw.getMetaWriter());
  Writable dataWriter = bfw.getDataWriter();
  if (dataWriter != null) {
    appendMetaBlock(BLOOM_FILTER_DATA_KEY, dataWriter);
  }
}
项目：PyroDB    文件：StoreFile.java    
private boolean closeBloomFilter(BloomFilterWriter bfw) throws IOException {
  boolean haveBloom = (bfw != null && bfw.getKeyCount() > 0);
  if (haveBloom) {
    bfw.compactBloom();
  }
  return haveBloom;
}
项目：c5    文件：StoreFile.java    
private boolean closeBloomFilter(BloomFilterWriter bfw) throws IOException {
  boolean haveBloom = (bfw != null && bfw.getKeyCount() > 0);
  if (haveBloom) {
    bfw.compactBloom();
  }
  return haveBloom;
}
项目：HBase-Research    文件：StoreFile.java    
private boolean closeBloomFilter(BloomFilterWriter bfw) throws IOException {
  boolean haveBloom = (bfw != null && bfw.getKeyCount() > 0);
  if (haveBloom) {
    bfw.compactBloom();
  }
  return haveBloom;
}
项目：HBase-Research    文件：HFileWriterV1.java    
/**
 * Version 1 general Bloom filters are stored in two meta blocks with two different
 * keys.
 */
@Override
public void addGeneralBloomFilter(BloomFilterWriter bfw) {
  appendMetaBlock(BLOOM_FILTER_META_KEY,
      bfw.getMetaWriter());
  Writable dataWriter = bfw.getDataWriter();
  if (dataWriter != null) {
    appendMetaBlock(BLOOM_FILTER_DATA_KEY, dataWriter);
  }
}
项目：hbase-0.94.8-qod    文件：StoreFile.java    
private boolean closeBloomFilter(BloomFilterWriter bfw) throws IOException {
  boolean haveBloom = (bfw != null && bfw.getKeyCount() > 0);
  if (haveBloom) {
    bfw.compactBloom();
  }
  return haveBloom;
}
项目：hbase-0.94.8-qod    文件：HFileWriterV1.java    
/**
 * Version 1 general Bloom filters are stored in two meta blocks with two different
 * keys.
 */
@Override
public void addGeneralBloomFilter(BloomFilterWriter bfw) {
  appendMetaBlock(BLOOM_FILTER_META_KEY,
      bfw.getMetaWriter());
  Writable dataWriter = bfw.getDataWriter();
  if (dataWriter != null) {
    appendMetaBlock(BLOOM_FILTER_DATA_KEY, dataWriter);
  }
}
项目：hbase-0.94.8-qod    文件：StoreFile.java    
private boolean closeBloomFilter(BloomFilterWriter bfw) throws IOException {
  boolean haveBloom = (bfw != null && bfw.getKeyCount() > 0);
  if (haveBloom) {
    bfw.compactBloom();
  }
  return haveBloom;
}
项目：hbase-0.94.8-qod    文件：HFileWriterV1.java    
/**
 * Version 1 general Bloom filters are stored in two meta blocks with two different
 * keys.
 */
@Override
public void addGeneralBloomFilter(BloomFilterWriter bfw) {
  appendMetaBlock(BLOOM_FILTER_META_KEY,
      bfw.getMetaWriter());
  Writable dataWriter = bfw.getDataWriter();
  if (dataWriter != null) {
    appendMetaBlock(BLOOM_FILTER_DATA_KEY, dataWriter);
  }
}
项目：DominoHBase    文件：StoreFile.java    
private boolean closeBloomFilter(BloomFilterWriter bfw) throws IOException {
  boolean haveBloom = (bfw != null && bfw.getKeyCount() > 0);
  if (haveBloom) {
    bfw.compactBloom();
  }
  return haveBloom;
}
项目：DominoHBase    文件：HFileWriterV1.java    
/**
 * Version 1 general Bloom filters are stored in two meta blocks with two different
 * keys.
 */
@Override
public void addGeneralBloomFilter(BloomFilterWriter bfw) {
  appendMetaBlock(BLOOM_FILTER_META_KEY,
      bfw.getMetaWriter());
  Writable dataWriter = bfw.getDataWriter();
  if (dataWriter != null) {
    appendMetaBlock(BLOOM_FILTER_DATA_KEY, dataWriter);
  }
}
项目：hindex    文件：StoreFile.java    
private boolean closeBloomFilter(BloomFilterWriter bfw) throws IOException {
  boolean haveBloom = (bfw != null && bfw.getKeyCount() > 0);
  if (haveBloom) {
    bfw.compactBloom();
  }
  return haveBloom;
}
项目：hindex    文件：HFileWriterV1.java    
/**
 * Version 1 general Bloom filters are stored in two meta blocks with two different
 * keys.
 */
@Override
public void addGeneralBloomFilter(BloomFilterWriter bfw) {
  appendMetaBlock(BLOOM_FILTER_META_KEY,
      bfw.getMetaWriter());
  Writable dataWriter = bfw.getDataWriter();
  if (dataWriter != null) {
    appendMetaBlock(BLOOM_FILTER_DATA_KEY, dataWriter);
  }
}
项目：ditb    文件：HFileWriterV2.java    
@Override
public void addGeneralBloomFilter(final BloomFilterWriter bfw) {
  this.addBloomFilter(bfw, BlockType.GENERAL_BLOOM_META);
}
项目：ditb    文件：HFileWriterV2.java    
@Override
public void addDeleteFamilyBloomFilter(final BloomFilterWriter bfw) {
  this.addBloomFilter(bfw, BlockType.DELETE_FAMILY_BLOOM_META);
}
项目：LCIndex-HBase-0.94.16    文件：HFileWriterV2.java    
@Override
public void addGeneralBloomFilter(final BloomFilterWriter bfw) {
  this.addBloomFilter(bfw, BlockType.GENERAL_BLOOM_META);
}
项目：LCIndex-HBase-0.94.16    文件：HFileWriterV2.java    
@Override
public void addDeleteFamilyBloomFilter(final BloomFilterWriter bfw) {
  this.addBloomFilter(bfw, BlockType.DELETE_FAMILY_BLOOM_META);
}
项目：LCIndex-HBase-0.94.16    文件：HFileWriterV1.java    
@Override
public void addDeleteFamilyBloomFilter(BloomFilterWriter bfw)
throws IOException {
  throw new IOException("Delete Bloom filter is not supported in HFile V1");
}