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.
608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 |
# File 'lib/fluent/plugin/out_bigquery.rb', line 608 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.
626 627 628 |
# File 'lib/fluent/plugin/out_bigquery.rb', line 626 def mode @mode end |
#name ⇒ Object (readonly)
Returns the value of attribute name.
626 627 628 |
# File 'lib/fluent/plugin/out_bigquery.rb', line 626 def name @name end |
Instance Method Details
#format(value) ⇒ Object
628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 |
# File 'lib/fluent/plugin/out_bigquery.rb', line 628 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) ⇒ Object
644 645 646 |
# File 'lib/fluent/plugin/out_bigquery.rb', line 644 def format_one(value) raise NotImplementedError, "Must implement in a subclass" end |
#to_h ⇒ Object
648 649 650 651 652 653 654 |
# File 'lib/fluent/plugin/out_bigquery.rb', line 648 def to_h { :name => name, :type => type.to_s.upcase, :mode => mode.to_s.upcase, } end |