--- a/src/CSVCommand.h Wed Sep 23 11:23:12 2020 +0200
+++ b/src/CSVCommand.h Wed Sep 23 11:26:33 2020 +0200
@@ -19,6 +19,7 @@
#include <iostream>
#include <sstream>
#include <vector>
+#include <memory>
#include <relpipe/writer/TypeId.h>
@@ -30,7 +31,7 @@
private:
bool readValue(std::istream& input, std::stringstream& currentValue, bool& lastInRecord);
public:
- void processDataStream(std::ostream &output, std::istream& input, const vector<relpipe::writer::string_t>& args);
+ void process(std::istream& input, const vector<relpipe::writer::string_t>& args, std::shared_ptr<writer::RelationalWriter> writer);
};