Package | Description |
---|---|
com.espertech.esper.client.dataflow |
Client API for data flows.
|
com.espertech.esper.client.dataflow.io |
Client API for data flow io handlers.
|
com.espertech.esper.dataflow.core |
Data flow core classes.
|
com.espertech.esper.dataflow.ops |
Data flow built-in operators.
|
Modifier and Type | Method and Description |
---|---|
EPDataFlowEmitter |
EPDataFlowIRStreamCollectorContext.getEmitter()
Returns the emitter.
|
EPDataFlowEmitter |
EPDataFlowEventBeanCollectorContext.getEmitter()
Returns the emitter.
|
Constructor and Description |
---|
EPDataFlowEventBeanCollectorContext(EPDataFlowEmitter emitter,
boolean submitEventBean,
EventBean event)
Ctor.
|
EPDataFlowIRStreamCollectorContext(EPDataFlowEmitter emitter,
boolean submitEventBean,
EventBean[] newEvents,
EventBean[] oldEvents,
EPStatement statement,
EPServiceProvider epServiceProvider)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
EPDataFlowEmitter |
DataInputToObjectCollectorContext.getEmitter()
Returns the emitter.
|
Modifier and Type | Method and Description |
---|---|
void |
DataInputToObjectCollectorContext.setEmitter(EPDataFlowEmitter emitter)
Sets the emitter
|
Modifier and Type | Interface and Description |
---|---|
interface |
SubmitHandler |
Modifier and Type | Class and Description |
---|---|
class |
EPDataFlowEmitter1Stream1TargetBase |
class |
EPDataFlowEmitter1Stream1TargetPassAlong |
class |
EPDataFlowEmitter1Stream1TargetPassAlongWStream |
class |
EPDataFlowEmitter1Stream1TargetUnwind |
class |
EPDataFlowEmitter1StreamNTarget |
class |
EPDataFlowEmitterNoTarget |
class |
EPDataFlowEmitterNStreamNTarget |
class |
EPDataFlowEmitterWrapperWStatistics |
Constructor and Description |
---|
EPDataFlowEmitterWrapperWStatistics(EPDataFlowEmitter facility,
int producerOpNum,
OperatorStatisticsProvider statisticsProvider,
boolean cpuStatistics) |
Modifier and Type | Class and Description |
---|---|
class |
Emitter |
static class |
EPStatementSource.LocalEmitter |
Modifier and Type | Field and Description |
---|---|
protected EPDataFlowEmitter |
EventBusSource.graphContext |