org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
Class POStream

java.lang.Object
  extended by org.apache.pig.impl.plan.Operator<PhyPlanVisitor>
      extended by org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
          extended by org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream
All Implemented Interfaces:
Serializable, Cloneable, Comparable<Operator>, Illustrable

public class POStream
extends PhysicalOperator

See Also:
Serialized Form

Field Summary
protected  boolean allInputFromPredecessorConsumed
           
protected  boolean allOutputFromBinaryProcessed
           
protected  BlockingQueue<Result> binaryInputQueue
           
protected  BlockingQueue<Result> binaryOutputQueue
           
protected  boolean initialized
           
 
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
alias, dummyBag, dummyBool, 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
POStream(OperatorKey k, ExecutableManager executableManager, StreamingCommand command, Properties properties)
           
 
Method Summary
 void finish()
           
 BlockingQueue<Result> getBinaryInputQueue()
           
 BlockingQueue<Result> getBinaryOutputQueue()
           
 StreamingCommand getCommand()
          Get the StreamingCommand for this StreamSpec.
 Result getNext(Tuple t)
           
 Result getNextHelper(Tuple t)
           
 Properties getShipCacheProperties()
           
 Tuple illustratorMarkup(Object in, Object out, int eqClassIndex)
          input tuple mark up to be illustrate-able
 String name()
           
 boolean supportsMultipleInputs()
          Indicates whether this operator supports multiple inputs.
 boolean supportsMultipleOutputs()
          Indicates whether this operator supports multiple outputs.
 String toString()
           
 void visit(PhyPlanVisitor v)
          Visit this node with the provided visitor.
 
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
attachInput, clone, cloneHelper, detachInput, getAlias, getAliasString, getDummy, getIllustrator, getInputs, getLogger, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getPigLogger, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setAlias, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType
 
Methods inherited from class org.apache.pig.impl.plan.Operator
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, unsetProjectionMap
 
Methods inherited from class java.lang.Object
finalize, getClass, notify, notifyAll, wait, wait, wait
 

Field Detail

initialized

protected boolean initialized

binaryOutputQueue

protected BlockingQueue<Result> binaryOutputQueue

binaryInputQueue

protected BlockingQueue<Result> binaryInputQueue

allInputFromPredecessorConsumed

protected boolean allInputFromPredecessorConsumed

allOutputFromBinaryProcessed

protected boolean allOutputFromBinaryProcessed
Constructor Detail

POStream

public POStream(OperatorKey k,
                ExecutableManager executableManager,
                StreamingCommand command,
                Properties properties)
Method Detail

getShipCacheProperties

public Properties getShipCacheProperties()

getCommand

public StreamingCommand getCommand()
Get the StreamingCommand for this StreamSpec.

Returns:
the StreamingCommand for this StreamSpec

getNext

public Result getNext(Tuple t)
               throws ExecException
Overrides:
getNext in class PhysicalOperator
Throws:
ExecException

getNextHelper

public Result getNextHelper(Tuple t)
                     throws ExecException
Throws:
ExecException

toString

public String toString()
Overrides:
toString in class Operator<PhyPlanVisitor>

visit

public void visit(PhyPlanVisitor v)
           throws VisitorException
Description copied from class: Operator
Visit this node with the provided visitor. This should only be called by the visitor class itself, never directly.

Specified by:
visit in class PhysicalOperator
Parameters:
v - Visitor to visit with.
Throws:
VisitorException - if the visitor has a problem.

name

public String name()
Specified by:
name in class Operator<PhyPlanVisitor>

supportsMultipleInputs

public boolean supportsMultipleInputs()
Description copied from class: Operator
Indicates whether this operator supports multiple inputs.

Specified by:
supportsMultipleInputs in class Operator<PhyPlanVisitor>
Returns:
true if it does, otherwise false.

supportsMultipleOutputs

public boolean supportsMultipleOutputs()
Description copied from class: Operator
Indicates whether this operator supports multiple outputs.

Specified by:
supportsMultipleOutputs in class Operator<PhyPlanVisitor>
Returns:
true if it does, otherwise false.

finish

public void finish()
            throws IOException
Throws:
IOException

getBinaryInputQueue

public BlockingQueue<Result> getBinaryInputQueue()
Returns:
the Queue which has input to binary

getBinaryOutputQueue

public BlockingQueue<Result> getBinaryOutputQueue()
Returns:
the Queue which has output from binary

illustratorMarkup

public Tuple illustratorMarkup(Object in,
                               Object out,
                               int eqClassIndex)
Description copied from interface: Illustrable
input tuple mark up to be illustrate-able

Parameters:
in - input tuple
out - output tuple before wrapped in ExampleTuple
eqClassIndex - index into equivalence classes in illustrator
Returns:
tuple


Copyright © ${year} The Apache Software Foundation