public class PigDelegator extends LauncherDelegator
LauncherDelegator.JobType
runAs
appConf, ARCHIVES, FILES
Constructor and Description |
---|
PigDelegator(AppConfig appConf) |
Modifier and Type | Method and Description |
---|---|
EnqueueBean |
run(String user,
Map<String,Object> userArgs,
String execute,
String srcFile,
List<String> pigArgs,
String otherFiles,
String statusdir,
String callback,
boolean usesHcatalog,
String completedUrl,
boolean enablelog,
Boolean enableJobReconnect) |
addCacheFiles, addDef, enqueueController, enqueueJob, getTempletonController, killJob, makeLauncherArgs, makeOverrideClasspath, registerJob, runTempletonControllerJob
public PigDelegator(AppConfig appConf)
public EnqueueBean run(String user, Map<String,Object> userArgs, String execute, String srcFile, List<String> pigArgs, String otherFiles, String statusdir, String callback, boolean usesHcatalog, String completedUrl, boolean enablelog, Boolean enableJobReconnect) 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 © 2022 The Apache Software Foundation. All rights reserved.