package com.cloudera.flume.master.commands;
import java.io.IOException;
import com.cloudera.flume.master.Command;
import com.cloudera.flume.master.Execable;
import com.cloudera.flume.master.FlumeMaster;
import com.cloudera.flume.master.MasterExecException;
import com.google.common.base.Preconditions;
String physicalNode;
String logicalNode;
return physicalNode;
}
this.physicalNode = physicalNode;
}
return logicalNode;
}
this.logicalNode = logicalNode;
}
String[] args = { physicalNode, logicalNode };
return new Command("spawn", args);
}
return new Execable() {
@Override
public void exec(String[] args)
throws MasterExecException, IOException {
Preconditions.checkArgument(args.length == 2);
String physical = args[0];
String logical = args[1];
if (!FlumeMaster.getInstance().getSpecMan()
.addLogicalNode(physical, logical)) {
throw new IllegalStateException("Unable to map logical node "
+ logical + " to physical node " + physical);
}
}
};
}
}