# File lib/fluent/event.rb, line 25 def each(&block) raise NotImplementedError, "DO NOT USE THIS CLASS directly." end
# File lib/fluent/event.rb, line 21 def repeatable? false end
# File lib/fluent/event.rb, line 29 def to_msgpack_stream out = MessagePack::Packer.new # MessagePack::Packer is fastest way to serialize events each {|time,record| out.write([time,record]) } out.to_s end