com.intropro.prairie.unit.pig

Class PigUnit

java.lang.Object

com.intropro.prairie.unit.common.BaseUnit

com.intropro.prairie.unit.hadoop.HadoopUnit

com.intropro.prairie.unit.pig.PigUnit

All Implemented Interfaces:

com.intropro.prairie.unit.common.Unit

public class PigUnit
extends HadoopUnit

Created by presidentio on 10/21/15.

Constructor Summary

Constructors

Constructor and Description
PigUnit()

Method Summary

Modifier and Type	Method and Description
protected void	destroy()
org.apache.hadoop.conf.Configuration	getConfig()
protected void	init()
void	run(String script)
void	run(String script, Map<String,String> placeholders)

Methods inherited from class com.intropro.prairie.unit.hadoop.HadoopUnit

createConfig, dumpConfigs

Methods inherited from class com.intropro.prairie.unit.common.BaseUnit

getTmpDir, getUnitName, replacePlaceholders, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PigUnit

public PigUnit()

Method Detail

getConfig

public org.apache.hadoop.conf.Configuration getConfig()

Specified by:

getConfig in class HadoopUnit

init

protected void init()
             throws com.intropro.prairie.unit.common.exception.InitUnitException

Specified by:

init in class com.intropro.prairie.unit.common.BaseUnit

Throws:

com.intropro.prairie.unit.common.exception.InitUnitException

destroy

protected void destroy()
                throws com.intropro.prairie.unit.common.exception.DestroyUnitException

Specified by:

destroy in class com.intropro.prairie.unit.common.BaseUnit

Throws:

com.intropro.prairie.unit.common.exception.DestroyUnitException

run

public void run(String script,
                Map<String,String> placeholders)
         throws org.apache.pig.PigException

Throws:

org.apache.pig.PigException

run

public void run(String script)
         throws org.apache.pig.PigException

Throws:

org.apache.pig.PigException