public class GroupOperation extends Object implements ReduceOperation
Constructor and Description |
---|
GroupOperation(StreamComparator streamComparator,
int size) |
GroupOperation(StreamExpression expression,
StreamFactory factory) |
Modifier and Type | Method and Description |
---|---|
void |
operate(Tuple tuple) |
Tuple |
reduce() |
StreamExpressionParameter |
toExpression(StreamFactory factory) |
public GroupOperation(StreamExpression expression, StreamFactory factory) throws IOException
IOException
public GroupOperation(StreamComparator streamComparator, int size)
public StreamExpressionParameter toExpression(StreamFactory factory) throws IOException
toExpression
in interface Expressible
IOException
public Tuple reduce()
reduce
in interface ReduceOperation
public void operate(Tuple tuple)
operate
in interface StreamOperation
Copyright © 2000-2016 Apache Software Foundation. All Rights Reserved.