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

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