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-2018 Apache Software Foundation. All Rights Reserved.