DTStack/flinkStreamSQL

Health v2 · maintenance only

Adoption not part of the score

2051 stars · 914 forks observed · 2026-08-28

What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-30, confidence not recorded

FlinkStreamSQL is a Java framework built on Apache Flink that extends Flink's real-time SQL with custom create table/view/function syntax and stream-to-dimension-table joins. It supports all native Flink SQL syntax and extends input/output performance metrics into Task metrics.

Use cases

• join a Kafka stream with a dimension table in Flink SQL
• write streaming SQL jobs with custom source, sink, and dimension table syntax
• extend Flink SQL with custom functions and views
• monitor input/output throughput metrics of Flink SQL jobs
• build real-time data pipelines using SQL instead of Java DataStream code

When to choose

• you need stream-to-dimension-table joins that native Flink SQL lacks
• you want declarative SQL-based stream processing on Flink
• you need custom DDL syntax for sources, sinks, and lookup tables
• you want extended task-level metrics for streaming SQL jobs

When to avoid

• you only need standard Flink SQL features already in Apache Flink
• you use a recent Flink version with built-in lookup joins
• you need a maintained project - development appears inactive since early 2024
• you prefer the official Flink SQL client and ecosystem

Facets

library · maturity maintenance

streaming parser database etl big-data databases analytics jvm flink sql stream-processing dimension-table-join real-time-compute apache-flink data-engineering linux docker

Member repositories

For agents

markdown · JSON · MCP: product_card(name="DTStack/flinkStreamSQL")