public class StreamingDelegator extends LauncherDelegator
LauncherDelegator.JobType
runAs
appConf
Constructor and Description |
---|
StreamingDelegator(AppConfig appConf) |
Modifier and Type | Method and Description |
---|---|
EnqueueBean |
run(java.lang.String user,
java.util.Map<java.lang.String,java.lang.Object> userArgs,
java.util.List<java.lang.String> inputs,
java.lang.String output,
java.lang.String mapper,
java.lang.String reducer,
java.lang.String combiner,
java.util.List<java.lang.String> fileList,
java.lang.String files,
java.util.List<java.lang.String> defines,
java.util.List<java.lang.String> cmdenvs,
java.util.List<java.lang.String> jarArgs,
java.lang.String statusdir,
java.lang.String callback,
java.lang.String completedUrl,
boolean enableLog,
LauncherDelegator.JobType jobType) |
addCacheFiles, addDef, enqueueController, makeLauncherArgs, makeOverrideClasspath, registerJob
public StreamingDelegator(AppConfig appConf)
public EnqueueBean run(java.lang.String user, java.util.Map<java.lang.String,java.lang.Object> userArgs, java.util.List<java.lang.String> inputs, java.lang.String output, java.lang.String mapper, java.lang.String reducer, java.lang.String combiner, java.util.List<java.lang.String> fileList, java.lang.String files, java.util.List<java.lang.String> defines, java.util.List<java.lang.String> cmdenvs, java.util.List<java.lang.String> jarArgs, java.lang.String statusdir, java.lang.String callback, java.lang.String completedUrl, boolean enableLog, LauncherDelegator.JobType jobType) throws NotAuthorizedException, BadParam, BusyException, QueueException, ExecuteException, java.io.IOException, java.lang.InterruptedException
NotAuthorizedException
BadParam
BusyException
QueueException
ExecuteException
java.io.IOException
java.lang.InterruptedException
Copyright © 2012 The Apache Software Foundation