| Modifier and Type | Interface and Description |
|---|---|
interface |
StreamHandler |
| Modifier and Type | Method and Description |
|---|---|
void |
StreamHandler.setNext(StreamProcessor nextPreStreamFlowProcessor) |
| Modifier and Type | Class and Description |
|---|---|
class |
FilterHandler |
| Modifier and Type | Method and Description |
|---|---|
void |
FilterHandler.setNext(StreamProcessor nextPreStreamFlowProcessor) |
| Modifier and Type | Class and Description |
|---|---|
class |
LengthWindowHandler |
class |
TimeBatchWindowHandler |
class |
TimeWindowHandler |
class |
WindowHandler |
| Modifier and Type | Method and Description |
|---|---|
protected StreamProcessor |
WindowHandler.getNextPreStreamFlowProcessor() |
| Modifier and Type | Method and Description |
|---|---|
void |
WindowHandler.setNext(StreamProcessor nextPreStreamFlowProcessor) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
StreamPacker |
| Modifier and Type | Class and Description |
|---|---|
class |
SingleStreamPacker |
| Modifier and Type | Class and Description |
|---|---|
class |
JoinStreamPacker |
class |
LeftJoinStreamPacker |
class |
RightJoinStreamPacker |
| Modifier and Type | Class and Description |
|---|---|
class |
AndPatternStreamPacker |
class |
CountPatternStreamPacker |
class |
OrPatternStreamPacker |
class |
PatternStreamPacker |
| Modifier and Type | Class and Description |
|---|---|
class |
CountSequenceStreamPacker |
class |
OrSequenceStreamPacker |
class |
SequenceStreamPacker |
| Constructor and Description |
|---|
SingleStreamReceiver(SingleStream inputStream,
StreamProcessor firstStreamProcessor,
ThreadPoolExecutor threadPoolExecutor) |
| Modifier and Type | Field and Description |
|---|---|
protected StreamProcessor |
PatternSingleStreamReceiver.firstSimpleStreamProcessor |
| Constructor and Description |
|---|
AndPatternSingleStreamReceiver(AndPatternState state,
StreamProcessor firstSimpleStreamProcessor,
int complexEventSize) |
CountPatternSingleStreamReceiver(CountPatternState state,
StreamProcessor firstSimpleStreamProcessor,
int complexEventSize) |
OrPatternSingleStreamReceiver(OrPatternState state,
StreamProcessor firstSimpleStreamProcessor,
int complexEventSize) |
PatternSingleStreamReceiver(PatternState state,
StreamProcessor firstSimpleStreamProcessor,
int complexEventSize) |
| Modifier and Type | Field and Description |
|---|---|
protected StreamProcessor |
SequenceSingleStreamReceiver.firstSimpleStreamProcessor |
| Constructor and Description |
|---|
CountSequenceSingleStreamReceiver(CountSequenceState state,
StreamProcessor firstSimpleStreamProcessor,
int complexEventSize) |
OrSequenceSingleStreamReceiver(OrSequenceState state,
StreamProcessor firstSimpleStreamProcessor,
int complexEventSize) |
SequenceSingleStreamReceiver(SequenceState state,
StreamProcessor firstSimpleStreamProcessor,
int complexEventSize) |
Copyright © 2012. All Rights Reserved.