Class: Fluent::BigQueryOutput::FieldSchema
- Inherits:
-
Object
- Object
- Fluent::BigQueryOutput::FieldSchema
- Defined in:
- lib/fluent/plugin/out_bigquery.rb
Direct Known Subclasses
BooleanFieldSchema, FloatFieldSchema, IntegerFieldSchema, RecordSchema, StringFieldSchema, TimestampFieldSchema
Instance Attribute Summary collapse
-
#mode ⇒ Object
readonly
Returns the value of attribute mode.
-
#name ⇒ Object
readonly
Returns the value of attribute name.
Instance Method Summary collapse
- #format(value) ⇒ Object
- #format_one(value) ⇒ Object
-
#initialize(name, mode = :nullable) ⇒ FieldSchema
constructor
A new instance of FieldSchema.
- #to_h ⇒ Object
Constructor Details
#initialize(name, mode = :nullable) ⇒ FieldSchema
Returns a new instance of FieldSchema.
517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 |
# File 'lib/fluent/plugin/out_bigquery.rb', line 517 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 |
Instance Attribute Details
#mode ⇒ Object (readonly)
Returns the value of attribute mode.
535 536 537 |
# File 'lib/fluent/plugin/out_bigquery.rb', line 535 def mode @mode end |
#name ⇒ Object (readonly)
Returns the value of attribute name.
535 536 537 |
# File 'lib/fluent/plugin/out_bigquery.rb', line 535 def name @name end |
Instance Method Details
#format(value) ⇒ Object
537 538 539 540 541 542 543 544 545 546 547 |
# File 'lib/fluent/plugin/out_bigquery.rb', line 537 def format(value) case @mode when :nullable format_one(value) unless value.nil? when :required raise "Required field #{name} cannot be null" if value.nil? format_one(value) when :repeated value.nil? ? [] : value.map {|v| format_one(v) } end end |
#format_one(value) ⇒ Object
549 550 551 |
# File 'lib/fluent/plugin/out_bigquery.rb', line 549 def format_one(value) raise NotImplementedError, "Must implement in a subclass" end |
#to_h ⇒ Object
553 554 555 556 557 558 559 |
# File 'lib/fluent/plugin/out_bigquery.rb', line 553 def to_h { :name => name, :type => type.to_s.upcase, :mode => mode.to_s.upcase, } end |