public class CoordActionMaterializeCommand extends CoordinatorCommand<Void>
Modifier and Type | Field and Description |
---|---|
static String |
CONF_DEFAULT_TIMEOUT_CATCHUP
Default timeout for catchup jobs, in minutes, after which coordinator input check will timeout
|
dryrun, instrumentation, LOCK_FAILURE_REQUEUE_INTERVAL
Constructor and Description |
---|
CoordActionMaterializeCommand(String jobId,
Date startTime,
Date endTime) |
Modifier and Type | Method and Description |
---|---|
protected Void |
call(CoordinatorStore store)
DagCallable subclasses must implement this method to perform their task.
|
protected Void |
execute(CoordinatorStore store) |
static void |
main(String[] args)
For preliminery testing.
|
protected String |
materializeJobs(boolean dryrun,
CoordinatorJobBean jobBean,
org.apache.hadoop.conf.Configuration conf,
CoordinatorStore store)
Create action instances starting from "start-time" to end-time" and store them into Action table.
|
getStoreClass
call, getCreatedTime, getEntityKey, getInstrumentation, getKey, getName, getPriority, getType, inInterruptMode, lock, logQueueCallableFalse, queueCallable, queueCallable, queueCallable, queueCallableForException, resetLogInfoAction, resetLogInfoWorkflow, setInterruptMode, setLogInfo, setLogInfo, setLogInfo, setLogInfo, toString
public static final String CONF_DEFAULT_TIMEOUT_CATCHUP
public CoordActionMaterializeCommand(String jobId, Date startTime, Date endTime)
protected Void call(CoordinatorStore store) throws CommandException
Command
call
in class Command<Void,CoordinatorStore>
store
- the workflow store instance for the callable, null
if the callable does not use a
store.CommandException
- thrown if the command could not perform its operation.protected String materializeJobs(boolean dryrun, CoordinatorJobBean jobBean, org.apache.hadoop.conf.Configuration conf, CoordinatorStore store) throws Exception
dryrun
- jobBean
- conf
- store
- Exception
protected Void execute(CoordinatorStore store) throws StoreException, CommandException
execute
in class Command<Void,CoordinatorStore>
StoreException
CommandException
Copyright © 2014 Apache Software Foundation. All Rights Reserved.