mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-30 05:30:51 +00:00
087d8ab020
The start was in https://github.com/ClickHouse/ClickHouse/pull/11026 It turned out that the problem was due to the incorrect mutate() implementation that lead to quadratic amount of column copying. This problem has since been fixed. Remove the excessively verbose logging, and also change appendToBlock of LogElement's to accept mutable columns instead of accepting a block and mutating it on each call. It looks wasteful, even though it is almost a noop.
52 lines
2.0 KiB
C++
52 lines
2.0 KiB
C++
#include <Interpreters/TraceLog.h>
|
|
#include <DataTypes/DataTypeArray.h>
|
|
#include <DataTypes/DataTypeString.h>
|
|
#include <DataTypes/DataTypesNumber.h>
|
|
#include <DataTypes/DataTypeDate.h>
|
|
#include <DataTypes/DataTypeDateTime.h>
|
|
#include <Common/ClickHouseRevision.h>
|
|
|
|
|
|
using namespace DB;
|
|
|
|
using TraceDataType = TraceLogElement::TraceDataType;
|
|
|
|
const TraceDataType::Values TraceLogElement::trace_values =
|
|
{
|
|
{"Real", static_cast<UInt8>(TraceType::Real)},
|
|
{"CPU", static_cast<UInt8>(TraceType::CPU)},
|
|
{"Memory", static_cast<UInt8>(TraceType::Memory)},
|
|
{"MemorySample", static_cast<UInt8>(TraceType::MemorySample)},
|
|
};
|
|
|
|
Block TraceLogElement::createBlock()
|
|
{
|
|
return
|
|
{
|
|
{std::make_shared<DataTypeDate>(), "event_date"},
|
|
{std::make_shared<DataTypeDateTime>(), "event_time"},
|
|
{std::make_shared<DataTypeUInt64>(), "timestamp_ns"},
|
|
{std::make_shared<DataTypeUInt32>(), "revision"},
|
|
{std::make_shared<TraceDataType>(trace_values), "trace_type"},
|
|
{std::make_shared<DataTypeUInt64>(), "thread_id"},
|
|
{std::make_shared<DataTypeString>(), "query_id"},
|
|
{std::make_shared<DataTypeArray>(std::make_shared<DataTypeUInt64>()), "trace"},
|
|
{std::make_shared<DataTypeInt64>(), "size"},
|
|
};
|
|
}
|
|
|
|
void TraceLogElement::appendToBlock(MutableColumns & columns) const
|
|
{
|
|
size_t i = 0;
|
|
|
|
columns[i++]->insert(DateLUT::instance().toDayNum(event_time));
|
|
columns[i++]->insert(event_time);
|
|
columns[i++]->insert(timestamp_ns);
|
|
columns[i++]->insert(ClickHouseRevision::get());
|
|
columns[i++]->insert(static_cast<UInt8>(trace_type));
|
|
columns[i++]->insert(thread_id);
|
|
columns[i++]->insertData(query_id.data(), query_id.size());
|
|
columns[i++]->insert(trace);
|
|
columns[i++]->insert(size);
|
|
}
|