2019-06-18 12:54:27 +00:00
|
|
|
#include <Storages/MergeTree/IMergedBlockOutputStream.h>
|
|
|
|
#include <IO/createWriteBufferFromFileBase.h>
|
2019-10-19 16:49:36 +00:00
|
|
|
#include <Storages/MergeTree/MergeTreeReaderSettings.h>
|
2019-10-21 15:33:59 +00:00
|
|
|
#include <Storages/MergeTree/IMergeTreeDataPartWriter.h>
|
|
|
|
|
2019-06-18 12:54:27 +00:00
|
|
|
namespace DB
|
|
|
|
{
|
|
|
|
|
|
|
|
namespace ErrorCodes
|
|
|
|
{
|
|
|
|
extern const int LOGICAL_ERROR;
|
|
|
|
}
|
|
|
|
|
|
|
|
namespace
|
|
|
|
{
|
2019-10-21 15:33:59 +00:00
|
|
|
// constexpr auto DATA_FILE_EXTENSION = ".bin";
|
2019-11-07 11:11:38 +00:00
|
|
|
// constexpr auto INDEX_FILE_EXTENSION = ".idx";
|
2019-06-18 12:54:27 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
IMergedBlockOutputStream::IMergedBlockOutputStream(
|
2019-11-07 11:11:38 +00:00
|
|
|
const MergeTreeDataPartPtr & data_part)
|
2019-10-19 16:49:36 +00:00
|
|
|
: storage(data_part->storage)
|
|
|
|
, part_path(data_part->getFullPath())
|
2019-06-18 12:54:27 +00:00
|
|
|
{
|
|
|
|
}
|
|
|
|
|
|
|
|
/// Implementation of IMergedBlockOutputStream::ColumnStream.
|
|
|
|
|
|
|
|
}
|