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