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() |
Explanation |
toExplanation(StreamFactory factory)
Returns an explanation about the stream object
|
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 Explanation toExplanation(StreamFactory factory) throws IOException
ExpressibletoExplanation in interface Expressiblefactory - Stream factory for this, contains information about the function nameIOException - throw on any errorpublic Tuple reduce()
reduce in interface ReduceOperationpublic void operate(Tuple tuple)
operate in interface StreamOperationCopyright © 2000-2017 Apache Software Foundation. All Rights Reserved.