com.espertech.esper.common.internal.epl.table.compiletime

Class TableCompileTimeUtil

java.lang.Object

com.espertech.esper.common.internal.epl.table.compiletime.TableCompileTimeUtil

public class TableCompileTimeUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
TableCompileTimeUtil()

Method Summary

Modifier and Type	Method and Description
static ExprTableIdentNode	getTableIdentNode(StreamTypeService streamTypeService, String unresolvedPropertyName, String streamOrPropertyName, TableCompileTimeResolver resolver)
static Pair<ExprNode,List<Chainable>>	getTableNodeChainable(StreamTypeService streamTypeService, List<Chainable> chainSpec, boolean allowTableAggReset, TableCompileTimeResolver tableCompileTimeResolver)
static Pair<ExprTableAccessNode,List<Chainable>>	handleTableAccessNode(LazyAllocatedMap<ConfigurationCompilerPlugInAggregationMultiFunction,AggregationMultiFunctionForge> plugInAggregations, String tableName, String sub, List<Chainable> chain)
static Pair<ExprTableAccessNode,ExprDotNode>	mapPropertyToTableNested(TableCompileTimeResolver resolver, String stream, String subproperty)
static ExprTableAccessNode	mapPropertyToTableUnnested(String propertyName, TableCompileTimeResolver resolver) Handle property "table" or "table[key]" where key is an integer and therefore can be a regular property
static StreamTypeServiceImpl	streamTypeFromTableColumn(EventType containedEventType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TableCompileTimeUtil

public TableCompileTimeUtil()

Method Detail

streamTypeFromTableColumn

public static StreamTypeServiceImpl streamTypeFromTableColumn(EventType containedEventType)

getTableNodeChainable

public static Pair<ExprNode,List<Chainable>> getTableNodeChainable(StreamTypeService streamTypeService,
                                                                   List<Chainable> chainSpec,
                                                                   boolean allowTableAggReset,
                                                                   TableCompileTimeResolver tableCompileTimeResolver)
                                                            throws ExprValidationException

Throws:

ExprValidationException

getTableIdentNode

public static ExprTableIdentNode getTableIdentNode(StreamTypeService streamTypeService,
                                                   String unresolvedPropertyName,
                                                   String streamOrPropertyName,
                                                   TableCompileTimeResolver resolver)
                                            throws ExprValidationException

Throws:

ExprValidationException

mapPropertyToTableNested

public static Pair<ExprTableAccessNode,ExprDotNode> mapPropertyToTableNested(TableCompileTimeResolver resolver,
                                                                             String stream,
                                                                             String subproperty)

handleTableAccessNode

public static Pair<ExprTableAccessNode,List<Chainable>> handleTableAccessNode(LazyAllocatedMap<ConfigurationCompilerPlugInAggregationMultiFunction,AggregationMultiFunctionForge> plugInAggregations,
                                                                              String tableName,
                                                                              String sub,
                                                                              List<Chainable> chain)

mapPropertyToTableUnnested

public static ExprTableAccessNode mapPropertyToTableUnnested(String propertyName,
                                                             TableCompileTimeResolver resolver)

Handle property "table" or "table[key]" where key is an integer and therefore can be a regular property

Parameters:

propertyName - property

resolver - resolver

Returns:

expression null or node