Modifier and Type | Interface and Description |
---|---|
interface |
StreamEvent
Events that can be streamed
|
Modifier and Type | Class and Description |
---|---|
class |
Event |
class |
ListEvent |
Modifier and Type | Class and Description |
---|---|
class |
FaultEvent |
class |
FaultListEvent |
Modifier and Type | Class and Description |
---|---|
class |
InEvent |
class |
InListEvent |
class |
StateEvent
Event with state
|
Modifier and Type | Class and Description |
---|---|
class |
RemoveEvent |
class |
RemoveListEvent |
Modifier and Type | Method and Description |
---|---|
void |
StreamProcessor.process(ComplexEvent complexEvent) |
Modifier and Type | Method and Description |
---|---|
void |
FilterHandler.process(ComplexEvent complexEvent) |
Modifier and Type | Method and Description |
---|---|
void |
LengthWindowHandler.process(ComplexEvent complexEvent) |
void |
TimeBatchWindowHandler.process(ComplexEvent complexEvent) |
void |
TimeWindowHandler.process(ComplexEvent complexEvent) |
Modifier and Type | Method and Description |
---|---|
void |
SingleStreamPacker.process(ComplexEvent complexEvent) |
Modifier and Type | Method and Description |
---|---|
protected abstract StateEvent |
JoinStreamPacker.createNewEvent(ComplexEvent complexEvent,
ComplexEvent complexEvent1) |
protected StateEvent |
LeftJoinStreamPacker.createNewEvent(ComplexEvent complexEvent,
ComplexEvent complexEvent1) |
protected StateEvent |
RightJoinStreamPacker.createNewEvent(ComplexEvent complexEvent,
ComplexEvent complexEvent1) |
void |
JoinStreamPacker.process(ComplexEvent complexEvent) |
Modifier and Type | Method and Description |
---|---|
void |
PatternStreamPacker.process(ComplexEvent complexEvent) |
void |
CountPatternStreamPacker.process(ComplexEvent complexEvent) |
Modifier and Type | Method and Description |
---|---|
void |
CountSequenceStreamPacker.process(ComplexEvent complexEvent) |
void |
SequenceStreamPacker.process(ComplexEvent complexEvent) |
Modifier and Type | Class and Description |
---|---|
class |
SequenceResetEvent |
Copyright © 2012. All Rights Reserved.