1 | #include <DataStreams/AddingDefaultBlockOutputStream.h> |
---|---|
2 | #include <Interpreters/addMissingDefaults.h> |
3 | |
4 | |
5 | namespace DB |
6 | { |
7 | |
8 | void AddingDefaultBlockOutputStream::write(const Block & block) |
9 | { |
10 | output->write(addMissingDefaults(block, output_block.getNamesAndTypesList(), column_defaults, context)); |
11 | } |
12 | |
13 | void AddingDefaultBlockOutputStream::flush() |
14 | { |
15 | output->flush(); |
16 | } |
17 | |
18 | void AddingDefaultBlockOutputStream::writePrefix() |
19 | { |
20 | output->writePrefix(); |
21 | } |
22 | |
23 | void AddingDefaultBlockOutputStream::writeSuffix() |
24 | { |
25 | output->writeSuffix(); |
26 | } |
27 | |
28 | } |
29 |