equal
deleted
inserted
replaced
33 |
33 |
34 void processRelation(RelationConfiguration& configuration, std::shared_ptr<writer::RelationalWriter> writer) { |
34 void processRelation(RelationConfiguration& configuration, std::shared_ptr<writer::RelationalWriter> writer) { |
35 // Write header / metadata: |
35 // Write header / metadata: |
36 std::vector<relpipe::writer::AttributeMetadata> attributesMetadata; |
36 std::vector<relpipe::writer::AttributeMetadata> attributesMetadata; |
37 for (AttributeRecipe ar : configuration.attributes) attributesMetadata.push_back({ar.name, ar.type}); |
37 for (AttributeRecipe ar : configuration.attributes) attributesMetadata.push_back({ar.name, ar.type}); |
38 writer->startRelation(configuration.relation, attributesMetadata, true); |
38 writer->startRelation(configuration.relation, attributesMetadata, configuration.writeHeader); |
39 |
39 |
40 // Write records from CLI: |
40 // Write records from CLI: |
41 for (auto value : configuration.values) writer->writeAttribute(value); |
41 for (auto value : configuration.values) writer->writeAttribute(value); |
42 |
42 |
43 // Write records from STDIN: |
43 // Write records from STDIN: |