org.springframework.data.hadoop.pig
Class PigExecutor

java.lang.Object
  org.springframework.data.hadoop.pig.PigExecutor

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean

Direct Known Subclasses:

PigRunner, PigTasklet

public abstract class PigExecutor
extends java.lang.Object
implements org.springframework.beans.factory.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 java.util.List<org.apache.pig.backend.executionengine.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(java.util.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 java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception

executePigScripts

protected java.util.List<org.apache.pig.backend.executionengine.ExecJob> executePigScripts()

setScripts

public void setScripts(java.util.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 -