ComplexEvent first
ComplexEvent previousToLastReturned
ComplexEvent lastReturned
ComplexEvent last
boolean isBatch
ComplexEvent complexEvent
String groupKey
ComplexEvent next
StreamEvent[] streamEvents
StateEvent next
long timestamp
ComplexEvent.Type type
Object[] outputData
long id
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
StreamEventConverter streamEventConverter
StreamEventFactory streamEventFactory
int fromPosition
int[] toPosition
StreamEvent first
StreamEvent previousToLastReturned
StreamEvent lastReturned
StreamEvent last
int operationChangeLogThreshold
ArrayList<E> operationChangeLog
long operationChangeLogSize
boolean forceFullSnapshot
boolean isOperationLogEnabled
int eventIndex
boolean classLoadingIssue
String key
long startTimestamp
long endTimestamp
long aliveTimestamp
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
StreamEventFactory tableStreamEventFactory
StreamEventConverter eventConverter
String primaryKeyAttribute
int primaryKeyPosition
String key
SessionWindowProcessor.SessionComplexEventChunk<E extends ComplexEvent> currentSession
SessionWindowProcessor.SessionComplexEventChunk<E extends ComplexEvent> previousSession
Object state
boolean isIncrementalSnapshot
Copyright © 2019. All rights reserved.