cascading.operation.function
Class UnGroup

java.lang.Object
  cascading.operation.BaseOperation
      cascading.operation.function.UnGroup

All Implemented Interfaces:

Function, Operation, Serializable

public class UnGroup
extends BaseOperation
implements Function

Class UnGroup is a Function that will 'un-group' data from a given dataset.

That is, for the given field positions, this function will emit a new Tuple for every value. For example:

 A, x, y
 B, x, z
 C, y, z
 

to:

 A, x
 A, y
 B, x
 B, z
 C, y
 C, z
 

See Also:

Serialized Form

Field Summary

Fields inherited from class cascading.operation.BaseOperation

fieldDeclaration, numArgs, trace

Fields inherited from interface cascading.operation.Operation

ANY

Constructor Summary

UnGroup(Fields groupSelector, Fields[] valueSelectors)
Constructor UnGroup creates a new UnGroup instance.

UnGroup(Fields fieldDeclaration, Fields groupSelector, Fields[] valueSelectors)
Constructor UnGroup creates a new UnGroup instance.

UnGroup(Fields fieldDeclaration, Fields groupSelector, int numValues)
Constructor UnGroup creates a new UnGroup instance.

Method Summary

void	operate(FlowProcess flowProcess, FunctionCall functionCall) Method operate provides the implementation of this Function.

Methods inherited from class cascading.operation.BaseOperation

cleanup, getFieldDeclaration, getNumArgs, getTrace, prepare, printOperationInternal, toString, toStringInternal

Methods inherited from class java.lang.Object

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

Methods inherited from interface cascading.operation.Operation

cleanup, getFieldDeclaration, getNumArgs, prepare

Constructor Detail

UnGroup

public UnGroup(Fields groupSelector,
               Fields[] valueSelectors)

Constructor UnGroup creates a new UnGroup instance.

Parameters:

groupSelector - of type Fields

valueSelectors - of type Fields[]

UnGroup

public UnGroup(Fields fieldDeclaration,
               Fields groupSelector,
               Fields[] valueSelectors)

Constructor UnGroup creates a new UnGroup instance.

Parameters:

fieldDeclaration - of type Fields

groupSelector - of type Fields

valueSelectors - of type Fields[]

UnGroup

public UnGroup(Fields fieldDeclaration,
               Fields groupSelector,
               int numValues)

Constructor UnGroup creates a new UnGroup instance. Where the numValues argument specifies the number of values to include.

Parameters:

fieldDeclaration - of type Fields

groupSelector - of type Fields

numValues - of type int

Method Detail

operate

public void operate(FlowProcess flowProcess,
                    FunctionCall functionCall)

Description copied from interface: Function

Method operate provides the implementation of this Function.

Specified by:

operate in interface Function

Parameters:

flowProcess - of type FlowProcess

functionCall - of type FunctionCall