public class ConcatOperation extends Object implements StreamOperation
| Constructor and Description |
|---|
ConcatOperation(StreamExpression expression,
StreamFactory factory) |
ConcatOperation(String[] fields,
String as,
String delim) |
| Modifier and Type | Method and Description |
|---|---|
void |
operate(Tuple tuple) |
Explanation |
toExplanation(StreamFactory factory)
Returns an explanation about the stream object
|
StreamExpressionParameter |
toExpression(StreamFactory factory) |
public ConcatOperation(StreamExpression expression, StreamFactory factory) throws IOException
IOExceptionpublic void operate(Tuple tuple)
operate in interface StreamOperationpublic 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 errorCopyright © 2000-2021 Apache Software Foundation. All Rights Reserved.