 +  
 +  @Override
 +  public void resourceOffer(SchedulerDriver d, String oid,
-+      SlaveOfferVector offers) {
++      List<SlaveOffer> offers) {
 +    try {
 +      synchronized(jobTracker) {
 +        LOG.info("Got resource offer " + oid);
-+        TaskDescriptionVector tasks = new TaskDescriptionVector();
++        List<TaskDescription> tasks = new ArrayList<TaskDescription>();
 +        
 +        int numOffers = (int) offers.size();
 +        int[] cpus = new int[numOffers];

+    
+    // Create a task description to pass back to Mesos
+    String name = "task " + mesosId + " (" + taskType + ")";
+    StringMap params = new StringMap();
+    params.set("cpus", "" + cpusPerTask);
+    params.set("mem", "" + memPerTask);
+    return new TaskDescription(mesosId, slaveId, name, params, new byte[0]);
+  }
+

+import mesos.Scheduler;
+import mesos.SchedulerDriver;
+import mesos.SlaveOffer;
+import mesos.TaskDescription;
+import mesos.TaskState;
+
+public class FrameworkScheduler extends Scheduler {
