org.apache.pig.backend.hadoop.executionengine.tez.plan.operator

Class POStoreTez

java.lang.Object

org.apache.pig.impl.plan.Operator<PhyPlanVisitor>

org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStore

org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POStoreTez

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.lang.Comparable<Operator>, TezOutput, TezTaskConfigurable, Illustrable

public class POStoreTez
extends POStore
implements TezOutput, TezTaskConfigurable

POStoreTez is used to write to a Tez MROutput

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

PhysicalOperator.OriginalLocation

Field Summary

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStore

empty

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

alias, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType

Fields inherited from class org.apache.pig.impl.plan.Operator

mKey

Constructor Summary

Constructors

Constructor and Description
POStoreTez(OperatorKey k)
POStoreTez(POStore copy)

Method Summary

Methods

Modifier and Type	Method and Description
void	attachOutputs(java.util.Map<java.lang.String,LogicalOutput> outputs, org.apache.hadoop.conf.Configuration conf)
Result	getNextTuple()
java.lang.String	getOutputKey()
java.lang.String[]	getTezOutputs()
void	initialize(ProcessorContext processorContext)
void	replaceOutput(java.lang.String oldOutputKey, java.lang.String newOutputKey)
void	setOutputKey(java.lang.String outputKey)

Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStore

cleanUp, disableCounter, getCacheFiles, getIndex, getInputSpec, getSchema, getSFile, getShipFiles, getSignature, getSortInfo, getStoreFunc, illustratorMarkup, isMultiStore, isTmpStore, name, setCacheFiles, setDisableCounter, setIndex, setInputSpec, setIsTmpStore, setMultiStore, setSchema, setSFile, setShipFiles, setSignature, setSortInfo, setStoreFunc, setStoreImpl, setUp, supportsMultipleInputs, supportsMultipleOutputs, tearDown, visit

Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

addOriginalLocation, addOriginalLocation, attachInput, clone, cloneHelper, copyAliasFrom, detachInput, getAlias, getAliasString, getIllustrator, getInputs, getLogger, getNext, getNextBigDecimal, getNextBigInteger, getNextBoolean, getNextDataBag, getNextDataByteArray, getNextDateTime, getNextDouble, getNextFloat, getNextInteger, getNextLong, getNextMap, getNextString, getOriginalLocations, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup

Methods inherited from class org.apache.pig.impl.plan.Operator

compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

POStoreTez

public POStoreTez(OperatorKey k)

POStoreTez

public POStoreTez(POStore copy)

Method Detail

getOutputKey

public java.lang.String getOutputKey()

setOutputKey

public void setOutputKey(java.lang.String outputKey)

getTezOutputs

public java.lang.String[] getTezOutputs()

Specified by:

getTezOutputs in interface TezOutput

initialize

public void initialize(ProcessorContext processorContext)
                throws ExecException

Specified by:

initialize in interface TezTaskConfigurable

Throws:

ExecException

replaceOutput

public void replaceOutput(java.lang.String oldOutputKey,
                 java.lang.String newOutputKey)

Specified by:

replaceOutput in interface TezOutput

attachOutputs

public void attachOutputs(java.util.Map<java.lang.String,LogicalOutput> outputs,
                 org.apache.hadoop.conf.Configuration conf)
                   throws ExecException

Specified by:

attachOutputs in interface TezOutput

Throws:

ExecException

getNextTuple

public Result getNextTuple()
                    throws ExecException

Overrides:

getNextTuple in class POStore

Throws:

ExecException