String onDemandQueryString
ComplexEvent first
ComplexEvent previousToLastReturned
ComplexEvent lastReturned
ComplexEvent last
long timestamp
Object[] data
boolean isExpired
ComplexEvent complexEvent
String groupKey
ComplexEvent next
MetaStreamEvent[] metaStreamEvents
int streamEventCount
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition
List<E> outputDataAttributes
io.siddhi.query.api.definition.Attribute attribute
int[] position
StreamEvent[] streamEvents
StateEvent next
long timestamp
ComplexEvent.Type type
Object[] outputData
long id
int eventSize
int outputDataSize
List<E> beforeWindowData
List<E> onAfterWindowData
List<E> outputData
List<E> inputDefinitions
String inputReferenceId
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition
MetaStreamEvent.EventType eventType
boolean multiValue
Operation.Operator operation
Object parameters
private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream stream) throws IOException
IOException
long timestamp
Object[] outputData
ComplexEvent.Type type
Object[] beforeWindowData
Object[] onAfterWindowData
StreamEvent next
int beforeWindowDataSize
int onAfterWindowDataSize
int outputDataSize
StreamEventFactory eventFactory
int beforeWindowDataSize
int onAfterWindowDataSize
int outputDataSize
StreamEventConverter streamEventConverter
StreamEventFactory streamEventFactory
int fromPosition
int[] toPosition
StreamEvent first
StreamEvent previousToLastReturned
StreamEvent lastReturned
StreamEvent last
int size
int operationChangeLogThreshold
ArrayList<E> operationChangeLog
long operationChangeLogSize
boolean forceFullSnapshot
boolean isOperationLogEnabled
int eventIndex
boolean classLoadingIssue
Object value
io.siddhi.query.api.definition.Attribute.Type type
int[] position
int[] position
io.siddhi.query.api.definition.Attribute attribute
int[] position
ExpressionExecutor leftConditionExecutor
ExpressionExecutor rightConditionExecutor
ExpressionExecutor conditionExecutor
int streamEventSize
boolean isMatchingEventAStateEvent
int matchingStreamIndex
CompiledCondition compiledCondition
Table table
ExpressionExecutor expressionExecutor
int[] eventPosition
ExpressionExecutor conditionExecutor
ExpressionExecutor leftConditionExecutor
ExpressionExecutor rightConditionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type inputType
TimestampGenerator timestampGenerator
io.siddhi.query.api.definition.Attribute.Type returnType
boolean expectEventObject
ExpressionExecutor[] attributeExpressionExecutors
SiddhiQueryContext siddhiQueryContext
String functionId
ProcessingMode processingMode
ConfigReader configReader
int attributeSize
StateHolder<S extends State> stateHolder
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
Script script
io.siddhi.query.api.definition.Attribute.Type returnType
String timeZone
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
ExpressionExecutor leftExpressionExecutor
ExpressionExecutor rightExpressionExecutor
String key
long startTimestamp
long endTimestamp
long aliveTimestamp
VariableExpressionExecutor[] groupByExecutors
boolean[] isAscendingArray
boolean isProcessPassThrough
ExpressionExecutor[] attributeExpressionExecutors
int attributeSize
StateHolder<S extends State> stateHolder
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
ExpressionExecutor attributeExpressionExecutor
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
io.siddhi.query.api.definition.Attribute.Type returnType
CompiledCondition operatorCompiledCondition
ExpressionExecutor updateOrInsertExpressionExecutor
int storeEventIndex
Map<K,V> primaryKeyData
Map<K,V> indexData
PrimaryKeyReferenceHolder[] primaryKeyReferenceHolders
String tableName
String siddhiAppName
String primaryKeyAttributes
StreamEventFactory tableStreamEventFactory
StreamEventConverter eventConverter
Map<K,V> indexMetaData
Map<K,V> multiPrimaryKeyMetaData
Map<K,V> allIndexMetaData
ArrayList<E> operationChangeLog
long eventsCount
boolean forceFullSnapshot
boolean isOperationLogEnabled
CacheTable cacheTable
StreamEventFactory tableStreamEventFactory
StreamEventConverter eventConverter
String primaryKeyAttribute
int primaryKeyPosition
QuerySelector querySelector
MetaStateEvent metaStateEvent
io.siddhi.core.table.record.AbstractQueryableRecordTable.RecordStoreCompiledSelection recordStoreCompiledSelection
int storeEventIndex
List<E> variableExpressionExecutorsForQuerySelector
Map<K,V> variableExpressionExecutorMap
CompiledCondition compiledCondition
SiddhiQueryContext siddhiQueryContext
StreamEventFactory streamEventFactory
StateEventFactory stateEventFactory
int storeEventIndex
int streamEventIndex
Map<K,V> attributeMap
ExpressionExecutor inMemoryCompiledCondition
String key
SessionWindowProcessor.SessionComplexEventChunk<E extends ComplexEvent> currentSession
SessionWindowProcessor.SessionComplexEventChunk<E extends ComplexEvent> previousSession
int matchingStreamEventPosition
ExpressionExecutor expressionExecutor
int storeEventPosition
ExpressionExecutor expressionExecutor
int storeEventPosition
boolean isOnDemandQuery
String aggregationName
boolean isProcessingOnExternalTime
boolean isDistributed
List<E> activeIncrementalDurations
StreamEventFactory streamEventFactoryForTableMeta
StreamEventCloner tableEventCloner
StreamEventFactory streamEventFactoryForAggregateMeta
StreamEventCloner aggregateEventCloner
Map<K,V> aggregationTableMap
List<E> outputExpressionExecutors
boolean isOptimisedLookup
Map<K,V> withinTableCompiledSelection
Map<K,V> withinTableCompiledConditions
CompiledCondition inMemoryStoreCompileCondition
Map<K,V> withinTableLowerGranularityCompileCondition
CompiledCondition onCompiledCondition
List<E> additionalAttributes
ExpressionExecutor perExpressionExecutor
ExpressionExecutor startTimeEndTimeExpressionExecutor
List<E> timestampFilterExecutors
MetaStreamEvent tableMetaStreamEvent
ComplexEventPopulater complexEventPopulater
MatchingMetaInfoHolder alteredMatchingMetaInfoHolder
MatchingMetaInfoHolder matchingHolderInfoForTableLookups
List<E> variableExpExecutorsForTableLookups
String queryName
CollectionExecutor collectionExecutor
CacheTable cacheTable
int matchingStreamEventIndex
int storeEventIndex
io.siddhi.query.api.definition.AbstractDefinition matchingStreamDefinition
io.siddhi.query.api.definition.AbstractDefinition storeDefinition
MetaStateEvent metaStateEvent
int currentState
ExpressionExecutor expressionExecutor
int storeEventPosition
ComplexEventChunk<E extends ComplexEvent> complexEventChunk
CompiledCondition compiledCondition
StateEvent stateEvent
CompiledUpdateSet compiledUpdateSet
AddingStreamEventExtractor addingStreamEventExtractor
boolean isFromConnectionUnavailableException
boolean isEditable
Object state
boolean isIncrementalSnapshot
Copyright © 2021. All rights reserved.