class Fluent::Plugin::WebHDFSOutput::GzipCompressor

Public Class Methods

new(options = {}) click to toggle source
# File lib/fluent/plugin/webhdfs_compressor_gzip.rb, line 6
def initialize(options = {})
  require "zlib"
end

Public Instance Methods

compress(chunk, tmp) click to toggle source
# File lib/fluent/plugin/webhdfs_compressor_gzip.rb, line 14
def compress(chunk, tmp)
  w = Zlib::GzipWriter.new(tmp)
  chunk.write_to(w)
  w.finish
end
ext() click to toggle source
# File lib/fluent/plugin/webhdfs_compressor_gzip.rb, line 10
def ext
  ".gz"
end