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) |
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 ExpressibleIOExceptionCopyright © 2000-2016 Apache Software Foundation. All Rights Reserved.