| 151 | } |
| 152 | |
| 153 | MongoDBBlockInputStream::MongoDBBlockInputStream( |
| 154 | std::shared_ptr<Poco::MongoDB::Connection> & connection_, |
| 155 | std::unique_ptr<Poco::MongoDB::Cursor> cursor_, |
| 156 | const Block & sample_block, |
| 157 | UInt64 max_block_size_, |
| 158 | bool strict_check_names_) |
| 159 | : connection(connection_) |
| 160 | , cursor{std::move(cursor_)} |
| 161 | , max_block_size{max_block_size_} |
| 162 | , strict_check_names{strict_check_names_} |
| 163 | { |
| 164 | description.init(sample_block); |
| 165 | } |
| 166 | |
| 167 | |
| 168 | MongoDBBlockInputStream::~MongoDBBlockInputStream() = default; |