Hi guys,
I would like knowing if the part of code is right to use in Window.
JavaPairDStream<String, Integer> wordCounts = words.map(
103 new PairFunction<String, String, Integer>() {
104 @Override
105 public Tuple2<String, Integer> call(String s) {
106 return new Tuple2<String, Integer>(s, 1);
107 }
108 }).reduceByKeyAndWindow(
109 new Function2<Integer, Integer, Integer>() {
110 public Integer call(Integer i1, Integer i2) { return i1 +
i2; }
111 },
112 new Function2<Integer, Integer, Integer>() {
113 public Integer call(Integer i1, Integer i2) { return i1 -
i2; }
114 },
115 new Duration(60 * 5 * 1000),
116 new Duration(1 * 1000)
117 );
Thanks
--
Informativa sulla Privacy: http://www.unibs.it/node/8155
