Class: Fluent::WebHDFSOutput::Bzip2Compressor

Inherits:
Compressor
  • Object
show all
Defined in:
lib/fluent/plugin/webhdfs_compressor_bzip2.rb

Instance Method Summary collapse

Methods inherited from Compressor

#configure, #initialise

Constructor Details

#initialize(options = {}) ⇒ Bzip2Compressor

Returns a new instance of Bzip2Compressor.



6
7
8
 
# File 'lib/fluent/plugin/webhdfs_compressor_bzip2.rb', line 6

def initialize(options = {})
  require "bzip2/ffi"
end

Instance Method Details

#compress(chunk, tmp) ⇒ Object 



14
15
16
17
18
 
# File 'lib/fluent/plugin/webhdfs_compressor_bzip2.rb', line 14

def compress(chunk, tmp)
  Bzip2::FFI::Writer.open(tmp) do |writer|
    chunk.write_to(writer)
  end
end

#ext ⇒ Object 



10
11
12
 
# File 'lib/fluent/plugin/webhdfs_compressor_bzip2.rb', line 10

def ext
  ".bz2"
end