public class POStream extends PhysicalOperator
PhysicalOperator.OriginalLocation
Modifier and Type | Field and Description |
---|---|
protected boolean |
allInputFromPredecessorConsumed |
protected boolean |
allOutputFromBinaryProcessed |
protected java.util.concurrent.BlockingQueue<Result> |
binaryInputQueue |
protected java.util.concurrent.BlockingQueue<Result> |
binaryOutputQueue |
alias, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POStream(OperatorKey k,
ExecutableManager executableManager,
StreamingCommand command,
java.util.Properties properties) |
Modifier and Type | Method and Description |
---|---|
void |
finish() |
java.util.concurrent.BlockingQueue<Result> |
getBinaryInputQueue() |
java.util.concurrent.BlockingQueue<Result> |
getBinaryOutputQueue() |
StreamingCommand |
getCommand()
Get the
StreamingCommand for this StreamSpec . |
boolean |
getInitialized() |
Result |
getNextHelper(Tuple t) |
Result |
getNextTuple() |
java.util.Properties |
getShipCacheProperties() |
Tuple |
illustratorMarkup(java.lang.Object in,
java.lang.Object out,
int eqClassIndex)
input tuple mark up to be illustrate-able
|
boolean |
isFetchable() |
java.lang.String |
name() |
void |
setFetchable(boolean isFetchable) |
void |
setInitialized(boolean initialized) |
boolean |
supportsMultipleInputs()
Indicates whether this operator supports multiple inputs.
|
boolean |
supportsMultipleOutputs()
Indicates whether this operator supports multiple outputs.
|
java.lang.String |
toString() |
void |
visit(PhyPlanVisitor v)
Visit this node with the provided visitor.
|
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
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, unsetProjectionMap
protected java.util.concurrent.BlockingQueue<Result> binaryOutputQueue
protected java.util.concurrent.BlockingQueue<Result> binaryInputQueue
protected boolean allInputFromPredecessorConsumed
protected boolean allOutputFromBinaryProcessed
public POStream(OperatorKey k, ExecutableManager executableManager, StreamingCommand command, java.util.Properties properties)
public java.util.Properties getShipCacheProperties()
public StreamingCommand getCommand()
StreamingCommand
for this StreamSpec
.StreamingCommand
for this StreamSpec
public Result getNextTuple() throws ExecException
getNextTuple
in class PhysicalOperator
ExecException
public boolean getInitialized()
public void setInitialized(boolean initialized)
public Result getNextHelper(Tuple t) throws ExecException
ExecException
public java.lang.String toString()
toString
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 java.lang.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 finish() throws java.io.IOException
java.io.IOException
public java.util.concurrent.BlockingQueue<Result> getBinaryInputQueue()
public java.util.concurrent.BlockingQueue<Result> getBinaryOutputQueue()
public Tuple illustratorMarkup(java.lang.Object in, java.lang.Object out, int eqClassIndex)
Illustrable
in
- input tupleout
- output tuple before wrapped in ExampleTupleeqClassIndex
- index into equivalence classes in illustratorpublic boolean isFetchable()
public void setFetchable(boolean isFetchable)
isFetchable
- - whether fetching is applied on POStreamCopyright © 2007-2012 The Apache Software Foundation