1 Commits

Author SHA1 Message Date
f2966b372e Add LowCardinality host/measurement
Signed-off-by: Nikolaos Karaolidis <nick@karaolidis.com>
2023-07-27 09:40:25 +03:00

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]) {