Class: Fluent::Compat::TextParser::ValuesParser

Inherits:

Parser

• Object
• Plugin::Parser
• Parser
• Fluent::Compat::TextParser::ValuesParser

Includes:

Fluent::Compat::TypeConverter

Defined in:

lib/fluent/compat/parser.rb

Constant Summary

Constants included from Fluent::Compat::TypeConverter

Fluent::Compat::TypeConverter::Converters

Instance Method Summary

• #configure(conf) ⇒ Object
• #values_map(values) ⇒ Object

Methods included from Fluent::Compat::TypeConverter

included

Instance Method Details

#configure(conf) ⇒ Object

# File 'lib/fluent/compat/parser.rb', line 191

def configure(conf)
  super

  if @time_key && !@keys.include?(@time_key) && @estimate_current_event
    raise Fluent::ConfigError, "time_key (#{@time_key.inspect}) is not included in keys (#{@keys.inspect})"
  end

  if @time_format && !@time_key
    raise Fluent::ConfigError, "time_format parameter is ignored because time_key parameter is not set. at #{conf.inspect}"
  end

  @time_parser = time_parser_create

  if @null_value_pattern
    @null_value_pattern = Regexp.new(@null_value_pattern)
  end

  @mutex = Mutex.new
end

#values_map(values) ⇒ Object

# File 'lib/fluent/compat/parser.rb', line 211

def values_map(values)
  record = Hash[keys.zip(values.map { |value| convert_value_to_nil(value) })]

  if @time_key
    value = @keep_time_key ? record[@time_key] : record.delete(@time_key)
    time = if value.nil?
             if @estimate_current_event
               Fluent::EventTime.now
             else
               nil
             end
           else
             @mutex.synchronize { @time_parser.parse(value) }
           end
  elsif @estimate_current_event
    time = Fluent::EventTime.now
  else
    time = nil
  end

  convert_field_type!(record) if @type_converters

  return time, record
end