lib/fluent/plugin/webhdfs_compressor_bzip2.rb in fluent-plugin-webhdfs-0.7.1 vs lib/fluent/plugin/webhdfs_compressor_bzip2.rb in fluent-plugin-webhdfs-1.0.0

@@ -1,15 +1,11 @@
-module Fluent
-  class WebHDFSOutput < Fluent::TimeSlicedOutput
+module Fluent::Plugin
+  class WebHDFSOutput < Output
     class Bzip2Compressor < Compressor
       WebHDFSOutput.register_compressor('bzip2', self)
 
       def initialize(options = {})
-        begin
-          require "bzip2/ffi"
-        rescue LoadError
-          raise Fluent::ConfigError, "Install bzip2-ffi before use bzip2 compressor"
-        end
+        require "bzip2/ffi"
       end
 
       def ext
         ".bz2"
       end