Uses of Interface
com.espertech.esper.epl.core.StreamTypeService

Packages that use StreamTypeService
com.espertech.esper.core.context.factory Statement agent instance factories. 
com.espertech.esper.core.start Classes related to start and stop of statements 
com.espertech.esper.epl.core Contains EPL statement specification classes define the constructs that make up an EPL statement, such as the list of items in the select clause, the insert-into stream name and property names etc. 
com.espertech.esper.epl.datetime.eval Date-Time methods and related utility classes. 
com.espertech.esper.epl.datetime.interval Interval algebra. 
com.espertech.esper.epl.db Database SQL polling views and caches 
com.espertech.esper.epl.enummethod.dot Enumeration method utility classes and input data sources. 
com.espertech.esper.epl.enummethod.eval Enumeration method implementations. 
com.espertech.esper.epl.expression This package contains the EPL expression nodes that represent all expressions such as used in select clauses, group-by and having clauses, or order-by clauses 
com.espertech.esper.filter Main switchboard filtering and routing of incoming events to interested statements is performed in this package. 
com.espertech.esper.view View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering. 
 

Uses of StreamTypeService in com.espertech.esper.core.context.factory
 

Constructors in com.espertech.esper.core.context.factory with parameters of type StreamTypeService
StatementAgentInstanceFactorySelect(int numStreams, ViewableActivator[] eventStreamParentViewableActivators, StatementContext statementContext, StatementSpecCompiled statementSpec, EPServicesContext services, StreamTypeService typeService, ViewFactoryChain[] unmaterializedViewChain, ResultSetProcessorFactoryDesc resultSetProcessorFactoryDesc, StreamJoinAnalysisResult joinAnalysisResult, boolean recoveringResilient, JoinSetComposerPrototype joinSetComposerPrototype, SubSelectStrategyCollection subSelectStrategyCollection, ViewResourceDelegateVerified viewResourceDelegate, OutputProcessViewFactory outputProcessViewFactory)
           
 

Uses of StreamTypeService in com.espertech.esper.core.start
 

Methods in com.espertech.esper.core.start with parameters of type StreamTypeService
protected static ExprNode EPStatementStartMethodHelperValidate.validateExprNoAgg(ExprNode exprNode, StreamTypeService streamTypeService, StatementContext statementContext, ExprEvaluatorContext exprEvaluatorContext, java.lang.String errorMsg)
           
protected static void EPStatementStartMethodHelperValidate.validateNodes(StatementSpecCompiled statementSpec, StatementContext statementContext, StreamTypeService typeService, ViewResourceDelegateUnverified viewResourceDelegate)
          Validate filter and join expression nodes.
protected static UniformPair<java.lang.Integer> EPStatementStartMethodHelperValidate.validateOuterJoinPropertyPair(StatementContext statementContext, ExprIdentNode leftNode, ExprIdentNode rightNode, int outerJoinCount, StreamTypeService typeService, ViewResourceDelegateUnverified viewResourceDelegate)
           
 

Uses of StreamTypeService in com.espertech.esper.epl.core
 

Classes in com.espertech.esper.epl.core that implement StreamTypeService
 class StreamTypeServiceImpl
          Implementation that provides stream number and property type information.
 

Methods in com.espertech.esper.epl.core with parameters of type StreamTypeService
static SelectExprProcessor SelectExprInsertEventBeanFactory.getInsertUnderlyingNonJoin(EventAdapterService eventAdapterService, EventType eventType, boolean isUsingWildcard, StreamTypeService typeService, ExprEvaluator[] expressionNodes, java.lang.String[] columnNames, java.lang.Object[] expressionReturnTypes, EngineImportService engineImportService, InsertIntoDesc insertIntoDesc, java.lang.String[] columnNamesAsProvided)
           
static SelectExprProcessor SelectExprProcessorFactory.getProcessor(java.util.Collection<java.lang.Integer> assignedTypeNumberStack, SelectClauseElementCompiled[] selectionList, boolean isUsingWildcard, InsertIntoDesc insertIntoDesc, ForClauseSpec forClauseSpec, StreamTypeService typeService, EventAdapterService eventAdapterService, StatementResultService statementResultService, ValueAddEventService valueAddEventService, SelectExprEventTypeRegistry selectExprEventTypeRegistry, MethodResolutionService methodResolutionService, ExprEvaluatorContext exprEvaluatorContext, VariableService variableService, TimeProvider timeProvider, java.lang.String engineURI, java.lang.String statementId, java.lang.String statementName, java.lang.annotation.Annotation[] annotations, ContextDescriptor contextDescriptor, ConfigurationInformation configuration, SelectExprProcessorDeliveryCallback selectExprProcessorCallback)
          Returns the processor to use for a given select-clause.
static ResultSetProcessorFactoryDesc ResultSetProcessorFactoryFactory.getProcessorPrototype(StatementSpecCompiled statementSpec, StatementContext stmtContext, StreamTypeService typeService, ViewResourceDelegateUnverified viewResourceDelegate, boolean[] isUnidirectionalStream, boolean allowAggregation, ContextPropertyRegistry contextPropertyRegistry, SelectExprProcessorDeliveryCallback selectExprProcessorCallback)
          Returns the result set process for the given select expression, group-by clause and having clause given a set of types describing each stream in the from-clause.
 void MethodPollingViewable.validate(EngineImportService engineImportService, StreamTypeService streamTypeService, MethodResolutionService methodResolutionService, TimeProvider timeProvider, VariableService variableService, ExprEvaluatorContext exprEvaluatorContext, ConfigurationInformation configSnapshot, SchedulingService schedulingService, java.lang.String engineURI, java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters, EventAdapterService eventAdapterService, java.lang.String statementName, java.lang.String statementId, java.lang.annotation.Annotation[] annotations)
           
 

Constructors in com.espertech.esper.epl.core with parameters of type StreamTypeService
SelectExprProcessorHelper(java.util.Collection<java.lang.Integer> assignedTypeNumberStack, java.util.List<SelectClauseExprCompiledSpec> selectionList, java.util.List<SelectExprStreamDesc> selectedStreams, InsertIntoDesc insertIntoDesc, boolean isUsingWildcard, StreamTypeService typeService, EventAdapterService eventAdapterService, ValueAddEventService valueAddEventService, SelectExprEventTypeRegistry selectExprEventTypeRegistry, MethodResolutionService methodResolutionService, java.lang.String statementId, java.lang.annotation.Annotation[] annotations, ConfigurationInformation configuration)
          Ctor.
 

Uses of StreamTypeService in com.espertech.esper.epl.datetime.eval
 

Methods in com.espertech.esper.epl.datetime.eval with parameters of type StreamTypeService
static ExprDotEvalDTMethodDesc ExprDotEvalDTFactory.validateMake(StreamTypeService streamTypeService, java.util.Deque<ExprChainedSpec> chainSpecStack, DatetimeMethodEnum dtMethod, java.lang.String dtMethodName, ExpressionReturnType inputType, java.util.List<ExprNode> parameters, ExprDotNodeFilterAnalyzerInput inputDesc)
           
 

Uses of StreamTypeService in com.espertech.esper.epl.datetime.interval
 

Methods in com.espertech.esper.epl.datetime.interval with parameters of type StreamTypeService
 IntervalOp IntervalOpFactory.getOp(StreamTypeService streamTypeService, DatetimeMethodEnum method, java.lang.String methodNameUsed, java.util.List<ExprNode> parameters, ExprEvaluator[] evaluators)
           
 

Constructors in com.espertech.esper.epl.datetime.interval with parameters of type StreamTypeService
IntervalOpImpl(DatetimeMethodEnum method, java.lang.String methodNameUse, StreamTypeService streamTypeService, java.util.List<ExprNode> expressions)
           
 

Uses of StreamTypeService in com.espertech.esper.epl.db
 

Methods in com.espertech.esper.epl.db with parameters of type StreamTypeService
 void DatabasePollingViewable.validate(EngineImportService engineImportService, StreamTypeService streamTypeService, MethodResolutionService methodResolutionService, TimeProvider timeProvider, VariableService variableService, ExprEvaluatorContext exprEvaluatorContext, ConfigurationInformation configSnapshot, SchedulingService schedulingService, java.lang.String engineURI, java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters, EventAdapterService eventAdapterService, java.lang.String statementName, java.lang.String statementId, java.lang.annotation.Annotation[] annotations)
           
 

Uses of StreamTypeService in com.espertech.esper.epl.enummethod.dot
 

Methods in com.espertech.esper.epl.enummethod.dot with parameters of type StreamTypeService
abstract  EnumEval ExprDotEvalEnumMethodBase.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 

Uses of StreamTypeService in com.espertech.esper.epl.enummethod.eval
 

Methods in com.espertech.esper.epl.enummethod.eval with parameters of type StreamTypeService
 EnumEval ExprDotEvalWhere.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalToMap.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalTakeWhileAndLast.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalTakeAndTakeLast.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalSumOf.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalSetExceptUnionIntersect.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalSequenceEqual.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalSelectFrom.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalReverse.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalOrderByAscDesc.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalNoOp.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalMostLeastFrequent.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalMinMax.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalMinByMaxBy.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalGroupBy.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalFirstLastOf.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalCountOf.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalAverage.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalAllOfAnyOf.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 EnumEval ExprDotEvalAggregate.getEnumEval(MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, java.lang.String statementId, java.lang.String enumMethodUsedName, java.util.List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, java.lang.Class collectionComponentType, int numStreamsIncoming)
           
 

Uses of StreamTypeService in com.espertech.esper.epl.expression
 

Methods in com.espertech.esper.epl.expression that return StreamTypeService
 StreamTypeService ExprSubselectNode.getFilterSubqueryStreamTypes()
          Return stream types.
 StreamTypeService ExprValidationContext.getStreamTypeService()
           
 

Methods in com.espertech.esper.epl.expression with parameters of type StreamTypeService
static Pair<ExprEvaluatorEnumeration,ExpressionReturnType> ExprDotNode.getEnumerationSource(ExprNode inputExpression, StreamTypeService streamTypeService, EventAdapterService eventAdapterService, java.lang.String statementId, boolean hasEnumerationMethod)
           
protected static boolean ExprAggMultiFunctionLinearAccessNode.getIstreamOnly(StreamTypeService streamTypeService, int streamNum)
           
static Pair<PropertyResolutionDescriptor,java.lang.String> ExprIdentNodeUtil.getTypeFromStream(StreamTypeService streamTypeService, java.lang.String propertyNameNestable, boolean explicitPropertiesOnly, boolean obtainFragment)
           
protected static Pair<PropertyResolutionDescriptor,java.lang.String> ExprIdentNodeUtil.getTypeFromStream(StreamTypeService streamTypeService, java.lang.String unresolvedPropertyName, java.lang.String streamOrPropertyName, boolean obtainFragment)
          Determine stream id and property type given an unresolved property name and a stream name that may also be part of the property name.
protected static Pair<PropertyResolutionDescriptor,java.lang.String> ExprIdentNodeUtil.getTypeFromStreamExplicitProperties(StreamTypeService streamTypeService, java.lang.String unresolvedPropertyName, java.lang.String streamOrPropertyName, boolean obtainFragment)
          This method only resolves against explicitly-listed properties (for use with XML or other types that allow any name as a property name).
static boolean ExprNodeUtility.hasRemoveStream(ExprNode child, StreamTypeService streamTypeService)
          Returns true if all properties within the expression are witin data window'd streams.
 void ExprSubselectNode.setFilterSubqueryStreamTypes(StreamTypeService filterSubqueryStreamTypes)
          Set stream types.
protected  java.lang.Class ExprAggregateNodeBase.validateNumericChildAllowFilter(StreamTypeService streamTypeService, boolean hasFilter)
          For use by implementing classes, validates the aggregation node expecting a single numeric-type child node.
 

Constructors in com.espertech.esper.epl.expression with parameters of type StreamTypeService
ExprValidationContext(StreamTypeService streamTypeService, MethodResolutionService methodResolutionService, ViewResourceDelegateUnverified viewResourceDelegate, TimeProvider timeProvider, VariableService variableService, ExprEvaluatorContext exprEvaluatorContext, EventAdapterService eventAdapterService, java.lang.String statementName, java.lang.String statementId, java.lang.annotation.Annotation[] annotations, ContextDescriptor contextDescriptor)
           
 

Uses of StreamTypeService in com.espertech.esper.filter
 

Methods in com.espertech.esper.filter with parameters of type StreamTypeService
static FilterSpecCompiled FilterSpecCompiler.build(java.util.List<ExprNode> validatedNodes, EventType eventType, java.lang.String eventTypeName, PropertyEvalSpec optionalPropertyEvalSpec, java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes, java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes, StreamTypeService streamTypeService, java.lang.String optionalStreamName, StatementContext stmtContext, java.util.Collection<java.lang.Integer> assignedTypeNumberStack)
           
static FilterSpecCompiled FilterSpecCompiler.buildNoStmtCtx(java.util.List<ExprNode> validatedNodes, EventType eventType, java.lang.String eventTypeName, PropertyEvalSpec optionalPropertyEvalSpec, java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes, java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes, StreamTypeService streamTypeService, java.lang.String optionalStreamName, java.util.Collection<java.lang.Integer> assignedTypeNumberStack, ExprEvaluatorContext exprEvaluatorContext, java.lang.String statementId, java.lang.String statementName, java.lang.annotation.Annotation[] annotations, ContextDescriptor contextDescriptor, MethodResolutionService methodResolutionService, EventAdapterService eventAdapterService, TimeProvider timeProvider, VariableService variableService, ConfigurationInformation configurationInformation)
           
static FilterSpecCompiled FilterSpecCompiler.makeFilterSpec(EventType eventType, java.lang.String eventTypeName, java.util.List<ExprNode> filterExpessions, PropertyEvalSpec optionalPropertyEvalSpec, java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes, java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes, StreamTypeService streamTypeService, java.lang.String optionalStreamName, StatementContext statementContext, java.util.Collection<java.lang.Integer> assignedTypeNumberStack)
          Factory method for compiling filter expressions into a filter specification for use with filter service.
static java.util.List<ExprNode> FilterSpecCompiler.validateAllowSubquery(java.util.List<ExprNode> exprNodes, StreamTypeService streamTypeService, StatementContext statementContext, java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes, java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes)
          Validates expression nodes and returns a list of validated nodes.
 

Uses of StreamTypeService in com.espertech.esper.view
 

Methods in com.espertech.esper.view with parameters of type StreamTypeService
 void ValidatedView.validate(EngineImportService engineImportService, StreamTypeService streamTypeService, MethodResolutionService methodResolutionService, TimeProvider timeProvider, VariableService variableService, ExprEvaluatorContext exprEvaluatorContext, ConfigurationInformation configSnapshot, SchedulingService schedulingService, java.lang.String engineURI, java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters, EventAdapterService eventAdapterService, java.lang.String statementName, java.lang.String statementId, java.lang.annotation.Annotation[] annotations)
          Validate the view.
static ExprNode ViewFactorySupport.validateExpr(StatementContext statementContext, ExprNode expression, StreamTypeService streamTypeService, int expressionNumber)
           
 


© 2006-2011 EsperTech Inc.
All rights reserved.
Visit us at espertech.com