Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 6 additions & 2 deletions parquet/internal/encoding/fixed_len_byte_array_encoder.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,11 +41,15 @@ func (enc *PlainFixedLenByteArrayEncoder) Put(in []parquet.FixedLenByteArray) {

bytesNeeded := len(in) * typeLen
enc.sink.Reserve(bytesNeeded)

emptyValue := make([]byte, typeLen)

for _, val := range in {
if val == nil {
panic("value cannot be nil")
enc.sink.UnsafeWrite(emptyValue)
} else {
enc.sink.UnsafeWrite(val[:typeLen])
}
enc.sink.UnsafeWrite(val[:typeLen])
}
}

Expand Down
Loading