####Spark Streaming benchmark implementation
| Task Name | Pattern(s) | Selectivity | Tasks |
|---|---|---|---|
| Identity | Transform | 1:1 | 1 |
| Project | Transform | 1:1 | 1 |
| Sequence | Transform | 1:1 | 3 |
| Quality Chk | Filter | N:M, M | 1 |
| Data Gen. | Flat Map | 1:N | 1 |
| Average | Flat Map, Aggregate | N:1 | 2 |
| Fork-Merge | Duplicate, Transform | 1:3 | 4 |
| Split-Merge | Hash, Transform | 1:1 | 4 |
| App. Name | Code |
|---|---|
| Pipeline for realtime forecasting and storage | FCAST |
