NewChunkDecoder creates a NewChunkDecoder.
(columns []ColInfo, handleColIDs []int64, defDatum func(i int, chk *chunk.Chunk) error, loc *time.Location)
| 193 | |
| 194 | // NewChunkDecoder creates a NewChunkDecoder. |
| 195 | func NewChunkDecoder(columns []ColInfo, handleColIDs []int64, defDatum func(i int, chk *chunk.Chunk) error, loc *time.Location) *ChunkDecoder { |
| 196 | return &ChunkDecoder{ |
| 197 | decoder: decoder{ |
| 198 | columns: columns, |
| 199 | handleColIDs: handleColIDs, |
| 200 | loc: loc, |
| 201 | }, |
| 202 | defDatum: defDatum, |
| 203 | } |
| 204 | } |
| 205 | |
| 206 | // DecodeToChunk decodes a row to chunk. |
| 207 | func (decoder *ChunkDecoder) DecodeToChunk(rowData []byte, commitTS uint64, handle kv.Handle, chk *chunk.Chunk) error { |
no outgoing calls