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

ZlibCodec介绍

暂无

代码示例

代码示例来源：origin: apache/nifi

public static CompressionCodec createCodec(CompressionKind kind) {
  switch (kind) {
    case NONE:
      return null;
    case ZLIB:
      return new ZlibCodec();
    case SNAPPY:
      return new SnappyCodec();
    case LZO:
      try {
        Class<? extends CompressionCodec> lzo =
            (Class<? extends CompressionCodec>)
                JavaUtils.loadClass("org.apache.hadoop.hive.ql.io.orc.LzoCodec");
        return lzo.newInstance();
      } catch (ClassNotFoundException e) {
        throw new IllegalArgumentException("LZO is not available.", e);
      } catch (InstantiationException e) {
        throw new IllegalArgumentException("Problem initializing LZO", e);
      } catch (IllegalAccessException e) {
        throw new IllegalArgumentException("Insufficient access to LZO", e);
      }
    default:
      throw new IllegalArgumentException("Unknown compression codec: " +
          kind);
  }
}

代码示例来源：origin: com.facebook.presto.hive/hive-apache

@Override
public void decompress(ByteBuffer in, ByteBuffer out) throws IOException {
 if(in.isDirect() && out.isDirect()) {
  directDecompress(in, out);
  return;
 }
 Inflater inflater = new Inflater(true);
 inflater.setInput(in.array(), in.arrayOffset() + in.position(),
          in.remaining());
 while (!(inflater.finished() || inflater.needsDictionary() ||
      inflater.needsInput())) {
  try {
   int count = inflater.inflate(out.array(),
                  out.arrayOffset() + out.position(),
                  out.remaining());
   out.position(count + out.position());
  } catch (DataFormatException dfe) {
   throw new IOException("Bad compression data", dfe);
  }
 }
 out.flip();
 inflater.end();
 in.position(in.limit());
}

代码示例来源：origin: com.facebook.presto.hive/hive-apache

return new ZlibCodec(l, s);

代码示例来源：origin: com.facebook.presto.hive/hive-apache

public static CompressionCodec createCodec(CompressionKind kind) {
 switch (kind) {
  case NONE:
   return null;
  case ZLIB:
   return new ZlibCodec();
  case SNAPPY:
   return new SnappyCodec();
  case LZO:
   try {
    Class<? extends CompressionCodec> lzo =
      (Class<? extends CompressionCodec>)
        JavaUtils.loadClass("org.apache.hadoop.hive.ql.io.orc.LzoCodec");
    return lzo.newInstance();
   } catch (ClassNotFoundException e) {
    throw new IllegalArgumentException("LZO is not available.", e);
   } catch (InstantiationException e) {
    throw new IllegalArgumentException("Problem initializing LZO", e);
   } catch (IllegalAccessException e) {
    throw new IllegalArgumentException("Insufficient access to LZO", e);
   }
  default:
   throw new IllegalArgumentException("Unknown compression codec: " +
     kind);
 }
}

代码示例来源：origin: org.apache.nifi/nifi-hive-processors

public static CompressionCodec createCodec(CompressionKind kind) {
  switch (kind) {
    case NONE:
      return null;
    case ZLIB:
      return new ZlibCodec();
    case SNAPPY:
      return new SnappyCodec();
    case LZO:
      try {
        Class<? extends CompressionCodec> lzo =
            (Class<? extends CompressionCodec>)
                JavaUtils.loadClass("org.apache.hadoop.hive.ql.io.orc.LzoCodec");
        return lzo.newInstance();
      } catch (ClassNotFoundException e) {
        throw new IllegalArgumentException("LZO is not available.", e);
      } catch (InstantiationException e) {
        throw new IllegalArgumentException("Problem initializing LZO", e);
      } catch (IllegalAccessException e) {
        throw new IllegalArgumentException("Insufficient access to LZO", e);
      }
    default:
      throw new IllegalArgumentException("Unknown compression codec: " +
          kind);
  }
}