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