org.apache.pig.pen.physicalOperators
Class POStreamLocal

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
              extended by org.apache.pig.pen.physicalOperators.POStreamLocal
All Implemented Interfaces:
Serializable, Cloneable, Comparable<Operator>

public class POStreamLocal
extends POStream

See Also:
Serialized Form

Field Summary
 
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream
allInputFromPredecessorConsumed, allOutputFromBinaryProcessed, binaryInputQueue, binaryOutputQueue, initialized
 
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
alias, dummyBag, dummyBool, dummyDBA, dummyDouble, dummyFloat, dummyInt, dummyLong, dummyMap, dummyString, dummyTuple, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, resultType
 
Fields inherited from class org.apache.pig.impl.plan.Operator
mKey
 
Constructor Summary
POStreamLocal(OperatorKey k, ExecutableManager executableManager, StreamingCommand command, Properties properties)
           
 
Method Summary
 Result getNext(Tuple t)
          This is different from the Map-Reduce implementation of the POStream since there is no push model here.
 
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream
finish, getBinaryInputQueue, getBinaryOutputQueue, getCommand, getNextHelper, getShipCacheProperties, name, supportsMultipleInputs, supportsMultipleOutputs, toString, visit
 
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
attachInput, clone, cloneHelper, detachInput, getAlias, getAliasString, getInputs, getLogger, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getPigLogger, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setAlias, setInputs, setLineageTracer, 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
 

Constructor Detail

POStreamLocal

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

getNext

public Result getNext(Tuple t)
               throws ExecException
This is different from the Map-Reduce implementation of the POStream since there is no push model here. POStatus_EOP signals the end of input and can be used to decide when to stop the stdin to the process

Overrides:
getNext in class POStream
Throws:
ExecException


Copyright © ${year} The Apache Software Foundation