(p []byte, off int64)
| 285 | } |
| 286 | |
| 287 | func (r *ctxReaderAt) ReadAt(p []byte, off int64) (n int, err error) { |
| 288 | if err := r.ctx.Err(); err != nil { |
| 289 | return 0, err |
| 290 | } |
| 291 | return r.readerAt.ReadAt(p, off) |
| 292 | } |
| 293 | |
| 294 | func createFileWith[T any](t testing.TB, ctx context.Context, rows []T) *parquet.File { //nolint:revive |
| 295 | f, err := os.CreateTemp(t.TempDir(), "data.parquet") |