Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
31 changes: 0 additions & 31 deletions src/export/clickhouse_exporter.cc
Original file line number Diff line number Diff line change
Expand Up @@ -176,9 +176,6 @@ class ClickHouseExporter : public StatsExporter {
shared_ptr<Column<uint64_t>> MetricUInt64(string_view name) final {
return MakeCol<FixedCol<uint64_t>>(name, "UInt64");
}
shared_ptr<Column<string_view>> MetricFixedString(int len, string_view name) final {
return MakeCol<FixedStringCol>(name, len);
}

shared_ptr<Column<int16_t>> RecordInt16(string_view name) final {
return MakeCol<FixedCol<int16_t>>(name, "Int16");
Expand Down Expand Up @@ -264,34 +261,6 @@ class ClickHouseExporter : public StatsExporter {
std::vector<uint64_t> offsets_;
};

class FixedStringCol : public Column<string_view> {
public:
FixedStringCol(ClickHouseExporter* exp, string_view name, int n)
: exp_(exp),
name_(name),
width_(static_cast<size_t>(n)),
type_name_("FixedString(" + std::to_string(n) + ")") {}
void Append(const string_view& s) final {
const size_t start = data_.size();
data_.resize(start + width_, '\0');
std::memcpy(data_.data() + start, s.data(), std::min(s.size(), width_));
++rows_;
}
void Crunch() final { exp_->AppendFixed(name_, type_name_.c_str(), data_.data(), rows_); }
void Clear() final {
data_.clear();
rows_ = 0;
}

private:
ClickHouseExporter* const exp_;
const std::string name_;
const size_t width_;
const std::string type_name_;
std::vector<char> data_;
size_t rows_ = 0;
};

template <typename ColT, typename... Args>
shared_ptr<ColT> MakeCol(string_view name, Args&&... args) {
if (auto it = col_index_.find(name); it != col_index_.end()) {
Expand Down
1 change: 0 additions & 1 deletion src/export/exporter_interface.h
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,6 @@ class StatsExporter {
virtual shared_ptr<Column<int64_t>> MetricInt64(string_view name) = 0;
virtual shared_ptr<Column<uint8_t>> MetricUInt8(string_view name) = 0;
virtual shared_ptr<Column<uint64_t>> MetricUInt64(string_view name) = 0;
virtual shared_ptr<Column<string_view>> MetricFixedString(int len, string_view name) = 0;

// Records: Data columns you wouldn't want to filter by.
virtual shared_ptr<Column<int16_t>> RecordInt16(string_view name) = 0;
Expand Down
4 changes: 0 additions & 4 deletions src/export/otel_exporter.cc
Original file line number Diff line number Diff line change
Expand Up @@ -170,10 +170,6 @@ class OTelExporter : public StatsExporter {
shared_ptr<Column<uint64_t>> MetricUInt64(string_view name) final {
return MakeIntCol<uint64_t>(name);
}
shared_ptr<Column<string_view>> MetricFixedString(int /*len*/, string_view name) final {
return MakeSvCol(name);
}

shared_ptr<Column<int16_t>> RecordInt16(string_view name) final {
return MakeIntCol<int16_t>(name);
}
Expand Down
Loading