diff -r 012d491e219a -r 157bb1d5e08a src/CSVCommand.h
--- 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);
 
 };