# DTStack/flinkStreamSQL

基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join，支持原生flink SQL所有的语法

Repository: https://github.com/DTStack/flinkStreamSQL
Canonical: https://ross.abutalabs.com/products/flinkstreamsql
Language: Java
License: Apache-2.0
License Family: permissive
Topics: flink, sql, stream, bigdata
Last push: 2024-02-21T00:11:04+00:00

## Health v2 (maintenance only)
Score: 23/100 (v2, computed 2026-09-03T02:20:16.233290+00:00)
- activity 0, release rhythm 8, longevity 100
- inputs: {"age_days": 2912, "days_push": 925, "days_rel": null, "gap_med": null, "n_releases_24m": 0}
- flags: none
- formula: round(0.45*activity + 0.35*rhythm + 0.20*longevity); archived -> min(score, 10)

## Adoption (not part of the score)
Stars 2051, forks 914 (observed 2026-08-28T04:06:09.583453+00:00)

## What it is
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
- artifact type: library
- maturity: maintenance
- function: streaming, parser, database, etl
- domain: big-data, databases, analytics
- platform: jvm
- tags: flink, sql, stream-processing, dimension-table-join, real-time-compute, apache-flink, data-engineering, linux, docker

## Member repositories
- DTStack/flinkStreamSQL (main) score 23

## Provenance
- Observed fields: from GitHub, fetched 2026-08-28T04:06:09.583453+00:00.
- Health v2: computed from the inputs above; adoption is never an input.
- Inferred fields (summary, facets, guidance): AI-extracted, prompt v1, taxonomy v1, on 2026-08-30T02:57:30.159275+00:00, confidence not recorded.
  - readme: https://github.com/DTStack/flinkStreamSQL (fetched 2026-08-28T04:06:09.583453+00:00, sha d14999e4a9a1)
- Data as of 2026-08-30T08:39:29.467469+00:00.