class Fluent::ArrayEventStream
and its representation is [ [time, record], [time, record], .. ]
Use this class for many events data with a tag
EventStream from entries: Array of [time, record]
def dup
def dup entries = @entries.map{ |time, record| [time, record.dup] } ArrayEventStream.new(entries) end
def each(&block)
def each(&block) @entries.each(&block) nil end
def empty?
def empty? @entries.empty? end
def initialize(entries)
def initialize(entries) @entries = entries end
def repeatable?
def repeatable? true end
def size
def size @entries.size end
def slice(index, num)
def slice(index, num) ArrayEventStream.new(@entries.slice(index, num)) end