public class StreamingDelegator extends LauncherDelegator
LauncherDelegator.JobType
runAs
appConf, ARCHIVES, FILES
Constructor and Description |
---|
StreamingDelegator(AppConfig appConf) |
Modifier and Type | Method and Description |
---|---|
EnqueueBean |
run(String user,
Map<String,Object> userArgs,
List<String> inputs,
String inputreader,
String output,
String mapper,
String reducer,
String combiner,
List<String> fileList,
String files,
List<String> defines,
List<String> cmdenvs,
List<String> jarArgs,
String statusdir,
String callback,
String completedUrl,
boolean enableLog,
Boolean enableJobReconnect,
LauncherDelegator.JobType jobType) |
addCacheFiles, addDef, enqueueController, enqueueJob, getTempletonController, killJob, makeLauncherArgs, makeOverrideClasspath, registerJob, runTempletonControllerJob
public StreamingDelegator(AppConfig appConf)
public EnqueueBean run(String user, Map<String,Object> userArgs, List<String> inputs, String inputreader, String output, String mapper, String reducer, String combiner, List<String> fileList, String files, List<String> defines, List<String> cmdenvs, List<String> jarArgs, String statusdir, String callback, String completedUrl, boolean enableLog, Boolean enableJobReconnect, LauncherDelegator.JobType jobType) throws NotAuthorizedException, BadParam, BusyException, QueueException, org.apache.commons.exec.ExecuteException, IOException, InterruptedException, TooManyRequestsException
NotAuthorizedException
BadParam
BusyException
QueueException
org.apache.commons.exec.ExecuteException
IOException
InterruptedException
TooManyRequestsException
Copyright © 2019 The Apache Software Foundation. All rights reserved.