我有一个用来测试时间的查询。下面是两个例子: users.fname as counselor, SEC_TO_TIME(AVG(TIME_TO_SEC(TIMEDIFF(starttime, signintime)))) AS 'AVG Wait Time',
SEC_TO_TIME(AVG(TIME_TO_SEC(TIMEDIFF(finishtime, starttime)))) AS 'AVG
但是,我对使用Beam,Spark Streaming持开放态度,无论我发现什么适合我的用例。., z 对于Flink来说,求平均值似乎是通过AggregateFunction https://github.com/apache/flink/blob/master/flink-core/src/对于单个字段的平均值而言,这似乎是大量的样板。如果我有几个不同的流,需要对不同的字段进行平均,该怎么办?
select SeasonPlayer).ToList();
SeasonPlayer有一个ICollection of StatisticsPlayer,所以我想得到一个由STP_timeplay命令下降的平均时间我不能用STP_timeplay求平均值,因为它不是小数,所以我试着用滴答来求平均值。