lib/fluent/plugin/webhdfs_compressor_snappy.rb in fluent-plugin-webhdfs-0.5.3 vs lib/fluent/plugin/webhdfs_compressor_snappy.rb in fluent-plugin-webhdfs-0.6.0rc1

@@ -1,6 +1,6 @@
-module Fluent
-  class WebHDFSOutput < Fluent::TimeSlicedOutput
+module Fluent::Plugin
+  class WebHDFSOutput < Output
     class SnappyCompressor < Compressor
       WebHDFSOutput.register_compressor('snappy', self)
 
       def initialize(options = {})
         begin