org.springframework.data.hadoop.pig
Class PigRunner
java.lang.Object
org.springframework.data.hadoop.pig.PigExecutor
org.springframework.data.hadoop.pig.PigRunner
- All Implemented Interfaces:
- Callable<List<ExecJob>>, InitializingBean
public class PigRunner
- extends PigExecutor
- implements Callable<List<ExecJob>>
Basic runner of Pig scripts inside a Spring environment. For more advanced functionality, consider using Spring Batch and the PigTasklet.
To make the runner execute at startup, use setRunAtStartup(boolean).
- Author:
- Costin Leau
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PigRunner
public PigRunner()
afterPropertiesSet
public void afterPropertiesSet()
throws Exception
- Specified by:
afterPropertiesSet in interface InitializingBean- Overrides:
afterPropertiesSet in class PigExecutor
- Throws:
Exception
call
public List<ExecJob> call()
throws Exception
- Specified by:
call in interface Callable<List<ExecJob>>
- Throws:
Exception
setRunAtStartup
public void setRunAtStartup(boolean runAtStartup)
- Indicates whether the scripts should run at container startup or not (the default).
- Parameters:
runAtStartup - The runAtStartup to set.
setPreAction
public void setPreAction(Collection<Callable<?>> actions)
- Actions to be invoked before running the action.
- Parameters:
actions -
setPostAction
public void setPostAction(Collection<Callable<?>> actions)
- Actions to be invoked after running the action.
- Parameters:
actions -