Class: Fluent::Plugin::WebHDFSOutput::Bzip2Compressor
- Inherits:
-
Compressor
- Object
- Compressor
- Fluent::Plugin::WebHDFSOutput::Bzip2Compressor
- Defined in:
- lib/fluent/plugin/webhdfs_compressor_bzip2.rb
Instance Method Summary collapse
- #compress(chunk, tmp) ⇒ Object
- #ext ⇒ Object
-
#initialize(options = {}) ⇒ Bzip2Compressor
constructor
A new instance of Bzip2Compressor.
Methods inherited from Compressor
Constructor Details
#initialize(options = {}) ⇒ Bzip2Compressor
Returns a new instance of Bzip2Compressor.
6 7 8 9 10 11 12 |
# File 'lib/fluent/plugin/webhdfs_compressor_bzip2.rb', line 6 def initialize( = {}) begin require "bzip2/ffi" rescue LoadError raise Fluent::ConfigError, "Install bzip2-ffi before use bzip2 compressor" end end |
Instance Method Details
#compress(chunk, tmp) ⇒ Object
18 19 20 21 22 |
# 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 ⇒ Object
14 15 16 |
# File 'lib/fluent/plugin/webhdfs_compressor_bzip2.rb', line 14 def ext ".bz2" end |