|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.pig.impl.plan.Operator<PhyPlanVisitor>
org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStore
public class POStore
The store operator which is used in two ways: 1) As a local operator it can be used to store files 2) In the Map Reduce setting, it is used to create jobs from MapReduce operators which keep the loads and stores in the Map and Reduce Plans till the job is created
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.PhysicalOperator |
---|
alias, dummyBag, dummyBool, dummyDateTime, dummyDBA, dummyDouble, dummyFloat, dummyInt, dummyLong, dummyMap, dummyString, dummyTuple, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, resultType |
Fields inherited from class org.apache.pig.impl.plan.Operator |
---|
mKey |
Constructor Summary | |
---|---|
POStore(OperatorKey k)
|
|
POStore(OperatorKey k,
int rp)
|
|
POStore(OperatorKey k,
int rp,
List<PhysicalOperator> inp)
|
Method Summary | |
---|---|
void |
cleanUp()
To perform cleanup when there is an error. |
boolean |
disableCounter()
|
int |
getIndex()
|
FileSpec |
getInputSpec()
|
Result |
getNext(Tuple t)
|
Schema |
getSchema()
|
FileSpec |
getSFile()
|
String |
getSignature()
|
SortInfo |
getSortInfo()
|
StoreFuncInterface |
getStoreFunc()
|
Tuple |
illustratorMarkup(Object in,
Object out,
int eqClassIndex)
input tuple mark up to be illustrate-able |
boolean |
isMultiStore()
|
boolean |
isTmpStore()
|
String |
name()
|
void |
setDisableCounter(boolean disableCounter)
|
void |
setIndex(int index)
|
void |
setInputSpec(FileSpec lFile)
|
void |
setIsTmpStore(boolean tmp)
|
void |
setMultiStore(boolean isMultiStore)
|
void |
setSchema(Schema schema)
|
void |
setSFile(FileSpec sFile)
|
void |
setSignature(String signature)
|
void |
setSortInfo(SortInfo sortInfo)
|
void |
setStoreFunc(StoreFuncInterface storeFunc)
|
void |
setStoreImpl(POStoreImpl impl)
|
void |
setUp()
Set up the storer |
boolean |
supportsMultipleInputs()
Indicates whether this operator supports multiple inputs. |
boolean |
supportsMultipleOutputs()
Indicates whether this operator supports multiple outputs. |
void |
tearDown()
Called at the end of processing for clean up. |
void |
visit(PhyPlanVisitor v)
Visit this node with the provided visitor. |
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator |
---|
addOriginalLocation, addOriginalLocation, attachInput, clone, cloneHelper, detachInput, getAlias, getAliasString, getDummy, getIllustrator, getInputs, getLogger, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getOriginalLocations, getPigLogger, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType |
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 |
---|
public POStore(OperatorKey k)
public POStore(OperatorKey k, int rp)
public POStore(OperatorKey k, int rp, List<PhysicalOperator> inp)
Method Detail |
---|
public void setUp() throws IOException
IOException
public void tearDown() throws IOException
IOException
public void cleanUp() throws IOException
IOException
public Result getNext(Tuple t) throws ExecException
getNext
in class PhysicalOperator
ExecException
public String name()
name
in class Operator<PhyPlanVisitor>
public boolean supportsMultipleInputs()
Operator
supportsMultipleInputs
in class Operator<PhyPlanVisitor>
public boolean supportsMultipleOutputs()
Operator
supportsMultipleOutputs
in class Operator<PhyPlanVisitor>
public void visit(PhyPlanVisitor v) throws VisitorException
Operator
visit
in class PhysicalOperator
v
- Visitor to visit with.
VisitorException
- if the visitor has a problem.public FileSpec getSFile()
public void setSFile(FileSpec sFile)
public void setInputSpec(FileSpec lFile)
public FileSpec getInputSpec()
public void setIsTmpStore(boolean tmp)
public boolean isTmpStore()
public void setStoreImpl(POStoreImpl impl)
public void setSchema(Schema schema)
public Schema getSchema()
public StoreFuncInterface getStoreFunc()
public void setSortInfo(SortInfo sortInfo)
sortInfo
- the sortInfo to setpublic SortInfo getSortInfo()
public String getSignature()
public void setSignature(String signature)
public void setMultiStore(boolean isMultiStore)
public boolean isMultiStore()
public Tuple illustratorMarkup(Object in, Object out, int eqClassIndex)
Illustrable
in
- input tupleout
- output tuple before wrapped in ExampleTupleeqClassIndex
- index into equivalence classes in illustrator
public void setIndex(int index)
public int getIndex()
public void setDisableCounter(boolean disableCounter)
public boolean disableCounter()
public void setStoreFunc(StoreFuncInterface storeFunc)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |