/*
* *************************************************************************************
* Copyright (C) 2008 EsperTech, Inc. All rights reserved. *
* http://esper.codehaus.org *
* http://www.espertech.com *
* ---------------------------------------------------------------------------------- *
* The software in this package is published under the terms of the GPL license *
* a copy of which has been included with this distribution in the license.txt file. *
* *************************************************************************************
*/
package com.espertech.esper.epl.join.hint;
import com.espertech.esper.client.EventBean;
import com.espertech.esper.core.context.mgr.ContextManagementServiceImpl;
import com.espertech.esper.core.service.EPAdministratorHelper;
import com.espertech.esper.core.service.StatementContext;
import com.espertech.esper.epl.declexpr.ExprDeclaredServiceImpl;
import com.espertech.esper.epl.expression.*;
import com.espertech.esper.epl.spec.SelectClauseStreamSelectorEnum;
import com.espertech.esper.epl.spec.StatementSpecRaw;
import com.espertech.esper.event.EventTypeMetadata;
import com.espertech.esper.event.arr.ObjectArrayEventBean;
import com.espertech.esper.event.arr.ObjectArrayEventType;
import com.espertech.esper.pattern.PatternNodeFactoryImpl;
import java.util.LinkedHashMap;
public class ExcludePlanHintExprUtil {
protected final static ObjectArrayEventType OAEXPRESSIONTYPE;
static {
LinkedHashMap<String, Object> properties = new LinkedHashMap<String, Object>();
properties.put("from_streamnum", int.class);
properties.put("to_streamnum", int.class);
properties.put("from_streamname", String.class);
properties.put("to_streamname", String.class);
properties.put("opname", String.class);
properties.put("exprs", String[].class);
OAEXPRESSIONTYPE = new ObjectArrayEventType(EventTypeMetadata.createAnonymous(ExcludePlanHintExprUtil.class.getSimpleName()),
ExcludePlanHintExprUtil.class.getSimpleName(), 0, null, properties, null, null, null);
}
public static EventBean toEvent(int from_streamnum,
int to_streamnum,
String from_streamname,
String to_streamname,
String opname,
ExprNode[] expressions) {
String[] texts = new String[expressions.length];
for (int i = 0; i < expressions.length; i++) {
texts[i] = ExprNodeUtility.toExpressionStringMinPrecedence(expressions[i]);
}
Object[] event = new Object[] {from_streamnum, to_streamnum, from_streamname, to_streamname, opname, texts};
return new ObjectArrayEventBean(event, OAEXPRESSIONTYPE);
}
public static ExprEvaluator toExpression(String hint, StatementContext statementContext) throws ExprValidationException {
String toCompile = "select * from java.lang.Object.win:time(" + hint + ")";
StatementSpecRaw raw = EPAdministratorHelper.compileEPL(toCompile, hint, false, null,
SelectClauseStreamSelectorEnum.ISTREAM_ONLY, statementContext.getMethodResolutionService().getEngineImportService(),
statementContext.getVariableService(), statementContext.getSchedulingService(),
statementContext.getEngineURI(), statementContext.getConfigSnapshot(),
new PatternNodeFactoryImpl(), new ContextManagementServiceImpl(),
new ExprDeclaredServiceImpl());
ExprNode expr = raw.getStreamSpecs().get(0).getViewSpecs()[0].getObjectParameters().get(0);
ExprNode validated = ExprNodeUtility.validateSimpleGetSubtree(ExprNodeOrigin.HINT, expr, statementContext, OAEXPRESSIONTYPE);
return validated.getExprEvaluator();
}
}