https://pinot.apache.org/ logo
#general
Title
# general
p

Peter Pringle

08/23/2021, 1:35 PM
How are people handling timeseries analytics with pinot? Looking for things like zero filing with last value (step interpolation), summing across interpolated series to get a total by time bucket, get last and first value in a time bucket, moving averages etc. Guess we can go over to python etc and implement but it would be nice for some native analytic functions.
g

Greg Simons

08/23/2021, 1:49 PM
I’m not well placed on this one but i was experimenting a little with Apache third eye https://readthedocs.org/projects/thirdeye/downloads/pdf/latest/ and there are some percentage based filtering and some based around holt winters
k

Kishore G

08/23/2021, 2:05 PM
Most end up implementing udf to achieve that.. if you think some of these are useful beyond your use case, please file issue
p

Peter Pringle

08/23/2021, 2:09 PM
Looks like presto has a pretty broad set of aggregation and window functions. https://prestodb.io/docs/current/functions/aggregate.html In pinot can we implement aggregates as udfs?
k

Kishore G

08/23/2021, 2:10 PM
Yes
p

Peter Pringle

08/26/2021, 1:37 AM
Nice I will see if I can build earliest / latest operators
Couldn't find an example udf which works on an aggregation. Looking for something like
Copy code
select product, groovy('{"returnType":"DOUBLE","isSingleValue":true}', 'arg[0]', myCol) as First
from table
group by product