get_schema_info

in src/fluent-plugin-mdsd/lib/fluent/plugin/out_mdsd.rb [154:168]


    def get_schema_info(record)
        hashkey = get_schema_key(record)
        value = @schemaHash[hashkey]
        if value
            return value
        else
            new_schema_id = get_new_schema_id()
            new_schema_str = get_new_schema(record)
            new_schema = [new_schema_id, new_schema_str]

            @schemaHash[hashkey] = new_schema
            return new_schema
        end
    end