Repositories list

• Flink-Recommended-System

  Public
  Java

  •1•11•0•4•Updated Sep 5, 2023Sep 5, 2023

• flink-connector-shared-utils

  Public
  Apache flink util

  Apache License 2.0

  •17•0•0•0•Updated Mar 21, 2023Mar 21, 2023

• flink-sql-lineage

  Public
  FlinkSQL字段血缘解决方案及源码。FlinkSQL field lineage solution and source code, The core idea is to parse SQL through Calcite to generate a RelNode tree of relational expressions. Then get the optimized logical paln through optimization stage, and finally call Calcite RelMetadataQuery to get the lineage relationship at the field level.

  Java

  •168•1•0•0•Updated Feb 1, 2023Feb 1, 2023

• flink-http-connector

  Public
  Flink Http Connector

  Java

  •

  Apache License 2.0

  •45•0•0•0•Updated Dec 6, 2022Dec 6, 2022

• flink

  Public
  Java

  •

  Apache License 2.0

  •0•3•0•10•Updated Nov 1, 2022Nov 1, 2022

• flink-learning

  Public
  Java

  •

  Apache License 2.0

  •40•159•0•7•Updated Jun 21, 2022Jun 21, 2022

• flink-kubernetes-operator

  Public
  Apache Flink Kubernetes Operator

  Java

  •

  Apache License 2.0

  •422•0•0•0•Updated Feb 18, 2022Feb 18, 2022

• flink-docker

  Public
  Docker packaging for Apache Flink

  Shell

  •

  Apache License 2.0

  •197•0•0•0•Updated Feb 7, 2022Feb 7, 2022

• flink-shaded-hadoop

  Public
  Apache Flink shaded hadoop artifacts repository

  Apache License 2.0

  •9•0•0•0•Updated Oct 27, 2021Oct 27, 2021

• flink-connector-clickhouse

  Public
  Flink SQL connector for ClickHouse. Support ClickHouseCatalog and writing primary data, maps, arrays to clickhouse.

  Java

  •

  Apache License 2.0

  •158•1•0•0•Updated Sep 22, 2021Sep 22, 2021

• flink-connector-email

  Public
  IMAP / SMTP connectors for Apache Flink®

  Java

  •

  Apache License 2.0

  •5•0•0•0•Updated Aug 23, 2021Aug 23, 2021

• ververica-platform-k8s-operator

  Public
  Kubernetes Operator for the Ververica Platform

  Go

  •

  Apache License 2.0

  •12•0•0•0•Updated Nov 23, 2020Nov 23, 2020

• flink-on-k8s-operator

  Public
  Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.

  Go

  •

  Apache License 2.0

  •265•0•0•0•Updated Sep 28, 2020Sep 28, 2020

• flink-native-k8s-operator

  Public
  Flink native Kubernetes Operator is a java based control plane for running Apache Flink native application on Kubernetes.

  Java

  •

  Apache License 2.0

  •31•0•0•0•Updated Jul 2, 2020Jul 2, 2020

• flink-siddhi

  Public
  A CEP library to run Siddhi within Apache Flink™ Streaming Application

  Java

  •

  Apache License 2.0

  •96•0•0•0•Updated May 7, 2020May 7, 2020

• flink-benchmarks

  Public
  Java

  •

  GNU General Public License v3.0

  •41•0•0•0•Updated Apr 9, 2020Apr 9, 2020

• flink-client

  Public
  Java library for managing Apache Flink via the Monitoring REST API

  Java

  •

  BSD 3-Clause "New" or "Revised" License

  •22•0•0•0•Updated Mar 28, 2020Mar 28, 2020

• bahir-flink

  Public
  Mirror of Apache Bahir Flink

  Java

  •

  Apache License 2.0

  •430•0•0•0•Updated Mar 14, 2020Mar 14, 2020

• flink-sql-gateway

  Public
  Java

  •

  Apache License 2.0

  •187•0•0•0•Updated Mar 11, 2020Mar 11, 2020

• flink-k8s-toolbox

  Public
  Tools for managing Flink clusters on Kubernetes

  Kotlin

  •

  BSD 3-Clause "New" or "Revised" License

  •9•0•0•0•Updated Mar 8, 2020Mar 8, 2020

• flinkx

  Public
  基于flink的分布式数据同步工具

  Java

  •

  Apache License 2.0

  •1.7k•0•0•0•Updated Mar 5, 2020Mar 5, 2020

• flink-tutorials

  Public
  Java

  •

  Apache License 2.0

  •75•0•0•0•Updated Dec 10, 2019Dec 10, 2019

• StreamingBench

  Public
  A streaming benchmark supporting Flink and Spark

  Java

  •7•2•0•0•Updated Nov 29, 2019Nov 29, 2019

• pulsar-flink

  Public
  Elastic data processing with Apache Pulsar and Apache Flink

  Scala

  •

  Apache License 2.0

  •120•0•0•0•Updated Nov 27, 2019Nov 27, 2019

• alibaba-flink-connectors

  Public
  Java

  •

  Apache License 2.0

  •42•0•0•0•Updated Nov 14, 2019Nov 14, 2019

• kafkastreams-cep

  Public
  Complex Event Processing on top of Kafka Streams

  Java

  •

  Apache License 2.0

  •63•0•0•0•Updated Oct 30, 2019Oct 30, 2019

• stateful-functions

  Public
  Stateful Functions for Apache Flink

  Java

  •

  Apache License 2.0

  •58•0•0•0•Updated Oct 15, 2019Oct 15, 2019

• flink-ai-extended

  Public
  C++

  •

  Apache License 2.0

  •201•0•0•0•Updated Oct 15, 2019Oct 15, 2019

• gelly-streaming

  Public
  An experimental Graph Streaming API for Apache Flink

  Java

  •

  Apache License 2.0

  •44•0•0•0•Updated May 23, 2019May 23, 2019

• flink-spector

  Public
  Framework for Apache Flink unit tests

  Java

  •

  Apache License 2.0

  •59•0•0•0•Updated Apr 28, 2019Apr 28, 2019