File tree 4 files changed +73
-0
lines changed
4 files changed +73
-0
lines changed Original file line number Diff line number Diff line change
1
+ # Licensed Materials - Property of IBM
2
+ # ObjectStorage Toolkit for IBM Streams
3
+ # (c) Copyright IBM Corp. 2020
4
+ # All rights reserved.
5
+ .PHONY : all clean
6
+
7
+ all :
8
+ for dir in $( shell ls -d -1 * /) ; do\
9
+ make -C $$ dir || exit 1; \
10
+ done
11
+
12
+ clean :
13
+ for dir in $( shell ls -d -1 * /) ; do\
14
+ make -C $$ dir clean || exit 1; \
15
+ done
16
+
Original file line number Diff line number Diff line change
1
+
2
+ public composite Main {
3
+
4
+ graph
5
+
6
+ // Let’s generate some data.
7
+ stream<int64 iter> Data = Beacon() {
8
+ param
9
+ period: 0.2; // new tuple every second
10
+ iterations: 10;
11
+ output Data:
12
+ iter = (int64)IterationCount();
13
+ }
14
+
15
+ stream<I> Incr = com.ibm.streamsx.transform::Modify(Data as I) {
16
+ output Incr: iter=I.iter+100l;
17
+ }
18
+
19
+ () as sink = Custom(Incr as I) {
20
+ logic onTuple I: {
21
+ println((rstring)I);
22
+ }
23
+ }
24
+
25
+ }
Original file line number Diff line number Diff line change
1
+ .PHONY : all clean
2
+
3
+ SPLC_FLAGS = -a -t ../../com.ibm.streamsx.transform
4
+ SPLC = $(STREAMS_INSTALL ) /bin/sc
5
+
6
+ SPL_CMD_ARGS ?=
7
+ SPL_MAIN_COMPOSITE = Main
8
+
9
+ all : distributed
10
+
11
+ distributed :
12
+ $(SPLC ) $(SPLC_FLAGS ) -M $(SPL_MAIN_COMPOSITE ) $(SPL_CMD_ARGS )
13
+
14
+ clean :
15
+ $(SPLC ) $(SPLC_FLAGS ) -C -M $(SPL_MAIN_COMPOSITE )
16
+ rm -rf output
17
+
Original file line number Diff line number Diff line change
1
+ <?xml version =" 1.0" encoding =" UTF-8" ?>
2
+ <info : toolkitInfoModel xmlns : common =" http://www.ibm.com/xmlns/prod/streams/spl/common" xmlns : info =" http://www.ibm.com/xmlns/prod/streams/spl/toolkitInfo" >
3
+ <info : identity >
4
+ <info : name >ModifySample</info : name >
5
+ <info : description >Sample application showing Modify operator</info : description >
6
+ <info : version >1.0.0</info : version >
7
+ <info : requiredProductVersion >4.3.0</info : requiredProductVersion >
8
+ </info : identity >
9
+ <info : dependencies >
10
+ <info : toolkit >
11
+ <common : name >com.ibm.streamsx.transform</common : name >
12
+ <common : version >[1.0.0,2.0.0)</common : version >
13
+ </info : toolkit >
14
+ </info : dependencies >
15
+ </info : toolkitInfoModel >
You can’t perform that action at this time.
0 commit comments