equal
deleted
inserted
replaced
17 #pragma once |
17 #pragma once |
18 |
18 |
19 #include <iostream> |
19 #include <iostream> |
20 #include <sstream> |
20 #include <sstream> |
21 #include <vector> |
21 #include <vector> |
|
22 #include <memory> |
22 |
23 |
23 #include <relpipe/writer/TypeId.h> |
24 #include <relpipe/writer/TypeId.h> |
24 |
25 |
25 namespace relpipe { |
26 namespace relpipe { |
26 namespace in { |
27 namespace in { |
28 |
29 |
29 class CSVCommand { |
30 class CSVCommand { |
30 private: |
31 private: |
31 bool readValue(std::istream& input, std::stringstream& currentValue, bool& lastInRecord); |
32 bool readValue(std::istream& input, std::stringstream& currentValue, bool& lastInRecord); |
32 public: |
33 public: |
33 void processDataStream(std::ostream &output, std::istream& input, const vector<relpipe::writer::string_t>& args); |
34 void process(std::istream& input, const vector<relpipe::writer::string_t>& args, std::shared_ptr<writer::RelationalWriter> writer); |
34 |
35 |
35 }; |
36 }; |
36 |
37 |
37 } |
38 } |
38 } |
39 } |