public class SimpleYarnJobProxyFactory extends java.lang.Object implements JobProxyFactory
AbstractJobProxy.fromFactory(org.apache.samza.rest.resources.JobsResourceConfig)| Constructor and Description |
|---|
SimpleYarnJobProxyFactory() |
| Modifier and Type | Method and Description |
|---|---|
JobProxy |
getJobProxy(JobsResourceConfig config)
Creates a new
JobProxy and initializes it with the specified config. |
public JobProxy getJobProxy(JobsResourceConfig config)
JobProxyFactoryJobProxy and initializes it with the specified config.getJobProxy in interface JobProxyFactoryconfig - the SamzaRestConfig to pass to the proxy.