public class StreamFactory extends Object implements Serializable
| Constructor and Description |
|---|
StreamFactory() |
public StreamFactory withCollectionZkHost(String collectionName, String zkHost)
public StreamFactory withDefaultZkHost(String zkHost)
public String getDefaultZkHost()
public Map<String,Class<? extends Expressible>> getFunctionNames()
public StreamFactory withFunctionName(String functionName, Class<? extends Expressible> clazz)
public StreamExpressionParameter getOperand(StreamExpression expression, int parameterIndex)
public String getValueOperand(StreamExpression expression, int parameterIndex)
public List<StreamExpressionNamedParameter> getNamedOperands(StreamExpression expression)
public StreamExpressionNamedParameter getNamedOperand(StreamExpression expression, String name)
public List<StreamExpression> getExpressionOperands(StreamExpression expression)
public List<StreamExpression> getExpressionOperands(StreamExpression expression, String functionName)
public List<StreamExpressionParameter> getOperandsOfType(StreamExpression expression, Class... clazzes)
public List<StreamExpression> getExpressionOperandsRepresentingTypes(StreamExpression expression, Class... clazzes)
public int getIntOperand(StreamExpression expression, String paramName, Integer defaultValue) throws IOException
IOExceptionpublic boolean getBooleanOperand(StreamExpression expression, String paramName, Boolean defaultValue) throws IOException
IOExceptionpublic TupleStream constructStream(String expressionClause) throws IOException
IOExceptionpublic TupleStream constructStream(StreamExpression expression) throws IOException
IOExceptionpublic Metric constructMetric(String expressionClause) throws IOException
IOExceptionpublic Metric constructMetric(StreamExpression expression) throws IOException
IOExceptionpublic StreamComparator constructComparator(String comparatorString, Class comparatorType) throws IOException
IOExceptionpublic StreamEqualitor constructEqualitor(String equalitorString, Class equalitorType) throws IOException
IOExceptionpublic Metric constructOperation(String expressionClause) throws IOException
IOExceptionpublic StreamOperation constructOperation(StreamExpression expression) throws IOException
IOExceptionpublic <T> T createInstance(Class<T> clazz, Class<?>[] paramTypes, Object[] params) throws IOException
IOExceptionpublic String getFunctionName(Class<? extends Expressible> clazz) throws IOException
IOExceptionCopyright © 2000-2016 Apache Software Foundation. All Rights Reserved.