beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <>
Subject [jira] [Commented] (BEAM-2953) Create more advanced Timeseries processing examples using state API
Date Mon, 27 Nov 2017 20:43:01 GMT


ASF GitHub Bot commented on BEAM-2953:

reuvenlax commented on issue #4116: [BEAM-2953] Part 1 of Multipart advanced timeseries examples
   R: @kennknowles 

This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:

> Create more advanced Timeseries processing examples using state API
> -------------------------------------------------------------------
>                 Key: BEAM-2953
>                 URL:
>             Project: Beam
>          Issue Type: Improvement
>          Components: examples-java
>    Affects Versions: 2.1.0
>            Reporter: Reza ardeshir rokni
>            Assignee: Reuven Lax
>            Priority: Minor
> As described in the phase 1 portion of this solution outline:
> BEAM can be used to build out some very interesting pre-processing stages for time series
data. Some examples that will be useful:
> - Downsampling time series based on simple AVG, MIN, MAX
> - Creating a value for each time window using generatesequence as a seed 
> - Loading the value of a downsample with the previous value (used in FX with previous
close being brought into current open value) 
> This will show some concrete examples of keyed state as well as the use of combiners.

> The samples can also be used to show how you can create a ordered list of values per
key from a unbounded topic which has multiple time series keys. 

This message was sent by Atlassian JIRA

View raw message