code: func DoLocalLimit(reader io.Reader, writer io.Writer, n int, offset int, stats *pb.InstructionStat) error {
  
  	return util.ProcessRow(reader, nil, func(row *util.Row) error {
  		stats.InputCounter++
  
  		if offset > 0 {
  			offset--
  		} else {
  			if n > 0 {
  				row.WriteTo(writer)
  				stats.OutputCounter++
  			}
  			n--
  		}
  
  		return nil
  	})
  
  }
docs: // DoLocalLimit streamingly get the n items starting from offset