InfoSphere Streams Studio - btree/btree.dp*'- Eclipse Platform
O-
S* import_export_appset.dpsm
El **lnfoSphe...
gE Outlme 53
> cp*appl
> c*app2 e* btree
> £3 streams.spade.jar
> a.JRE System Library Ij t> src
e-data &etc &opt
t>
t>
btree.dps
btree.processed 13 canceljob_ btree.sh L^Makefile B) monitor_btree.sh start_streams_btree. stop_streams_btree.: i2 submitjob_btree.sh t> c*grep
^ gy import_export_appset £> data
t> £>etc
El canceljob_appl.sh BI canceljob_app2.sh L canceljob_import_ex imDort exoort aoosc
1*1 ' I ~
IB
[Program)
tdefine LEVELS \1
stream Sourcel(test:Strmg)
:■ SourceO [“file: ///Source. dat", interArnvalTimc=O.Gl, workloadSize=1000] {}
bundle Nodes
stream NodeOO(test:String) :* Functor(Sourcel)[]{> Nodes ♦= NodeOO
forjyegin ©i 1 to LEVELS-1 forjbegin @j 0 to (2**©i)-l stream Vode©i©j(test:String)
:■ Functor(Nodes[ (pow(2,£i)4£;)/2-l)) U{> Nodes 4= Node@i@j forjtnd for_end
eh
** Streams Live Gra LL Problems 0 Console 53 “ □
SPADE build sunmary auocation:
a0217b07el.hny.distiUery.ibm.com
Total rumbę r of jobs 1 Total nimber of PEs 8
Total nimber of PEs to be placed at compilc time
Total nimber of hosts to be used 1
SPADE compilation has completed successfully, wr
Ynn arp riinninn m nnprAtnr fiisp mrw
>
/ SPADE Application Graph 53
& 5
R application btree
> & Source 1 <= Source ■* bundle Nodes := ()
> fa NodeOO <= Functor •* Nodes += NodeOO
v c for_bcgin Ui v C for_begin
f* Node@i@j <= Fun > [K output stream f C* flmput port $1 Nodes += Node@
^ O. Nodes => Sink t> ~BJ input port $1
Preprocessor arguments: 4
rw |
fM ff*1 | |
a
£B & □' n-
will hi
Oi Streams Search £2 |
/ Streams Live Graph Ou “ |
□ | |
|Node* |
J searc.y | ||
□ Produced Stream Names | |||
El Operator Names □ Operator Types | |||
Name |
Type |
_2_ | |
IM Node32 |
FUnctor | ||
!MNode33 |
Functor | ||
1 u- |
* |