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
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. |
UnGroup
@ConstructorProperties(value={"groupSelector","valueSelectors"})
public UnGroup(Fields groupSelector,
Fields[] valueSelectors)
- Constructor UnGroup creates a new UnGroup instance.
- Parameters:
groupSelector
- of type FieldsvalueSelectors
- of type Fields[]
UnGroup
@ConstructorProperties(value={"fieldDeclaration","groupSelector","valueSelectors"})
public UnGroup(Fields fieldDeclaration,
Fields groupSelector,
Fields[] valueSelectors)
- Constructor UnGroup creates a new UnGroup instance.
- Parameters:
fieldDeclaration
- of type FieldsgroupSelector
- of type FieldsvalueSelectors
- of type Fields[]
UnGroup
@ConstructorProperties(value={"fieldDeclaration","groupSelector","numValues"})
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 FieldsgroupSelector
- of type FieldsnumValues
- of type int
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 FlowProcessfunctionCall
- of type FunctionCall
equals
public boolean equals(Object object)
- Overrides:
equals
in class BaseOperation
hashCode
public int hashCode()
- Overrides:
hashCode
in class BaseOperation
Copyright © 2007-2010 Concurrent, Inc. All Rights Reserved.