org.apache.pig.newplan.logical.rules

Class StreamTypeCastInserter

java.lang.Object

org.apache.pig.newplan.optimizer.Rule

org.apache.pig.newplan.logical.rules.TypeCastInserter

org.apache.pig.newplan.logical.rules.StreamTypeCastInserter

public class StreamTypeCastInserter
extends TypeCastInserter

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.newplan.logical.rules.TypeCastInserter

TypeCastInserter.TypeCastInserterTransformer

Field Summary

Fields inherited from class org.apache.pig.newplan.optimizer.Rule

currentPlan, log, name, pattern

Constructor Summary

Constructors

Constructor and Description
StreamTypeCastInserter(String n)

Method Summary

Methods

Modifier and Type	Method and Description
protected OperatorPlan	buildPattern() Build the pattern that this rule will look for
protected LogicalSchema	determineSchema(LogicalRelationalOperator op)
protected boolean	isCastAdjusted(LogicalRelationalOperator op)
protected void	markCastInserted(LogicalRelationalOperator op)
protected void	markCastNoNeed(LogicalRelationalOperator op)

Methods inherited from class org.apache.pig.newplan.logical.rules.TypeCastInserter

getNewTransformer

Methods inherited from class org.apache.pig.newplan.optimizer.Rule

getName, getPattern, isMandatory, isSkipListener, match, setSkipListener

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamTypeCastInserter

public StreamTypeCastInserter(String n)

Method Detail

buildPattern

protected OperatorPlan buildPattern()

Description copied from class: Rule

Build the pattern that this rule will look for

Specified by:

buildPattern in class Rule

Returns:

the pattern to look for by this rule

determineSchema

protected LogicalSchema determineSchema(LogicalRelationalOperator op)
                                 throws FrontendException

Specified by:

determineSchema in class TypeCastInserter

Throws:

FrontendException

markCastInserted

protected void markCastInserted(LogicalRelationalOperator op)

Specified by:

markCastInserted in class TypeCastInserter

markCastNoNeed

protected void markCastNoNeed(LogicalRelationalOperator op)

Specified by:

markCastNoNeed in class TypeCastInserter

isCastAdjusted

protected boolean isCastAdjusted(LogicalRelationalOperator op)

Specified by:

isCastAdjusted in class TypeCastInserter