public abstract class PigExecutor extends Object implements InitializingBean
| Constructor and Description |
|---|
PigExecutor() |
| Modifier and Type | Method and Description |
|---|---|
void |
afterPropertiesSet() |
protected List<ExecJob> |
executePigScripts() |
void |
setPigFactory(PigServerFactory pigFactory)
Sets the pig server instance used by this class.
|
void |
setPigTemplate(PigOperations pigTemplate)
Sets the pig template used by this class.
|
void |
setScripts(Collection<PigScript> scripts)
Sets the pig scripts to be executed by this class.
|
public void afterPropertiesSet()
throws Exception
afterPropertiesSet in interface InitializingBeanExceptionpublic void setScripts(Collection<PigScript> scripts)
scripts - The scripts to set.public void setPigFactory(PigServerFactory pigFactory)
pigFactory - The pigFactory to set.public void setPigTemplate(PigOperations pigTemplate)
pigTemplate - the pigTemplate