Also see the SensorsAggregates sample [1]. If this info addresses your question wrt groupBy maybe that’s an indicator that more doc is needed to note this. e.g., something in one or more of the TStream class javadoc, TStream.last(), TWindow, FAQ [2] and/or The Power of Edgent [3]. Your thoughts? Maybe you could contribute some additional clarifying info?
— Dale [1] https://github.com/apache/incubator-edgent-samples/blob/develop/topology/src/main/java/org/apache/edgent/samples/topology/SensorsAggregates.java <https://github.com/apache/incubator-edgent-samples/blob/develop/topology/src/main/java/org/apache/edgent/samples/topology/SensorsAggregates.java> [2] http://edgent.apache.org/docs/faq <http://edgent.apache.org/docs/faq> [3] http://edgent.apache.org/docs/power-of-edgent.html <http://edgent.apache.org/docs/power-of-edgent.html> > On Mar 22, 2018, at 1:06 PM, Dale LaBossiere <dml.apa...@gmail.com> wrote: > > Hi, (I’ve been in my first month of retirement, yeah it would be helpful if > other original Edgent developers chimed in) > > Edgent provides count or time based Windows of tuples. A window inherently > supports multiple independently managed partitions by a key. Continuous or > batch aggregations can be performed on each partition. > > See TStream.last() and TWindow. Additionally, see edgent.analytics.math3.* > in particular the javadoc for edgent.analytics.math3.Aggregations. > > Hope that helps. > > — Dale > >> On Mar 20, 2018, at 5:28 AM, vino yang <yanghua1...@gmail.com> wrote: >> >> 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 <christofer.d...@c-ware.de>: >> >>> 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" <christofer.d...@c-ware.de>: >>> >>> 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 <yanghua1...@gmail.com> >>> Sent: Friday, March 16, 2018 2:26:10 AM >>> To: dev@edgent.apache.org >>> 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 <yanghua1...@gmail.com>: >>> >>>> Hi guys, >>>> >>>> Does Edgent current support groupBy operator? >>>> >>>> Vino yang >>>> Thanks. >>>> >>> >>> >>> >
