class Fluent::Plugin::WebHDFSOutput::Bzip2Compressor

Public Class Methods

new(options = {}) click to toggle source
# File lib/fluent/plugin/webhdfs_compressor_bzip2.rb, line 6
def initialize(options = {})
  begin
    require "bzip2/ffi"
  rescue LoadError
    raise Fluent::ConfigError, "Install bzip2-ffi before use bzip2 compressor"
  end
end

Public Instance Methods

compress(chunk, tmp) click to toggle source
# File lib/fluent/plugin/webhdfs_compressor_bzip2.rb, line 18
def compress(chunk, tmp)
  Bzip2::FFI::Writer.open(tmp) do |writer|
    chunk.write_to(writer)
  end
end
ext() click to toggle source
# File lib/fluent/plugin/webhdfs_compressor_bzip2.rb, line 14
def ext
  ".bz2"
end