NewByteDecoder creates a BytesDecoder. defBytes: provided default value bytes in old datum format(flag+colData).
(columns []ColInfo, handleColIDs []int64, defBytes func(i int) ([]byte, error), loc *time.Location)
| 388 | // NewByteDecoder creates a BytesDecoder. |
| 389 | // defBytes: provided default value bytes in old datum format(flag+colData). |
| 390 | func NewByteDecoder(columns []ColInfo, handleColIDs []int64, defBytes func(i int) ([]byte, error), loc *time.Location) *BytesDecoder { |
| 391 | return &BytesDecoder{ |
| 392 | decoder: decoder{ |
| 393 | columns: columns, |
| 394 | handleColIDs: handleColIDs, |
| 395 | loc: loc, |
| 396 | }, |
| 397 | defBytes: defBytes, |
| 398 | } |
| 399 | } |
| 400 | |
| 401 | func (decoder *BytesDecoder) decodeToBytesInternal(outputOffset map[int64]int, handle kv.Handle, value []byte, cacheBytes []byte) ([][]byte, error) { |
| 402 | var r row |
no outgoing calls
searching dependent graphs…