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.