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, incrCommandCounter, incrJobCounter, incrJobCounter, 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 © 2015 Apache Software Foundation. All Rights Reserved.