wonook commented on a change in pull request #293:
URL: https://github.com/apache/incubator-nemo/pull/293#discussion_r466203442
##########
File path:
compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/NemoPlanRewriter.java
##########
@@ -60,23 +68,44 @@
private final NemoOptimizer nemoOptimizer;
private final NemoBackend nemoBackend;
private final Map<Integer, Map<Object, Long>> messageIdToAggregatedData;
+ private CountDownLatch readyToRewriteLatch;
+ private final InjectionFuture<SimulationScheduler>
simulationSchedulerInjectionFuture;
+ private final PhysicalPlanGenerator physicalPlanGenerator;
private IRDAG currentIRDAG;
+ private PhysicalPlan currentPhysicalPlan;
@Inject
public NemoPlanRewriter(final NemoOptimizer nemoOptimizer,
- final NemoBackend nemoBackend) {
+ final NemoBackend nemoBackend,
+ final InjectionFuture<SimulationScheduler>
simulationSchedulerInjectionFuture,
+ final PhysicalPlanGenerator physicalPlanGenerator,
+ @Parameter(JobConf.ClientSideRPCServerHost.class)
final String clientHost,
+ @Parameter(JobConf.ClientSideRPCServerPort.class)
final int clientPort,
Review comment:
These args are unused.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
