public class UnGroup extends BaseOperation implements Function
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, zto:
A, x A, y B, x B, z C, y C, z
fieldDeclaration, numArgs, trace
Constructor and Description |
---|
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.
|
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object object) |
Fields |
getGroupFieldSelector() |
Fields[] |
getResultFieldSelectors() |
int |
getSize() |
int |
hashCode() |
void |
operate(FlowProcess flowProcess,
FunctionCall functionCall)
Method operate provides the implementation of this Function.
|
cleanup, flush, getFieldDeclaration, getNumArgs, getTrace, isSafe, prepare, printOperationInternal, toString, toStringInternal
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
cleanup, flush, getFieldDeclaration, getNumArgs, isSafe, prepare
@ConstructorProperties(value={"groupSelector","valueSelectors"}) public UnGroup(Fields groupSelector, Fields[] valueSelectors)
groupSelector
- of type FieldsvalueSelectors
- of type Fields[]@ConstructorProperties(value={"fieldDeclaration","groupSelector","valueSelectors"}) public UnGroup(Fields fieldDeclaration, Fields groupSelector, Fields[] valueSelectors)
fieldDeclaration
- of type FieldsgroupSelector
- of type FieldsvalueSelectors
- of type Fields[]@ConstructorProperties(value={"fieldDeclaration","groupSelector","numValues"}) public UnGroup(Fields fieldDeclaration, Fields groupSelector, int numValues)
fieldDeclaration
- of type FieldsgroupSelector
- of type FieldsnumValues
- of type intpublic Fields getGroupFieldSelector()
public Fields[] getResultFieldSelectors()
public int getSize()
public void operate(FlowProcess flowProcess, FunctionCall functionCall)
Function
public boolean equals(Object object)
equals
in class BaseOperation
public int hashCode()
hashCode
in class BaseOperation
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.