class Fluent::Plugin::WebHDFSOutput::SnappyCompressor

Constants

DEFAULT_BLOCK_SIZE

Public Class Methods

new(options = {}) click to toggle source
Calls superclass method
# File lib/fluent/plugin/webhdfs_compressor_snappy.rb, line 11
def initialize(options = {})
  super()
  begin
    require "snappy"
  rescue LoadError
    raise Fluent::ConfigError, "Install snappy before using snappy compressor"
  end
end

Public Instance Methods

compress(chunk, tmp) click to toggle source
# File lib/fluent/plugin/webhdfs_compressor_snappy.rb, line 24
def compress(chunk, tmp)
  Snappy::Writer.new(tmp, @block_size) do |w|
    w << chunk.read
    w.flush
  end
end
ext() click to toggle source
# File lib/fluent/plugin/webhdfs_compressor_snappy.rb, line 20
def ext
  ".sz"
end