public class DistinctOperation extends Object implements ReduceOperation
| Constructor and Description |
|---|
DistinctOperation() |
DistinctOperation(StreamExpression expression,
StreamFactory factory) |
| Modifier and Type | Method and Description |
|---|---|
void |
operate(Tuple tuple) |
Tuple |
reduce() |
StreamExpressionParameter |
toExpression(StreamFactory factory) |
public DistinctOperation(StreamExpression expression, StreamFactory factory) throws IOException
IOExceptionpublic DistinctOperation()
public StreamExpressionParameter toExpression(StreamFactory factory) throws IOException
toExpression in interface ExpressibleIOExceptionpublic Tuple reduce()
reduce in interface ReduceOperationpublic void operate(Tuple tuple)
operate in interface StreamOperationCopyright © 2000-2016 Apache Software Foundation. All Rights Reserved.