Stream Input (Input) -> Tuple-Based Aggregator (Stream ??“ Stream) - >
Stream Output.
2. Stream Input (Input) -> Attribute-Based Window (Stream ??“ Relation) ->
Relation Stream -> Stream Output.
Chapter 8
[ 173 ]
3. Stream Input (Input) -> Partitioned Window (Stream ??“ Relation) -> Union
(Relation ??“ Relation) -> Table (Relation ??“ Table) -> Table Output
In Chapter 10 on Building a Sample Application, we will be creating some IEPs to
monitor the airlines reservation stream.
The above figure shows how you can connect operators based on the input types
shown in the table.
Testing IEP Projects
When the IEP is invoked, the stream data is stored in the CURRENTITINERARY table.
The IEP example shown in this chapter needs a stream input simulator
to test the IEP process. The source code bundle provided on the site
has a TestItineraryIEP NetBeans project that reads an external data file
and sends a data stream to the IEP module using the SheperdDriver
(com.sun.jbi.engine.iep.core.runtime.client.pojo.
SheperdDriver). The project is available under src\PartG\
TestItineraryIEP.
You can also test the project by creating a test case in the composite application.
Intelligent Event Processor
[ 174 ]
NetBeans IDE 6.0 and above features an IEP Editor for creating IEPs that can be
deployed to a JBI container as a composite application.
Pages:
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160