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