org.springframework.data.hadoop.pig
Class PigExecutor

java.lang.Object
  extended by org.springframework.data.hadoop.pig.PigExecutor
All Implemented Interfaces:
InitializingBean
Direct Known Subclasses:
PigRunner

public abstract class PigExecutor
extends Object
implements InitializingBean

Common class for configuring and executing pig scripts. Shared by the Pig tasklet and runner.

Author:
Costin Leau

Constructor Summary
PigExecutor()
           
 
Method Summary
 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.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PigExecutor

public PigExecutor()
Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception
Specified by:
afterPropertiesSet in interface InitializingBean
Throws:
Exception

executePigScripts

protected List<ExecJob> executePigScripts()

setScripts

public void setScripts(Collection<PigScript> scripts)
Sets the pig scripts to be executed by this class.

Parameters:
scripts - The scripts to set.

setPigFactory

public void setPigFactory(PigServerFactory pigFactory)
Sets the pig server instance used by this class.

Parameters:
pigFactory - The pigFactory to set.

setPigTemplate

public void setPigTemplate(PigOperations pigTemplate)
Sets the pig template used by this class.

Parameters:
pigTemplate - the pigTemplate