karaolidis/telegraf-clickhouse-plugin
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add LowCardinality host/measurement

Browse Source 
Signed-off-by: Nikolaos Karaolidis <nick@karaolidis.com>
This commit is contained in:
Nick Karaolidis
2023-07-27 09:40:25 +03:00
parent 7b2191d2ea
commit f2966b372e
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
plugins/outputs/clickhouse/clickhouse.go
View File

@@ -160,10 +160,10 @@ func (ch *ClickHouse) toDatatype(value interface{}) string {
func (ch *ClickHouse) toNullableDatatype(key string, value interface{}) string { func (ch *ClickHouse) toNullableDatatype(key string, value interface{}) string {
datatype := ch.toDatatype(value) datatype := ch.toDatatype(value)
if key != "host" && key != ch.TimestampColumn && key != "measurement" { if key == "host" || key == "measurement" {
return fmt.Sprintf("Nullable(%s)", datatype) return fmt.Sprintf("LowCardinality(%s)", datatype)
} }
return datatype return fmt.Sprintf("Nullable(%s)", datatype)
} }
func (ch *ClickHouse) pepareMetrics(metrics []telegraf.Metric, metricsData map[string][]map[string]interface{}, columns map[string]*orderedmap.OrderedMap[string, string]) { func (ch *ClickHouse) pepareMetrics(metrics []telegraf.Metric, metricsData map[string][]map[string]interface{}, columns map[string]*orderedmap.OrderedMap[string, string]) {