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

项目：ditb 文件：HRegionServer.java

/**
 * Run test on configured codecs to make sure supporting libs are in place.
 *
 * @param c
 * @throws IOException
 */
private static void checkCodecs(final Configuration c) throws IOException {
  // check to see if the codec list is available:
  String[] codecs = c.getStrings("hbase.regionserver.codecs", (String[]) null);
  if (codecs == null) return;
  for (String codec : codecs) {
    if (!CompressionTest.testCompression(codec)) {
      throw new IOException(
          "Compression codec " + codec + " not supported, aborting RS construction");
    }
  }
}

项目：ditb 文件：IndexFile.java

private FixedFileTrailer readTrailer() throws IOException {
  FixedFileTrailer fft = new FixedFileTrailer();
  long seekPoint = this.fileSize - FixedFileTrailer.trailerSize();
  this.istream.seek(seekPoint);
  fft.deserialize(this.istream);
  // Set up the codec.
  this.compressAlgo =
    Compression.Algorithm.values()[fft.compressionCodec];

  CompressionTest.testCompression(this.compressAlgo);

  return fft;
}

项目：LCIndex-HBase-0.94.16 文件：IndexFile.java

private FixedFileTrailer readTrailer() throws IOException {
  FixedFileTrailer fft = new FixedFileTrailer();
  long seekPoint = this.fileSize - FixedFileTrailer.trailerSize();
  this.istream.seek(seekPoint);
  fft.deserialize(this.istream);
  // Set up the codec.
  this.compressAlgo =
    Compression.Algorithm.values()[fft.compressionCodec];

  CompressionTest.testCompression(this.compressAlgo);

  return fft;
}

项目：LCIndex-HBase-0.94.16 文件：HRegionServer.java

/**
 * Run test on configured codecs to make sure supporting libs are in place.
 * @param c
 * @throws IOException
 */
private static void checkCodecs(final Configuration c) throws IOException {
  // check to see if the codec list is available:
  String[] codecs = c.getStrings("hbase.regionserver.codecs", (String[]) null);
  if (codecs == null) return;
  for (String codec : codecs) {
    if (!CompressionTest.testCompression(codec)) {
      throw new IOException("Compression codec " + codec
          + " not supported, aborting RS construction");
    }
  }
}

项目：pbase 文件：HRegionServer.java

/**
 * Run test on configured codecs to make sure supporting libs are in place.
 *
 * @param c
 * @throws IOException
 */
private static void checkCodecs(final Configuration c) throws IOException {
    // check to see if the codec list is available:
    String[] codecs = c.getStrings("hbase.regionserver.codecs", (String[]) null);
    if (codecs == null) return;
    for (String codec : codecs) {
        if (!CompressionTest.testCompression(codec)) {
            throw new IOException("Compression codec " + codec +
                    " not supported, aborting RS construction");
        }
    }
}

项目：HIndex 文件：HRegionServer.java

/**
 * Run test on configured codecs to make sure supporting libs are in place.
 * @param c
 * @throws IOException
 */
private static void checkCodecs(final Configuration c) throws IOException {
  // check to see if the codec list is available:
  String [] codecs = c.getStrings("hbase.regionserver.codecs", (String[])null);
  if (codecs == null) return;
  for (String codec : codecs) {
    if (!CompressionTest.testCompression(codec)) {
      throw new IOException("Compression codec " + codec +
        " not supported, aborting RS construction");
    }
  }
}

项目：IRIndex 文件：IndexFile.java

private FixedFileTrailer readTrailer() throws IOException {
  FixedFileTrailer fft = new FixedFileTrailer();
  long seekPoint = this.fileSize - FixedFileTrailer.trailerSize();
  this.istream.seek(seekPoint);
  fft.deserialize(this.istream);
  // Set up the codec.
  this.compressAlgo =
    Compression.Algorithm.values()[fft.compressionCodec];

  CompressionTest.testCompression(this.compressAlgo);

  return fft;
}

项目：IRIndex 文件：HRegionServer.java

/**
 * Run test on configured codecs to make sure supporting libs are in place.
 * @param c
 * @throws IOException
 */
private static void checkCodecs(final Configuration c) throws IOException {
  // check to see if the codec list is available:
  String [] codecs = c.getStrings("hbase.regionserver.codecs", (String[])null);
  if (codecs == null) return;
  for (String codec : codecs) {
    if (!CompressionTest.testCompression(codec)) {
      throw new IOException("Compression codec " + codec +
        " not supported, aborting RS construction");
    }
  }
}

项目：hbase 文件：HRegionServer.java

/**
 * Run test on configured codecs to make sure supporting libs are in place.
 * @param c
 * @throws IOException
 */
private static void checkCodecs(final Configuration c) throws IOException {
  // check to see if the codec list is available:
  String [] codecs = c.getStrings("hbase.regionserver.codecs", (String[])null);
  if (codecs == null) return;
  for (String codec : codecs) {
    if (!CompressionTest.testCompression(codec)) {
      throw new IOException("Compression codec " + codec +
        " not supported, aborting RS construction");
    }
  }
}

项目：RStore 文件：HRegionServer.java

/**
 * Run test on configured codecs to make sure supporting libs are in place.
 * @param c
 * @throws IOException
 */
private static void checkCodecs(final Configuration c) throws IOException {
  // check to see if the codec list is available:
  String [] codecs = c.getStrings("hbase.regionserver.codecs", (String[])null);
  if (codecs == null) return;
  for (String codec : codecs) {
    if (!CompressionTest.testCompression(codec)) {
      throw new IOException("Compression codec " + codec +
        " not supported, aborting RS construction");
    }
  }
}

项目：Kylin 文件：LZOSupportnessChecker.java

public static boolean getSupportness() {
    try {
        File temp = File.createTempFile("test", ".tmp");
        CompressionTest.main(new String[] { "file://" + temp.toString(), "lzo" });
    } catch (Exception e) {
        return false;
    }
    return true;
}

项目：PyroDB 文件：HRegionServer.java

/**
 * Run test on configured codecs to make sure supporting libs are in place.
 * @param c
 * @throws IOException
 */
private static void checkCodecs(final Configuration c) throws IOException {
  // check to see if the codec list is available:
  String [] codecs = c.getStrings("hbase.regionserver.codecs", (String[])null);
  if (codecs == null) return;
  for (String codec : codecs) {
    if (!CompressionTest.testCompression(codec)) {
      throw new IOException("Compression codec " + codec +
        " not supported, aborting RS construction");
    }
  }
}

项目：c5 文件：HRegionServer.java

/**
 * Run test on configured codecs to make sure supporting libs are in place.
 * @param c
 * @throws IOException
 */
private static void checkCodecs(final Configuration c) throws IOException {
  // check to see if the codec list is available:
  String [] codecs = c.getStrings("hbase.regionserver.codecs", (String[])null);
  if (codecs == null) return;
  for (String codec : codecs) {
    if (!CompressionTest.testCompression(codec)) {
      throw new IOException("Compression codec " + codec +
        " not supported, aborting RS construction");
    }
  }
}

项目：HBase-Research 文件：HRegionServer.java

/**
 * Run test on configured codecs to make sure supporting libs are in place.
 * @param c
 * @throws IOException
 */
private static void checkCodecs(final Configuration c) throws IOException {
  // check to see if the codec list is available:
  String [] codecs = c.getStrings("hbase.regionserver.codecs", (String[])null);
  if (codecs == null) return;
  for (String codec : codecs) {
    if (!CompressionTest.testCompression(codec)) {
      throw new IOException("Compression codec " + codec +
        " not supported, aborting RS construction");
    }
  }
}

项目：hbase-0.94.8-qod 文件：HRegionServer.java

/**
 * Run test on configured codecs to make sure supporting libs are in place.
 * @param c
 * @throws IOException
 */
private static void checkCodecs(final Configuration c) throws IOException {
  // check to see if the codec list is available:
  String [] codecs = c.getStrings("hbase.regionserver.codecs", (String[])null);
  if (codecs == null) return;
  for (String codec : codecs) {
    if (!CompressionTest.testCompression(codec)) {
      throw new IOException("Compression codec " + codec +
        " not supported, aborting RS construction");
    }
  }
}

项目：hbase-0.94.8-qod 文件：HRegionServer.java

/**
 * Run test on configured codecs to make sure supporting libs are in place.
 * @param c
 * @throws IOException
 */
private static void checkCodecs(final Configuration c) throws IOException {
  // check to see if the codec list is available:
  String [] codecs = c.getStrings("hbase.regionserver.codecs", (String[])null);
  if (codecs == null) return;
  for (String codec : codecs) {
    if (!CompressionTest.testCompression(codec)) {
      throw new IOException("Compression codec " + codec +
        " not supported, aborting RS construction");
    }
  }
}

项目：DominoHBase 文件：HRegionServer.java

/**
 * Run test on configured codecs to make sure supporting libs are in place.
 * @param c
 * @throws IOException
 */
private static void checkCodecs(final Configuration c) throws IOException {
  // check to see if the codec list is available:
  String [] codecs = c.getStrings("hbase.regionserver.codecs", (String[])null);
  if (codecs == null) return;
  for (String codec : codecs) {
    if (!CompressionTest.testCompression(codec)) {
      throw new IOException("Compression codec " + codec +
        " not supported, aborting RS construction");
    }
  }
}

项目：hindex 文件：HRegionServer.java

/**
 * Run test on configured codecs to make sure supporting libs are in place.
 * @param c
 * @throws IOException
 */
private static void checkCodecs(final Configuration c) throws IOException {
  // check to see if the codec list is available:
  String [] codecs = c.getStrings("hbase.regionserver.codecs", (String[])null);
  if (codecs == null) return;
  for (String codec : codecs) {
    if (!CompressionTest.testCompression(codec)) {
      throw new IOException("Compression codec " + codec +
        " not supported, aborting RS construction");
    }
  }
}

项目：ditb 文件：HMaster.java

private void checkCompression(final HColumnDescriptor hcd)
throws IOException {
  if (!this.masterCheckCompression) return;
  CompressionTest.testCompression(hcd.getCompression());
  CompressionTest.testCompression(hcd.getCompactionCompression());
}

项目：ditb 文件：HRegion.java

private void checkCompressionCodecs() throws IOException {
  for (HColumnDescriptor fam : this.htableDescriptor.getColumnFamilies()) {
    CompressionTest.testCompression(fam.getCompression());
    CompressionTest.testCompression(fam.getCompactionCompression());
  }
}

项目：LCIndex-HBase-0.94.16 文件：HRegion.java

private void checkCompressionCodecs() throws IOException {
  for (HColumnDescriptor fam : this.htableDescriptor.getColumnFamilies()) {
    CompressionTest.testCompression(fam.getCompression());
    CompressionTest.testCompression(fam.getCompactionCompression());
  }
}

项目：pbase 文件：HMaster.java

private void checkCompression(final HColumnDescriptor hcd)
        throws IOException {
    if (!this.masterCheckCompression) return;
    CompressionTest.testCompression(hcd.getCompression());
    CompressionTest.testCompression(hcd.getCompactionCompression());
}

项目：pbase 文件：HRegion.java

private void checkCompressionCodecs() throws IOException {
    for (HColumnDescriptor fam : this.htableDescriptor.getColumnFamilies()) {
        CompressionTest.testCompression(fam.getCompression());
        CompressionTest.testCompression(fam.getCompactionCompression());
    }
}

项目：HIndex 文件：HMaster.java

private void checkCompression(final HColumnDescriptor hcd)
throws IOException {
  if (!this.masterCheckCompression) return;
  CompressionTest.testCompression(hcd.getCompression());
  CompressionTest.testCompression(hcd.getCompactionCompression());
}

项目：HIndex 文件：HRegion.java

private void checkCompressionCodecs() throws IOException {
  for (HColumnDescriptor fam: this.htableDescriptor.getColumnFamilies()) {
    CompressionTest.testCompression(fam.getCompression());
    CompressionTest.testCompression(fam.getCompactionCompression());
  }
}

项目：IRIndex 文件：HRegion.java

private void checkCompressionCodecs() throws IOException {
  for (HColumnDescriptor fam: this.htableDescriptor.getColumnFamilies()) {
    CompressionTest.testCompression(fam.getCompression());
    CompressionTest.testCompression(fam.getCompactionCompression());
  }
}

项目：hbase 文件：HMaster.java

private void checkCompression(final ColumnFamilyDescriptor hcd)
throws IOException {
  if (!this.masterCheckCompression) return;
  CompressionTest.testCompression(hcd.getCompressionType());
  CompressionTest.testCompression(hcd.getCompactionCompressionType());
}

项目：hbase 文件：HRegion.java

private void checkCompressionCodecs() throws IOException {
  for (ColumnFamilyDescriptor fam: this.htableDescriptor.getColumnFamilies()) {
    CompressionTest.testCompression(fam.getCompressionType());
    CompressionTest.testCompression(fam.getCompactionCompressionType());
  }
}

项目：RStore 文件：HRegion.java

private void checkCompressionCodecs() throws IOException {
  for (HColumnDescriptor fam: this.htableDescriptor.getColumnFamilies()) {
    CompressionTest.testCompression(fam.getCompression());
    CompressionTest.testCompression(fam.getCompactionCompression());
  }
}

项目：PyroDB 文件：HMaster.java

private void checkCompression(final HColumnDescriptor hcd)
throws IOException {
  if (!this.masterCheckCompression) return;
  CompressionTest.testCompression(hcd.getCompression());
  CompressionTest.testCompression(hcd.getCompactionCompression());
}

项目：PyroDB 文件：HRegion.java

private void checkCompressionCodecs() throws IOException {
  for (HColumnDescriptor fam: this.htableDescriptor.getColumnFamilies()) {
    CompressionTest.testCompression(fam.getCompression());
    CompressionTest.testCompression(fam.getCompactionCompression());
  }
}

项目：c5 文件：HMaster.java

private void checkCompression(final HColumnDescriptor hcd)
throws IOException {
  if (!this.masterCheckCompression) return;
  CompressionTest.testCompression(hcd.getCompression());
  CompressionTest.testCompression(hcd.getCompactionCompression());
}

项目：c5 文件：HRegion.java

private void checkCompressionCodecs() throws IOException {
  for (HColumnDescriptor fam: this.htableDescriptor.getColumnFamilies()) {
    CompressionTest.testCompression(fam.getCompression());
    CompressionTest.testCompression(fam.getCompactionCompression());
  }
}

项目：HBase-Research 文件：HRegion.java

private void checkCompressionCodecs() throws IOException {
  for (HColumnDescriptor fam: this.htableDescriptor.getColumnFamilies()) {
    CompressionTest.testCompression(fam.getCompression());
    CompressionTest.testCompression(fam.getCompactionCompression());
  }
}

项目：hbase-0.94.8-qod 文件：HRegion.java

private void checkCompressionCodecs() throws IOException {
  for (HColumnDescriptor fam: this.htableDescriptor.getColumnFamilies()) {
    CompressionTest.testCompression(fam.getCompression());
    CompressionTest.testCompression(fam.getCompactionCompression());
  }
}

项目：hbase-0.94.8-qod 文件：HRegion.java

private void checkCompressionCodecs() throws IOException {
  for (HColumnDescriptor fam: this.htableDescriptor.getColumnFamilies()) {
    CompressionTest.testCompression(fam.getCompression());
    CompressionTest.testCompression(fam.getCompactionCompression());
  }
}

项目：DominoHBase 文件：HMaster.java

private void checkCompression(final HColumnDescriptor hcd)
throws IOException {
  if (!this.masterCheckCompression) return;
  CompressionTest.testCompression(hcd.getCompression());
  CompressionTest.testCompression(hcd.getCompactionCompression());
}

项目：DominoHBase 文件：HRegion.java

private void checkCompressionCodecs() throws IOException {
  for (HColumnDescriptor fam: this.htableDescriptor.getColumnFamilies()) {
    CompressionTest.testCompression(fam.getCompression());
    CompressionTest.testCompression(fam.getCompactionCompression());
  }
}

项目：hindex 文件：HRegion.java

private void checkCompressionCodecs() throws IOException {
  for (HColumnDescriptor fam: this.htableDescriptor.getColumnFamilies()) {
    CompressionTest.testCompression(fam.getCompression());
    CompressionTest.testCompression(fam.getCompactionCompression());
  }
}