Issues

• Metadata catalog for features & pipelines (OpenLineage/Marquez)

  cchenax/streamforge-ai#76 · Filter by author cchenax opened on May 25, 2026
  

• Training data sampling/downsampling for active learning

  cchenax/streamforge-ai#75 · Filter by author cchenax opened on May 25, 2026
  

• Real-time inference pipeline example (Flink + model server)

  cchenax/streamforge-ai#74 · Filter by author cchenax opened on May 25, 2026
  

• Streaming windowed feature examples (rolling aggregates, sessionization)

  cchenax/streamforge-ai#73 · Filter by author cchenax opened on May 25, 2026
  

• Real-time feature drift detection & alerting

  cchenax/streamforge-ai#72 · Filter by author cchenax opened on May 25, 2026
  

• Stream-to-batch joins (Flink with Iceberg dimension tables)

  cchenax/streamforge-ai#71 · Filter by author cchenax opened on May 25, 2026
  

• Schema registry integration (Confluent Schema Registry or Apicurio)

  cchenax/streamforge-ai#70 · Filter by author cchenax opened on May 25, 2026
  

• Online feature serving API with caching

  cchenax/streamforge-ai#69 · Filter by author cchenax opened on May 25, 2026
  

• Feature store integration (Feast, Tecton-compatible interface)

  cchenax/streamforge-ai#68 · Filter by author cchenax opened on May 25, 2026
  

• Multi-source CDC support (PostgreSQL, MongoDB)

  cchenax/streamforge-ai#67 · Filter by author cchenax opened on May 25, 2026