From dff1b04089d57948119f3a9034d76e731d7a44b1 Mon Sep 17 00:00:00 2001 From: Kevin Biju Date: Wed, 11 Dec 2024 12:52:49 +0530 Subject: [PATCH] another another type to add --- flow/e2e/clickhouse/clickhouse.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/flow/e2e/clickhouse/clickhouse.go b/flow/e2e/clickhouse/clickhouse.go index 85209a846..916f0606f 100644 --- a/flow/e2e/clickhouse/clickhouse.go +++ b/flow/e2e/clickhouse/clickhouse.go @@ -198,6 +198,14 @@ func (s ClickHouseSuite) GetRows(table string, cols string) (*model.QRecordBatch } case *int64: qrow = append(qrow, qvalue.QValueInt64{Val: *v}) + case **int16: + if *v == nil { + qrow = append(qrow, qvalue.QValueNull(qvalue.QValueKindInt16)) + } else { + qrow = append(qrow, qvalue.QValueInt16{Val: **v}) + } + case *int16: + qrow = append(qrow, qvalue.QValueInt16{Val: *v}) default: return nil, fmt.Errorf("cannot convert %T to qvalue", v) }