Pinned Repositories
flink
flink-connector-clickhouse
Flink SQL connector for ClickHouse. Support ClickHouseCatalog and writing primary data, maps, arrays to clickhouse.
flink-learning
Flink-Recommended-System
flink-siddhi
A CEP library to run Siddhi within Apache Flink™ Streaming Application
flink-spector
Framework for Apache Flink unit tests
flink-sql-gateway
flink-sql-lineage
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.
gelly-streaming
An experimental Graph Streaming API for Apache Flink
StreamingBench
A streaming benchmark supporting Flink and Spark
Flink-zhisheng's Repositories
Flink-zhisheng/flink-learning
Flink-zhisheng/Flink-Recommended-System
Flink-zhisheng/flink
Flink-zhisheng/StreamingBench
A streaming benchmark supporting Flink and Spark
Flink-zhisheng/flink-connector-clickhouse
Flink SQL connector for ClickHouse. Support ClickHouseCatalog and writing primary data, maps, arrays to clickhouse.
Flink-zhisheng/flink-sql-lineage
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.
Flink-zhisheng/bahir-flink
Mirror of Apache Bahir Flink
Flink-zhisheng/flink-connector-email
IMAP / SMTP connectors for Apache Flink®
Flink-zhisheng/flink-siddhi
A CEP library to run Siddhi within Apache Flink™ Streaming Application
Flink-zhisheng/flink-spector
Framework for Apache Flink unit tests
Flink-zhisheng/flink-sql-gateway
Flink-zhisheng/gelly-streaming
An experimental Graph Streaming API for Apache Flink
Flink-zhisheng/pulsar-flink
Elastic data processing with Apache Pulsar and Apache Flink
Flink-zhisheng/alibaba-flink-connectors
Flink-zhisheng/flink-ai-extended
Flink-zhisheng/flink-benchmarks
Flink-zhisheng/flink-client
Java library for managing Apache Flink via the Monitoring REST API
Flink-zhisheng/flink-connector-shared-utils
Apache flink util
Flink-zhisheng/flink-docker
Docker packaging for Apache Flink
Flink-zhisheng/flink-http-connector
Flink Http Connector
Flink-zhisheng/flink-k8s-toolbox
Tools for managing Flink clusters on Kubernetes
Flink-zhisheng/flink-kubernetes-operator
Apache Flink Kubernetes Operator
Flink-zhisheng/flink-native-k8s-operator
Flink native Kubernetes Operator is a java based control plane for running Apache Flink native application on Kubernetes.
Flink-zhisheng/flink-on-k8s-operator
Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.
Flink-zhisheng/flink-shaded-hadoop
Apache Flink shaded hadoop artifacts repository
Flink-zhisheng/flink-tutorials
Flink-zhisheng/flinkx
基于flink的分布式数据同步工具
Flink-zhisheng/kafkastreams-cep
Complex Event Processing on top of Kafka Streams
Flink-zhisheng/stateful-functions
Stateful Functions for Apache Flink
Flink-zhisheng/ververica-platform-k8s-operator
Kubernetes Operator for the Ververica Platform