Enum Constant Detail

• LZO

  public static final Compression.Algorithm LZO

• GZ

  public static final Compression.Algorithm GZ

• NONE

  public static final Compression.Algorithm NONE

• SNAPPY

  public static final Compression.Algorithm SNAPPY

• LZ4

  public static final Compression.Algorithm LZ4

• ZSTD

  public static final Compression.Algorithm ZSTD

Field Detail

• conf

  private final transient org.apache.hadoop.conf.Configuration conf

• compressName

  private final String compressName

• DATA_IBUF_SIZE

  private static final int DATA_IBUF_SIZE

  data input buffer size to absorb small reads from application.

  See Also:

  Constant Field Values

• DATA_OBUF_SIZE

  private static final int DATA_OBUF_SIZE

  data output buffer size to absorb small writes from application.

  See Also:

  Constant Field Values

Method Detail

• values

  public static Compression.Algorithm[] values()

  Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:

  for (Compression.Algorithm c : Compression.Algorithm.values())
      System.out.println(c);
  

  Returns:

  an array containing the constants of this enum type, in the order they are declared

• valueOf

  public static Compression.Algorithm valueOf(String name)

  Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)

  Parameters:

  name - the name of the enum constant to be returned.

  Returns:

  the enum constant with the specified name

  Throws:

  IllegalArgumentException - if this enum type has no constant with the specified name

  NullPointerException - if the argument is null

• getCodec

  abstract org.apache.hadoop.io.compress.CompressionCodec getCodec(org.apache.hadoop.conf.Configuration conf)

• createDecompressionStream

  public InputStream createDecompressionStream(InputStream downStream,
                                      org.apache.hadoop.io.compress.Decompressor decompressor,
                                      int downStreamBufferSize)
                                        throws IOException

  Throws:

  IOException

• createCompressionStream

  public OutputStream createCompressionStream(OutputStream downStream,
                                     org.apache.hadoop.io.compress.Compressor compressor,
                                     int downStreamBufferSize)
                                       throws IOException

  Throws:

  IOException

• createPlainCompressionStream

  public org.apache.hadoop.io.compress.CompressionOutputStream createPlainCompressionStream(OutputStream downStream,
                                                                                   org.apache.hadoop.io.compress.Compressor compressor)
                                                                                     throws IOException

  Creates a compression stream without any additional wrapping into buffering streams.

  Throws:

  IOException

• getCompressor

  public org.apache.hadoop.io.compress.Compressor getCompressor()

• returnCompressor

  public void returnCompressor(org.apache.hadoop.io.compress.Compressor compressor)

• getDecompressor

  public org.apache.hadoop.io.compress.Decompressor getDecompressor()

• returnDecompressor

  public void returnDecompressor(org.apache.hadoop.io.compress.Decompressor decompressor)

• getName

  public String getName()