Java 类org.apache.hadoop.io.compress.DirectDecompressor 实例源码

项目：QDrill 文件：DirectCodecPool.java

public DirectDecompressor borrowDirectDecompressor(){
  Preconditions.checkArgument(supportDirectDecompressor, "Tried to get a direct Decompressor from a non-direct codec.");
  try {
    return (DirectDecompressor) directDecompressorPool.borrowObject();
  } catch (Exception e) {
    throw new DrillRuntimeException(e);
  }
}

项目：QDrill 文件：DirectCodecPool.java

public void returnDecompressor(DirectDecompressor decompressor) {
  returnToPool(decompressor, directDePools);
}

项目：clowncar 文件：BloscCodec.java

@Override
public DirectDecompressor createDirectDecompressor() {
    return new BloscDecompressor(conf);
}

项目：hadoop-oss 文件：ZlibFactory.java

/**
 * Return the appropriate implementation of the zlib direct decompressor. 
 * 
 * @param conf configuration
 * @return the appropriate implementation of the zlib decompressor.
 */
public static DirectDecompressor getZlibDirectDecompressor(Configuration conf) {
  return (isNativeZlibLoaded(conf)) ? 
    new ZlibDecompressor.ZlibDirectDecompressor() : null; 
}

项目：hadoop 文件：ZlibFactory.java

/**
 * Return the appropriate implementation of the zlib direct decompressor. 
 * 
 * @param conf configuration
 * @return the appropriate implementation of the zlib decompressor.
 */
public static DirectDecompressor getZlibDirectDecompressor(Configuration conf) {
  return (isNativeZlibLoaded(conf)) ? 
    new ZlibDecompressor.ZlibDirectDecompressor() : null; 
}

项目：aliyun-oss-hadoop-fs 文件：ZlibFactory.java

/**
 * Return the appropriate implementation of the zlib direct decompressor. 
 * 
 * @param conf configuration
 * @return the appropriate implementation of the zlib decompressor.
 */
public static DirectDecompressor getZlibDirectDecompressor(Configuration conf) {
  return (isNativeZlibLoaded(conf)) ? 
    new ZlibDecompressor.ZlibDirectDecompressor() : null; 
}

项目：big-c 文件：ZlibFactory.java

/**
 * Return the appropriate implementation of the zlib direct decompressor. 
 * 
 * @param conf configuration
 * @return the appropriate implementation of the zlib decompressor.
 */
public static DirectDecompressor getZlibDirectDecompressor(Configuration conf) {
  return (isNativeZlibLoaded(conf)) ? 
    new ZlibDecompressor.ZlibDirectDecompressor() : null; 
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ZlibFactory.java

/**
 * Return the appropriate implementation of the zlib direct decompressor. 
 * 
 * @param conf configuration
 * @return the appropriate implementation of the zlib decompressor.
 */
public static DirectDecompressor getZlibDirectDecompressor(Configuration conf) {
  return (isNativeZlibLoaded(conf)) ? 
    new ZlibDecompressor.ZlibDirectDecompressor() : null; 
}

项目：hops 文件：ZlibFactory.java

/**
 * Return the appropriate implementation of the zlib direct decompressor. 
 * 
 * @param conf configuration
 * @return the appropriate implementation of the zlib decompressor.
 */
public static DirectDecompressor getZlibDirectDecompressor(Configuration conf) {
  return (isNativeZlibLoaded(conf)) ? 
    new ZlibDecompressor.ZlibDirectDecompressor() : null; 
}

项目：hadoop-on-lustre2 文件：ZlibFactory.java

/**
 * Return the appropriate implementation of the zlib direct decompressor. 
 * 
 * @param conf configuration
 * @return the appropriate implementation of the zlib decompressor.
 */
public static DirectDecompressor getZlibDirectDecompressor(Configuration conf) {
  return (isNativeZlibLoaded(conf)) ? 
    new ZlibDecompressor.ZlibDirectDecompressor() : null; 
}