A partition-based stream converter is used to monitor
the last couple of reservations from all the partner airlines.
Drag-and-drop the Stream Input operator into the workspace. In the Stream Input
Property Editor, we define Attributes, Data Types, and the Size, which will be
updated in the IEP table. Enter ItineraryStream as the Name of the operator.
Chapter 8
[ 169 ]
Once the input is defined, you can create a TupleBasedWindow stream
converter that takes a pre-defined size of entries and pipe it to the stream output.
Drag-and-drop the TupleBasedWindow stream converter into the palette. Now,
drag-and-drop the arrow head from the ItineraryStream icon to the arrow head of
the TubleBasedWindow0 icon.
Double-click on the TupleBasedWindow operator. The Attributes are automatically
populated. In the Size filed enter 3. This is because, at any time, we want to process
only three itineraries. This is shown in the following figure:
Intelligent Event Processor
[ 170 ]
Now, drag-and-drop the TableOutput operator into the workspace and connect the
arrow head of the TupleBasedWindow0 icon to the arrow head of the TableOutput0
icon as shown in the following figure:
Now, double-click on the TableOutput operator to view the properties dialog. Click
the IsGlobal check box and enter the Global ID as CurrentItinerary.
Pages:
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158