Hi Chris, My background is BigData (MapReduce, Spark, Flink, Kafka Stream) those data processing frameworks all provide the groupBy / keyBy operation and aggregation operator. It comes from traditional RDBMS. Edgent like a single JVM's Flink / Kafka Stream works on edges(gateway or IoT). They are similar with each other in some ways.
Vino yang. Thanks! 2018-03-20 17:05 GMT+08:00 Christofer Dutz <[email protected]>: > Hi Vino, > > unfortunately I can't contribute any opinion on this as I don't yet > understand the consequences. > I know that in an asynchronous event processing system some operations > that might be useful have to be sacrificed for the sake of asynchonisity. > > For me Kafka Stream sort of feeling like the cloud-brother of Edgent, it > does seem to support groupBy. > > Would be really cool if some of the formerly active people could at least > leave some comments on questions like this. You don't have to actually work > on things, but giving us new guys some guidance would be awesome. > > I don't want to ruin thing you built over years, just because I'm not that > into the topic ... yet. > > Chris > > > > > Am 16.03.18, 13:02 schrieb "Christofer Dutz" <[email protected]>: > > I'm currently at a conference, so I can't be as responsive as I used > to be ... All will be back to normal next Tuesday ;-) > > Chris > > Outlook for Android<https://aka.ms/ghei36> herunterladen > > ________________________________ > From: vino yang <[email protected]> > Sent: Friday, March 16, 2018 2:26:10 AM > To: [email protected] > Subject: Re: [disscuss] make TStream support groupBy operator? > > Hi all, > > Anyone can give some opinion? Chris ? I think we should support some > reduce > operation(aggregation function, such as max / avg / min sum) for both > stream and windowed stream, these features based on the keyBy or > groupBy > operation. > > Vino yang > Thanks! > > 2018-03-13 12:52 GMT+08:00 vino yang <[email protected]>: > > > Hi guys, > > > > Does Edgent current support groupBy operator? > > > > Vino yang > > Thanks. > > > > >
