Skip to content

Commit

Permalink
Clean up generics
Browse files Browse the repository at this point in the history
  • Loading branch information
domoritz committed Mar 10, 2014
1 parent b6b2b54 commit b951ed4
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions src/edu/washington/escience/myria/parallel/Server.java
Expand Up @@ -1520,8 +1520,7 @@ public QueryFuture startLogDataStream(final long queryId, final long fragmentId,

/* Construct the workers' {@link SingleQueryPlanWithArgs}. */
SingleQueryPlanWithArgs workerPlan = new SingleQueryPlanWithArgs(producer);
Map<Integer, SingleQueryPlanWithArgs> workerPlans =
new HashMap<Integer, SingleQueryPlanWithArgs>(actualWorkers.size());
Map<Integer, SingleQueryPlanWithArgs> workerPlans = new HashMap<>(actualWorkers.size());
for (Integer worker : actualWorkers) {
workerPlans.put(worker, workerPlan);
}
Expand Down Expand Up @@ -1596,8 +1595,7 @@ public QueryFuture startProfilingRootsLogDataStream(final long queryId, final lo

/* Construct the workers' {@link SingleQueryPlanWithArgs}. */
SingleQueryPlanWithArgs workerPlan = new SingleQueryPlanWithArgs(producer);
Map<Integer, SingleQueryPlanWithArgs> workerPlans =
new HashMap<Integer, SingleQueryPlanWithArgs>(actualWorkers.size());
Map<Integer, SingleQueryPlanWithArgs> workerPlans = new HashMap<>(actualWorkers.size());
for (Integer worker : actualWorkers) {
workerPlans.put(worker, workerPlan);
}
Expand Down

0 comments on commit b951ed4

Please sign in to comment.