MCPcopy
hub / github.com/grafana/tempo / testColumnIteratorSeek

Function testColumnIteratorSeek

pkg/parquetquery/iters_test.go:148–173  ·  view source on GitHub ↗
(t *testing.T, makeIter makeTestIterFn)

Source from the content-addressed store, hash-verified

146}
147
148func testColumnIteratorSeek(t *testing.T, makeIter makeTestIterFn) {
149 count := 10_000
150 pf := createTestFile(t, count)
151
152 idx, _, _ := GetColumnIndexByPath(pf, "A")
153 iter := makeIter(pf, idx, nil, "A")
154 defer iter.Close()
155
156 seekTos := []int32{
157 100,
158 1234,
159 4567,
160 5000,
161 7890,
162 }
163
164 for _, seekTo := range seekTos {
165 rn := EmptyRowNumber()
166 rn[0] = seekTo
167 res, err := iter.SeekTo(rn, 0)
168 require.NoError(t, err)
169 require.NotNil(t, res, "seekTo=%v", seekTo)
170 require.Equal(t, RowNumber{seekTo, -1, -1, -1, -1, -1, -1, -1}, res.RowNumber)
171 require.Equal(t, seekTo, res.ToMap()["A"][0].Int32())
172 }
173}
174
175func TestColumnIteratorPredicate(t *testing.T) {
176 for _, tc := range iterTestCases {

Callers 1

TestColumnIteratorSeekFunction · 0.85

Calls 7

createTestFileFunction · 0.85
GetColumnIndexByPathFunction · 0.85
EmptyRowNumberFunction · 0.85
ToMapMethod · 0.80
CloseMethod · 0.65
SeekToMethod · 0.65
EqualMethod · 0.45

Tested by

no test coverage detected