get_new_schema

in src/fluent-plugin-mdsd/lib/fluent/plugin/out_mdsd.rb [183:206]

• 19 lines of code
• 3 McCabe index (conditional complexity)

    def get_new_schema(record)
        schema_str = ""

        
        time_field_index = record.size() - 1
        record.each { |key, value|
            rb_typestr = value.class.name
            mdsd_typestr = @@rb2mdsdType[rb_typestr]
            if !mdsd_typestr
                mdsd_typestr = "FT_STRING"
            end

            if (schema_str == "")
                schema_str << "[" << time_field_index.to_s << ","
            else
                schema_str << ","
            end
            schema_str << '["' << key << '","' << mdsd_typestr << '"]'
        }
        schema_str << "]"

        return schema_str
    end