# File lib/fluent/event.rb, line 27 def each(&block) raise NotImplementedError, "DO NOT USE THIS CLASS directly." end
# File lib/fluent/event.rb, line 23 def repeatable? false end
# File lib/fluent/event.rb, line 31 def to_msgpack_stream out = Fluent::Engine.msgpack_factory.packer each {|time,record| out.write([time,record]) } out.to_s end