...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package encoding
18
19 import (
20 "fmt"
21 "github.com/apache/arrow/go/v15/arrow/memory"
22 "github.com/apache/arrow/go/v15/parquet"
23 "github.com/stretchr/testify/assert"
24 "testing"
25 )
26
27 func TestDeltaByteArrayDecoder_SetData(t *testing.T) {
28 tests := []struct {
29 name string
30 nvalues int
31 data []byte
32 wantErr assert.ErrorAssertionFunc
33 }{
34 {
35 name: "null only page",
36 nvalues: 126609,
37 data: []byte{128, 1, 4, 0, 0},
38 wantErr: assert.NoError,
39 },
40 }
41 for _, tt := range tests {
42 d := NewDecoder(parquet.Types.ByteArray, parquet.Encodings.DeltaLengthByteArray, nil, memory.DefaultAllocator)
43 t.Run(tt.name, func(t *testing.T) {
44 tt.wantErr(t, d.SetData(tt.nvalues, tt.data), fmt.Sprintf("SetData(%v, %v)", tt.nvalues, tt.data))
45 })
46 }
47 }
48
View as plain text