class Fluent::BigQueryOutput::FieldSchema
Attributes
mode[R]
name[R]
Public Class Methods
new(name, mode = :nullable)
click to toggle source
# File lib/fluent/plugin/out_bigquery.rb, line 640 def initialize(name, mode = :nullable) unless [:nullable, :required, :repeated].include?(mode) raise ConfigError, "Unrecognized mode for #{name}: #{mode}" end ### https://developers.google.com/bigquery/docs/tables # Each field has the following properties: # # name - The name must contain only letters (a-z, A-Z), numbers (0-9), or underscores (_), # and must start with a letter or underscore. The maximum length is 128 characters. # https://cloud.google.com/bigquery/docs/reference/v2/tables#schema.fields.name unless name =~ /^[_A-Za-z][_A-Za-z0-9]{,127}$/ raise Fluent::ConfigError, "invalid bigquery field name: '#{name}'" end @name = name @mode = mode end
Public Instance Methods
format(value)
click to toggle source
# File lib/fluent/plugin/out_bigquery.rb, line 660 def format(value) case @mode when :nullable format_one(value) unless value.nil? when :required if value.nil? log.warn "Required field #{name} cannot be null" nil else format_one(value) end when :repeated value.nil? ? [] : value.map {|v| format_one(v) } end end
format_one(value)
click to toggle source
# File lib/fluent/plugin/out_bigquery.rb, line 676 def format_one(value) raise NotImplementedError, "Must implement in a subclass" end
to_h()
click to toggle source
# File lib/fluent/plugin/out_bigquery.rb, line 680 def to_h { :name => name, :type => type.to_s.upcase, :mode => mode.to_s.upcase, } end