| Mode | Name | Size | |
|---|---|---|---|
| -rw-r--r-- | filter.go | 712 | logplain |
| -rw-r--r-- | harness_test.go | 436 | logplain |
| -rw-r--r-- | keyby.go | 700 | logplain |
| -rw-r--r-- | keyed_process.go | 2066 | logplain |
| -rw-r--r-- | map.go | 1176 | logplain |
| -rw-r--r-- | operator.go | 347 | logplain |
| -rw-r--r-- | stateful_map.go | 2095 | logplain |
| -rw-r--r-- | watermark.go | 1293 | logplain |
| -rw-r--r-- | watermark_test.go | 1236 | logplain |
| -rw-r--r-- | window.go | 2945 | logplain |
 |
index : flux.git | |
| Event-driven stream processing engine in Go with stateful computation & windowing | sangtran |
| aboutsummaryrefslogtreecommitdiff |