feat(wirings): Kafka Streams DSL tier wirings + capstone demo (stacks on #3; Kafka mirror of Flink #6→#10)

kafka-streams-app/src/main/java/org/mobilitydb/kafka/meos/MeosOpsBigintSet.java

@@ -0,0 +1,130 @@
+package org.mobilitydb.kafka.meos;
+
+/* AUTO-GENERATED by codegen_flink_v3.py — do not edit by hand.
+ * MEOS object-model class: BigintSet
+ * Methods emitted: 8 (bounded-state=5 · io-meta=2 · stateless=1)
+ * Source: JMEOS jar (PR #15 / regen-against-meos-1.4) ∩ streaming-relevance baseline v4.
+ */
+
+import functions.GeneratedFunctions;
+import jnr.ffi.Pointer;
+
+public final class MeosOpsBigintSet {
+
+    public static final boolean MEOS_AVAILABLE = MeosOpsRuntime.MEOS_AVAILABLE;
+
+    private MeosOpsBigintSet() { /* utility */ }
+
+    /**
+     * MEOS {@code bigintset_make} — tier <b>stateless</b>.
+     * <p>Pure per-event; safe in any Flink scalar position.</p>
+     * <p>Object-model role: {@code constructor}.</p>
+     * <p>Classification: constructor of instant/scalar</p>
+     */
+    public static Pointer bigintset_make(Pointer arg0, int arg1) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintset_make requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintset_make(arg0, arg1);
+    }
+
+    /**
+     * MEOS {@code bigintset_end_value} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static int bigintset_end_value(Pointer arg0) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintset_end_value requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintset_end_value(arg0);
+    }
+
+    /**
+     * MEOS {@code bigintset_shift_scale} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static Pointer bigintset_shift_scale(Pointer arg0, int arg1, int arg2, int arg3, int arg4) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintset_shift_scale requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintset_shift_scale(arg0, arg1, arg2, arg3, arg4);
+    }
+
+    /**
+     * MEOS {@code bigintset_start_value} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static int bigintset_start_value(Pointer arg0) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintset_start_value requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintset_start_value(arg0);
+    }
+
+    /**
+     * MEOS {@code bigintset_value_n} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static int bigintset_value_n(Pointer arg0, int arg1, Pointer arg2) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintset_value_n requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintset_value_n(arg0, arg1, arg2);
+    }
+
+    /**
+     * MEOS {@code bigintset_values} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static Pointer bigintset_values(Pointer arg0) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintset_values requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintset_values(arg0);
+    }
+
+    /**
+     * MEOS {@code bigintset_in} — tier <b>io-meta</b>.
+     * <p>I/O / catalog / lifecycle helper.</p>
+     * <p>Object-model role: {@code constructor}.</p>
+     * <p>Classification: IO/serialization</p>
+     */
+    public static Pointer bigintset_in(String arg0) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintset_in requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintset_in(arg0);
+    }
+
+    /**
+     * MEOS {@code bigintset_out} — tier <b>io-meta</b>.
+     * <p>I/O / catalog / lifecycle helper.</p>
+     * <p>Object-model role: {@code output}.</p>
+     * <p>Classification: IO/serialization</p>
+     */
+    public static String bigintset_out(Pointer arg0) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintset_out requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintset_out(arg0);
+    }
+
+}

kafka-streams-app/src/main/java/org/mobilitydb/kafka/meos/MeosOpsBigintSpan.java

@@ -0,0 +1,144 @@
+package org.mobilitydb.kafka.meos;
+
+/* AUTO-GENERATED by codegen_flink_v3.py — do not edit by hand.
+ * MEOS object-model class: BigintSpan
+ * Methods emitted: 9 (bounded-state=6 · io-meta=2 · stateless=1)
+ * Source: JMEOS jar (PR #15 / regen-against-meos-1.4) ∩ streaming-relevance baseline v4.
+ */
+
+import functions.GeneratedFunctions;
+import jnr.ffi.Pointer;
+
+public final class MeosOpsBigintSpan {
+
+    public static final boolean MEOS_AVAILABLE = MeosOpsRuntime.MEOS_AVAILABLE;
+
+    private MeosOpsBigintSpan() { /* utility */ }
+
+    /**
+     * MEOS {@code bigintspan_make} — tier <b>stateless</b>.
+     * <p>Pure per-event; safe in any Flink scalar position.</p>
+     * <p>Object-model role: {@code constructor}.</p>
+     * <p>Classification: constructor of instant/scalar</p>
+     */
+    public static Pointer bigintspan_make(int arg0, int arg1, int arg2, int arg3) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspan_make requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspan_make(arg0, arg1, arg2, arg3);
+    }
+
+    /**
+     * MEOS {@code bigintspan_bins} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static Pointer bigintspan_bins(Pointer arg0, int arg1, int arg2, Pointer arg3) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspan_bins requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspan_bins(arg0, arg1, arg2, arg3);
+    }
+
+    /**
+     * MEOS {@code bigintspan_expand} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static Pointer bigintspan_expand(Pointer arg0, int arg1) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspan_expand requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspan_expand(arg0, arg1);
+    }
+
+    /**
+     * MEOS {@code bigintspan_lower} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static int bigintspan_lower(Pointer arg0) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspan_lower requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspan_lower(arg0);
+    }
+
+    /**
+     * MEOS {@code bigintspan_shift_scale} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static Pointer bigintspan_shift_scale(Pointer arg0, int arg1, int arg2, int arg3, int arg4) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspan_shift_scale requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspan_shift_scale(arg0, arg1, arg2, arg3, arg4);
+    }
+
+    /**
+     * MEOS {@code bigintspan_upper} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static int bigintspan_upper(Pointer arg0) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspan_upper requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspan_upper(arg0);
+    }
+
+    /**
+     * MEOS {@code bigintspan_width} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static int bigintspan_width(Pointer arg0) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspan_width requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspan_width(arg0);
+    }
+
+    /**
+     * MEOS {@code bigintspan_in} — tier <b>io-meta</b>.
+     * <p>I/O / catalog / lifecycle helper.</p>
+     * <p>Object-model role: {@code constructor}.</p>
+     * <p>Classification: IO/serialization</p>
+     */
+    public static Pointer bigintspan_in(String arg0) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspan_in requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspan_in(arg0);
+    }
+
+    /**
+     * MEOS {@code bigintspan_out} — tier <b>io-meta</b>.
+     * <p>I/O / catalog / lifecycle helper.</p>
+     * <p>Object-model role: {@code output}.</p>
+     * <p>Classification: IO/serialization</p>
+     */
+    public static String bigintspan_out(Pointer arg0) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspan_out requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspan_out(arg0);
+    }
+
+}

kafka-streams-app/src/main/java/org/mobilitydb/kafka/meos/MeosOpsBigintSpanSet.java

@@ -0,0 +1,116 @@
+package org.mobilitydb.kafka.meos;
+
+/* AUTO-GENERATED by codegen_flink_v3.py — do not edit by hand.
+ * MEOS object-model class: BigintSpanSet
+ * Methods emitted: 7 (bounded-state=5 · io-meta=2)
+ * Source: JMEOS jar (PR #15 / regen-against-meos-1.4) ∩ streaming-relevance baseline v4.
+ */
+
+import functions.GeneratedFunctions;
+import jnr.ffi.Pointer;
+
+public final class MeosOpsBigintSpanSet {
+
+    public static final boolean MEOS_AVAILABLE = MeosOpsRuntime.MEOS_AVAILABLE;
+
+    private MeosOpsBigintSpanSet() { /* utility */ }
+
+    /**
+     * MEOS {@code bigintspanset_bins} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static Pointer bigintspanset_bins(Pointer arg0, int arg1, int arg2, Pointer arg3) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspanset_bins requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspanset_bins(arg0, arg1, arg2, arg3);
+    }
+
+    /**
+     * MEOS {@code bigintspanset_lower} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static int bigintspanset_lower(Pointer arg0) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspanset_lower requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspanset_lower(arg0);
+    }
+
+    /**
+     * MEOS {@code bigintspanset_shift_scale} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static Pointer bigintspanset_shift_scale(Pointer arg0, int arg1, int arg2, int arg3, int arg4) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspanset_shift_scale requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspanset_shift_scale(arg0, arg1, arg2, arg3, arg4);
+    }
+
+    /**
+     * MEOS {@code bigintspanset_upper} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static int bigintspanset_upper(Pointer arg0) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspanset_upper requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspanset_upper(arg0);
+    }
+
+    /**
+     * MEOS {@code bigintspanset_width} — tier <b>bounded-state</b>.
+     * <p>Per-event with bounded per-key state (MEOS handle).</p>
+     * <p>Object-model role: {@code accessor}.</p>
+     * <p>Classification: role=accessor</p>
+     */
+    public static int bigintspanset_width(Pointer arg0, int arg1) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspanset_width requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspanset_width(arg0, arg1);
+    }
+
+    /**
+     * MEOS {@code bigintspanset_in} — tier <b>io-meta</b>.
+     * <p>I/O / catalog / lifecycle helper.</p>
+     * <p>Object-model role: {@code constructor}.</p>
+     * <p>Classification: IO/serialization</p>
+     */
+    public static Pointer bigintspanset_in(String arg0) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspanset_in requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspanset_in(arg0);
+    }
+
+    /**
+     * MEOS {@code bigintspanset_out} — tier <b>io-meta</b>.
+     * <p>I/O / catalog / lifecycle helper.</p>
+     * <p>Object-model role: {@code output}.</p>
+     * <p>Classification: IO/serialization</p>
+     */
+    public static String bigintspanset_out(Pointer arg0) {
+        if (!MEOS_AVAILABLE) {
+            throw new UnsupportedOperationException(
+                "bigintspanset_out requires libmeos — set -Dmobilityflink.meos.enabled=true");
+        }
+        return GeneratedFunctions.bigintspanset_out(arg0);
+    }
+
+}