本文整理了Java中org.apache.hadoop.io.compress.zlib.ZlibFactory.getZlibCompressor()方法的一些代码示例，展示了ZlibFactory.getZlibCompressor()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZlibFactory.getZlibCompressor()方法的具体详情如下：
包路径：org.apache.hadoop.io.compress.zlib.ZlibFactory
类名称：ZlibFactory
方法名：getZlibCompressor

ZlibFactory.getZlibCompressor介绍

[英]Return the appropriate implementation of the zlib compressor.
[中]返回zlib压缩器的相应实现。

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public Compressor createCompressor() {
 return ZlibFactory.getZlibCompressor(conf);
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

@Override
public Compressor createCompressor() {
 return ZlibFactory.getZlibCompressor(conf);
}

代码示例来源：origin: io.hops/hadoop-common

@Override
public Compressor createCompressor() {
 return ZlibFactory.getZlibCompressor(conf);
}

代码示例来源：origin: org.jvnet.hudson.hadoop/hadoop-core

public Compressor createCompressor() {
 return ZlibFactory.getZlibCompressor(conf);
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Override
public Compressor createCompressor() {
 return ZlibFactory.getZlibCompressor(conf);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Override
public Compressor createCompressor() {
 return ZlibFactory.getZlibCompressor(conf);
}

代码示例来源：origin: com.facebook.hadoop/hadoop-core

public Compressor createCompressor() {
 return ZlibFactory.getZlibCompressor(conf);
}

代码示例来源：origin: org.apache.hadoop/hadoop-common-test

Compressor zlibCompressor = ZlibFactory.getZlibCompressor(conf);
assertNotNull("zlibCompressor is null!", zlibCompressor);
assertTrue("ZlibFactory returned unexpected deflator",

代码示例来源：origin: ch.cern.hadoop/hadoop-common

Compressor zlibCompressor = ZlibFactory.getZlibCompressor(conf);
assertNotNull("zlibCompressor is null!", zlibCompressor);
assertTrue("ZlibFactory returned unexpected deflator",

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

Compressor zlibCompressor = ZlibFactory.getZlibCompressor(conf);
assertNotNull("zlibCompressor is null!", zlibCompressor);
assertTrue("ZlibFactory returned unexpected deflator",

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Test
public void testZlibCompressorDecompressorSetDictionary() {
 Configuration conf = new Configuration();
 conf.setBoolean(CommonConfigurationKeys.IO_NATIVE_LIB_AVAILABLE_KEY, true);
 if (ZlibFactory.isNativeZlibLoaded(conf)) {
  Compressor zlibCompressor = ZlibFactory.getZlibCompressor(conf);
  Decompressor zlibDecompressor = ZlibFactory.getZlibDecompressor(conf);
  checkSetDictionaryNullPointerException(zlibCompressor);
  checkSetDictionaryNullPointerException(zlibDecompressor);
  checkSetDictionaryArrayIndexOutOfBoundsException(zlibDecompressor);
  checkSetDictionaryArrayIndexOutOfBoundsException(zlibCompressor);
 } else {
  assertTrue("ZlibFactory is using native libs against request",
    ZlibFactory.isNativeZlibLoaded(conf));
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Test
public void testZlibCompressorDecompressorSetDictionary() {
 Configuration conf = new Configuration();
 conf.setBoolean(CommonConfigurationKeys.IO_NATIVE_LIB_AVAILABLE_KEY, true);
 if (ZlibFactory.isNativeZlibLoaded(conf)) {
  Compressor zlibCompressor = ZlibFactory.getZlibCompressor(conf);
  Decompressor zlibDecompressor = ZlibFactory.getZlibDecompressor(conf);
  checkSetDictionaryNullPointerException(zlibCompressor);
  checkSetDictionaryNullPointerException(zlibDecompressor);
  checkSetDictionaryArrayIndexOutOfBoundsException(zlibDecompressor);
  checkSetDictionaryArrayIndexOutOfBoundsException(zlibCompressor);
 } else {
  assertTrue("ZlibFactory is using native libs against request",
    ZlibFactory.isNativeZlibLoaded(conf));
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Test
public void testZlibCompressorDecompressorWithConfiguration() {
 Configuration conf = new Configuration();
 conf.setBoolean(CommonConfigurationKeys.IO_NATIVE_LIB_AVAILABLE_KEY, true);
 if (ZlibFactory.isNativeZlibLoaded(conf)) {
  byte[] rawData;
  int tryNumber = 5;
  int BYTE_SIZE = 10 * 1024;
  Compressor zlibCompressor = ZlibFactory.getZlibCompressor(conf);
  Decompressor zlibDecompressor = ZlibFactory.getZlibDecompressor(conf);
  rawData = generate(BYTE_SIZE);
  try {
   for (int i = 0; i < tryNumber; i++)
    compressDecompressZlib(rawData, (ZlibCompressor) zlibCompressor,
      (ZlibDecompressor) zlibDecompressor);
   zlibCompressor.reinit(conf);
  } catch (Exception ex) {
   fail("testZlibCompressorDecompressorWithConfiguration ex error " + ex);
  }
 } else {
  assertTrue("ZlibFactory is using native libs against request",
    ZlibFactory.isNativeZlibLoaded(conf));
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Test
public void testZlibCompressorDecompressorWithCompressionLevels() {
 Configuration conf = new Configuration();
 conf.set("zlib.compress.level","FOUR");
 if (ZlibFactory.isNativeZlibLoaded(conf)) {
  byte[] rawData;
  int tryNumber = 5;
  int BYTE_SIZE = 10 * 1024;
  Compressor zlibCompressor = ZlibFactory.getZlibCompressor(conf);
  Decompressor zlibDecompressor = ZlibFactory.getZlibDecompressor(conf);
  rawData = generate(BYTE_SIZE);
  try {
   for (int i = 0; i < tryNumber; i++)
    compressDecompressZlib(rawData, (ZlibCompressor) zlibCompressor,
        (ZlibDecompressor) zlibDecompressor);
   zlibCompressor.reinit(conf);
  } catch (Exception ex) {
   fail("testZlibCompressorDecompressorWithConfiguration ex error " + ex);
  }
 } else {
  assertTrue("ZlibFactory is using native libs against request",
      ZlibFactory.isNativeZlibLoaded(conf));
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Test
public void testZlibCompressorDecompressorWithConfiguration() {
 Configuration conf = new Configuration();
 conf.setBoolean(CommonConfigurationKeys.IO_NATIVE_LIB_AVAILABLE_KEY, true);
 if (ZlibFactory.isNativeZlibLoaded(conf)) {
  byte[] rawData;
  int tryNumber = 5;
  int BYTE_SIZE = 10 * 1024;
  Compressor zlibCompressor = ZlibFactory.getZlibCompressor(conf);
  Decompressor zlibDecompressor = ZlibFactory.getZlibDecompressor(conf);
  rawData = generate(BYTE_SIZE);
  try {
   for (int i = 0; i < tryNumber; i++)
    compressDecompressZlib(rawData, (ZlibCompressor) zlibCompressor,
      (ZlibDecompressor) zlibDecompressor);
   zlibCompressor.reinit(conf);
  } catch (Exception ex) {
   fail("testZlibCompressorDecompressorWithConfiguration ex error " + ex);
  }
 } else {
  assertTrue("ZlibFactory is using native libs against request",
    ZlibFactory.isNativeZlibLoaded(conf));
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Test
public void testZlibCompressorDecompressorWithCompressionLevels() {
 Configuration conf = new Configuration();
 conf.set("zlib.compress.level","FOUR");
 if (ZlibFactory.isNativeZlibLoaded(conf)) {
  byte[] rawData;
  int tryNumber = 5;
  int BYTE_SIZE = 10 * 1024;
  Compressor zlibCompressor = ZlibFactory.getZlibCompressor(conf);
  Decompressor zlibDecompressor = ZlibFactory.getZlibDecompressor(conf);
  rawData = generate(BYTE_SIZE);
  try {
   for (int i = 0; i < tryNumber; i++)
    compressDecompressZlib(rawData, (ZlibCompressor) zlibCompressor,
        (ZlibDecompressor) zlibDecompressor);
   zlibCompressor.reinit(conf);
  } catch (Exception ex) {
   fail("testZlibCompressorDecompressorWithConfiguration ex error " + ex);
  }
 } else {
  assertTrue("ZlibFactory is using native libs against request",
      ZlibFactory.isNativeZlibLoaded(conf));
 }
}