class Fluent::Plugin::WebHDFSOutput::Compressor

Public Instance Methods

compress(chunk) click to toggle source
# File lib/fluent/plugin/out_webhdfs.rb, line 518
def compress(chunk)
end
configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_webhdfs.rb, line 511
def configure(conf)
  super
end
ext() click to toggle source
# File lib/fluent/plugin/out_webhdfs.rb, line 515
def ext
end
initialise(options = {}) click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_webhdfs.rb, line 507
def initialise(options = {})
  super()
end

Private Instance Methods

check_command(command, algo = nil) click to toggle source
# File lib/fluent/plugin/out_webhdfs.rb, line 523
def check_command(command, algo = nil)
  require 'open3'

  algo = command if algo.nil?
  begin
    Open3.capture3("#{command} -V")
  rescue Errno::ENOENT
    raise Fluent::ConfigError, "'#{command}' utility must be in PATH for #{algo} compression"
  end
end