Skip to content

Commit 6a1c1af

Browse files
Anomaly Detection tutorial (#61)
* Add anomaly detection tutorial * Update data generator to create batches at higher rate: * Create topics with retention * Increase emission rate to 1 event per second * Add `batchSize()` to `Data` class * Add `batchSize()` and quantity multiplication to `SalesData` * Use `batchSize()` in `DataGenerator` Co-authored-by: Thomas Cooper <code@tomcooper.dev>
1 parent 61d47b7 commit 6a1c1af

File tree

14 files changed

+698
-5
lines changed

14 files changed

+698
-5
lines changed

docs/anomaly-detection/assets/avg_range.excalidraw.svg

Lines changed: 5 additions & 0 deletions
Loading

docs/anomaly-detection/assets/first_last.excalidraw.svg

Lines changed: 5 additions & 0 deletions
Loading

docs/anomaly-detection/assets/moving_average.excalidraw.svg

Lines changed: 5 additions & 0 deletions
Loading

docs/anomaly-detection/assets/reluctant_quantifier.excalidraw.svg

Lines changed: 5 additions & 0 deletions
Loading

docs/anomaly-detection/assets/scenario.excalidraw.svg

Lines changed: 4 additions & 0 deletions
Loading

docs/anomaly-detection/assets/skip_past_last_row.excalidraw.svg

Lines changed: 5 additions & 0 deletions
Loading

docs/anomaly-detection/assets/useful_match.excalidraw.svg

Lines changed: 5 additions & 0 deletions
Loading

docs/anomaly-detection/assets/useful_query.excalidraw.svg

Lines changed: 5 additions & 0 deletions
Loading

docs/anomaly-detection/index.md

Lines changed: 484 additions & 0 deletions
Large diffs are not rendered by default.
Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
apiVersion: flink.apache.org/v1beta1
2+
kind: FlinkDeployment
3+
metadata:
4+
name: session-cluster-anomaly
5+
spec:
6+
image: quay.io/streamshub/flink-sql-runner:0.2.0
7+
flinkVersion: v2_0
8+
flinkConfiguration:
9+
taskmanager.numberOfTaskSlots: "2"
10+
serviceAccount: flink
11+
jobManager:
12+
resource:
13+
memory: "2048m"
14+
cpu: 1
15+
taskManager:
16+
resource:
17+
memory: "2048m"
18+
cpu: 2

0 commit comments

Comments
 (0)