org.apache.pig.impl.plan

Class ProjectionMap

java.lang.Object

org.apache.pig.impl.plan.ProjectionMap

public class ProjectionMap
extends java.lang.Object

A struct detailing how a projection is altered by an operator.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ProjectionMap.Column A wrapper for projection map columns to contain the input number, input column.

Constructor Summary

Constructors

Constructor and Description
ProjectionMap(boolean changes)
ProjectionMap(MultiMap<java.lang.Integer,ProjectionMap.Column> mapFields, java.util.List<Pair<java.lang.Integer,java.lang.Integer>> removedFields, java.util.List<java.lang.Integer> addedFields)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	changes()
java.util.List<java.lang.Integer>	getAddedFields()
boolean	getChanges()
MultiMap<java.lang.Integer,ProjectionMap.Column>	getMappedFields()
java.util.List<Pair<java.lang.Integer,java.lang.Integer>>	getRemovedFields()
void	setAddedFields(java.util.List<java.lang.Integer> fields)
void	setChanges(boolean changes)
void	setMappedFields(MultiMap<java.lang.Integer,ProjectionMap.Column> fields)
void	setRemovedFields(java.util.List<Pair<java.lang.Integer,java.lang.Integer>> fields)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ProjectionMap

public ProjectionMap(boolean changes)

Parameters:

changes - to indicate if this projection map changes its input or not

ProjectionMap

public ProjectionMap(MultiMap<java.lang.Integer,ProjectionMap.Column> mapFields,
             java.util.List<Pair<java.lang.Integer,java.lang.Integer>> removedFields,
             java.util.List<java.lang.Integer> addedFields)

Parameters:

mapFields - the mapping of input column to output column

removedFields - the list of input columns that are removed

addedFields - the list of columns that are added to the output

Method Detail

getMappedFields

public MultiMap<java.lang.Integer,ProjectionMap.Column> getMappedFields()

Returns:

the mapping of input column to output column

setMappedFields

public void setMappedFields(MultiMap<java.lang.Integer,ProjectionMap.Column> fields)

Parameters:

fields - the mapping of input column to output column

getRemovedFields

public java.util.List<Pair<java.lang.Integer,java.lang.Integer>> getRemovedFields()

Returns:

the list of input columns that are removed

setRemovedFields

public void setRemovedFields(java.util.List<Pair<java.lang.Integer,java.lang.Integer>> fields)

Parameters:

fields - the list of input columns that are removed

getAddedFields

public java.util.List<java.lang.Integer> getAddedFields()

Returns:

the list of columns that are added to the output

setAddedFields

public void setAddedFields(java.util.List<java.lang.Integer> fields)

Parameters:

fields - the list of columns that are added to the output

changes

public boolean changes()

Returns:

if this projection map changes its input or not

getChanges

public boolean getChanges()

Returns:

if this projection map changes its input or not

setChanges

public void setChanges(boolean changes)

Parameters:

changes - if this projection map changes its input or not

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object