Add flink util

spotify · Feb 21, 2022 · 3eb17d5 · 3eb17d5
1 parent c88c9ae
commit 3eb17d5
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/internal/flink/util.go b/internal/flink/util.go
@@ -0,0 +1,12 @@
+package flink
+
+import (
+	"crypto/md5"
+	"encoding/hex"
+)
+
+// Deterministic job ID generation based on the input string
+func GenerateJobId(str string) string {
+	hash := md5.Sum([]byte(str))
+	return hex.EncodeToString(hash[:])
+}