equal
deleted
inserted
replaced
85 } |
85 } |
86 } |
86 } |
87 return false; |
87 return false; |
88 } |
88 } |
89 |
89 |
90 void CSVCommand::processDataStream(std::ostream& output, std::istream& input, const vector<relpipe::writer::string_t>& args) { |
90 void CSVCommand::process(std::istream& input, const vector<relpipe::writer::string_t>& args, std::shared_ptr<writer::RelationalWriter> writer) { |
91 wstring_convert < codecvt_utf8<wchar_t>> convertor; // UTF-8 is required for CSV |
91 wstring_convert < codecvt_utf8<wchar_t>> convertor; // UTF-8 is required for CSV |
92 std::shared_ptr<RelationalWriter> writer(Factory::create(output)); |
|
93 vector<AttributeMetadata> metadata; |
92 vector<AttributeMetadata> metadata; |
94 bool headerDone = false; |
93 bool headerDone = false; |
95 bool lastInRecord = false; |
94 bool lastInRecord = false; |
96 stringstream currentValue; |
95 stringstream currentValue; |
97 |
96 |