class Fluent::Plugin::WebHDFSOutput::ZstdCompressor

Public Class Methods

new(options = {}) click to toggle source
# File lib/fluent/plugin/webhdfs_compressor_zstd.rb, line 6
def initialize(options = {})
  begin
    require "zstandard"
  rescue LoadError
    raise Fluent::ConfigError, "Install zstandard gem before use of zstd compressor"
  end
end

Public Instance Methods

compress(chunk, tmp) click to toggle source
# File lib/fluent/plugin/webhdfs_compressor_zstd.rb, line 18
def compress(chunk, tmp)
  tmp.binmode
  tmp.write Zstandard.deflate(chunk.read)
end
ext() click to toggle source
# File lib/fluent/plugin/webhdfs_compressor_zstd.rb, line 14
def ext
  ".zst"
end