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