org.apache.pig.impl.logicalLayer
Class LOGenerate

java.lang.Object
  org.apache.pig.impl.plan.Operator<LOVisitor>
      org.apache.pig.impl.logicalLayer.LogicalOperator
          org.apache.pig.impl.logicalLayer.LOGenerate

All Implemented Interfaces:

Serializable, Cloneable, Comparable<Operator>

public class LOGenerate
extends LogicalOperator

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.pig.impl.logicalLayer.LogicalOperator

mAlias, mCustomPartitioner, mIsProjectionMapComputed, mIsSchemaComputed, mPinnedOptions, mPlan, mProjectionMap, mRequestedParallelism, mSchema, mType

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

mKey

Constructor Summary

LOGenerate(LogicalPlan plan, OperatorKey key, ArrayList<LogicalPlan> generatePlans, ArrayList<Boolean> flatten)

LOGenerate(LogicalPlan plan, OperatorKey key, ArrayList<LogicalPlan> generatePlans, ArrayList<Boolean> flatten, ArrayList<Schema> userDefinedSchemaList)

LOGenerate(LogicalPlan plan, OperatorKey key, LogicalPlan generatePlan, boolean flatten)

Method Summary

protected Object	clone()
List<Boolean>	getFlatten()
List<LogicalPlan>	getGeneratePlans()
Schema	getSchema() Get a copy of the schema for the output of this operator.
List<Schema>	getUserDefinedSchema()
String	name()
boolean	supportsMultipleInputs() Indicates whether this operator supports multiple inputs.
void	visit(LOVisitor v) Visit this node with the provided visitor.

Methods inherited from class org.apache.pig.impl.logicalLayer.LogicalOperator

forceSchema, getAlias, getAliasString, getCustomPartitioner, getOperatorKey, getPlan, getRequestedParallelism, getType, isPinnedOption, pinOption, reconcileSchema, regenerateSchema, setAlias, setCanonicalNames, setCustomPartitioner, setParent, setPlan, setRequestedParallelism, setSchema, setSchemaComputed, setType, supportsMultipleOutputs, toString, unsetSchema

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

LOGenerate

public LOGenerate(LogicalPlan plan,
                  OperatorKey key,
                  ArrayList<LogicalPlan> generatePlans,
                  ArrayList<Boolean> flatten)

Parameters:

plan - Logical plan this operator is a part of.

key - Operator key to assign to this node.

generatePlans - Plans for each projection element

flatten - Whether to flatten each projection element

LOGenerate

public LOGenerate(LogicalPlan plan,
                  OperatorKey key,
                  ArrayList<LogicalPlan> generatePlans,
                  ArrayList<Boolean> flatten,
                  ArrayList<Schema> userDefinedSchemaList)

LOGenerate

public LOGenerate(LogicalPlan plan,
                  OperatorKey key,
                  LogicalPlan generatePlan,
                  boolean flatten)

Parameters:

plan - Logical plan this operator is a part of.

key - Operator key to assign to this node.

generatePlan - the projection of the generate

flatten - whether the result needs to be flattened

Method Detail

getGeneratePlans

public List<LogicalPlan> getGeneratePlans()

getFlatten

public List<Boolean> getFlatten()

getUserDefinedSchema

public List<Schema> getUserDefinedSchema()

name

public String name()

Specified by:

name in class Operator<LOVisitor>

supportsMultipleInputs

public boolean supportsMultipleInputs()

Description copied from class: Operator

Indicates whether this operator supports multiple inputs.

Specified by:

supportsMultipleInputs in class Operator<LOVisitor>

Returns:

true if it does, otherwise false.

getSchema

public Schema getSchema()
                 throws FrontendException

Description copied from class: LogicalOperator

Get a copy of the schema for the output of this operator.

Specified by:

getSchema in class LogicalOperator

Throws:

FrontendException

visit

public void visit(LOVisitor v)
           throws VisitorException

Description copied from class: LogicalOperator

Visit this node with the provided visitor. This should only be called by the visitor class itself, never directly.

Specified by:

visit in class LogicalOperator

Parameters:

v - Visitor to visit with.

Throws:

VisitorException - if the visitor has a problem.

clone

protected Object clone()
                throws CloneNotSupportedException

Overrides:

clone in class LogicalOperator

Throws:

CloneNotSupportedException

See Also:

Do not use the clone method directly. Operators are cloned when logical plans are cloned using {@link LogicalPlanCloner}