All Projects → ververica → Flink Sql Cookbook

ververica / Flink Sql Cookbook

Licence: apache-2.0
The Apache Flink SQL Cookbook is a curated collection of examples, patterns, and use cases of Apache Flink SQL. Many of the recipes are completely self-contained and can be run in Ververica Platform as is.

Projects that are alternatives of or similar to Flink Sql Cookbook

Pulsar Flink
Elastic data processing with Apache Pulsar and Apache Flink
Stars: ✭ 126 (-33.33%)
Mutual labels:  sql, stream-processing, flink
Streaming Readings
Streaming System 相关的论文读物
Stars: ✭ 554 (+193.12%)
Mutual labels:  stream-processing, flink
Ksql
The database purpose-built for stream processing applications.
Stars: ✭ 4,668 (+2369.84%)
Mutual labels:  sql, stream-processing
Athenax
SQL-based streaming analytics platform at scale
Stars: ✭ 1,178 (+523.28%)
Mutual labels:  sql, flink
flink-connectors
Apache Flink connectors for Pravega.
Stars: ✭ 84 (-55.56%)
Mutual labels:  stream-processing, flink
Alchemy
给flink开发的web系统。支持页面上定义udf,进行sql和jar任务的提交;支持source、sink、job的管理;可以管理openshift上的flink集群
Stars: ✭ 264 (+39.68%)
Mutual labels:  sql, flink
Pulsar Spark
When Apache Pulsar meets Apache Spark
Stars: ✭ 55 (-70.9%)
Mutual labels:  stream-processing, flink
Examples
Demo applications and code examples for Confluent Platform and Apache Kafka
Stars: ✭ 571 (+202.12%)
Mutual labels:  sql, stream-processing
Fiflow
flink-sql 在 flink 上运行 sql 和 构建数据流的平台 基于 apache flink 1.10.0
Stars: ✭ 100 (-47.09%)
Mutual labels:  sql, flink
Flink Learning
flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例,还有 Flink 落地应用的大型项目案例(PVUV、日志存储、百亿数据实时去重、监控告警)分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
Stars: ✭ 11,378 (+5920.11%)
Mutual labels:  stream-processing, flink
Flinkstreamsql
基于开源的flink,对其实时sql进行扩展;主要实现了流与维表的join,支持原生flink SQL所有的语法
Stars: ✭ 1,682 (+789.95%)
Mutual labels:  sql, flink
open-stream-processing-benchmark
This repository contains the code base for the Open Stream Processing Benchmark.
Stars: ✭ 37 (-80.42%)
Mutual labels:  stream-processing, flink
FlinkExperiments
Experiments with Apache Flink.
Stars: ✭ 3 (-98.41%)
Mutual labels:  stream-processing, flink
Sylph
Stream computing platform for bigdata
Stars: ✭ 362 (+91.53%)
Mutual labels:  sql, flink
Pipelinedb
High-performance time-series aggregation for PostgreSQL
Stars: ✭ 2,447 (+1194.71%)
Mutual labels:  sql, stream-processing
Kamu Cli
Next generation tool for decentralized exchange and transformation of semi-structured data
Stars: ✭ 69 (-63.49%)
Mutual labels:  sql, flink
Quicksql
A Flexible, Fast, Federated(3F) SQL Analysis Middleware for Multiple Data Sources
Stars: ✭ 1,821 (+863.49%)
Mutual labels:  sql, flink
Bats
面向 OLTP、OLAP、批处理、流处理场景的大一统 SQL 引擎
Stars: ✭ 152 (-19.58%)
Mutual labels:  sql, stream-processing
Krush
Idiomatic persistence layer for Kotlin
Stars: ✭ 185 (-2.12%)
Mutual labels:  sql
Leetcode Solutions
A compilation of all the Leetcode solutions.
Stars: ✭ 188 (-0.53%)
Mutual labels:  sql

Apache Flink SQL Cookbook

The Apache Flink SQL Cookbook is a curated collection of examples, patterns, and use cases of Apache Flink SQL. Many of the recipes are completely self-contained and can be run in Ververica Platform as is.

The cookbook is a living document. 🌱

Table of Contents

Foundations

  1. Creating Tables
  2. Inserting Into Tables
  3. Working with Temporary Tables
  4. Filtering Data
  5. Aggregating Data
  6. Sorting Tables
  7. Encapsulating Logic with (Temporary) Views
  8. Writing Results into Multiple Tables

Aggregations and Analytics

  1. Aggregating Time Series Data
  2. Watermarks
  3. Analyzing Sessions in Time Series Data
  4. Rolling Aggregations on Time Series Data
  5. Continuous Top-N
  6. Deduplication
  7. Chained (Event) Time Windows
  8. Detecting Patterns with MATCH_RECOGNIZE
  9. Maintaining Materialized Views with Change Data Capture (CDC) and Debezium

Other Built-in Functions & Operators

  1. Working with Dates and Timestamps
  2. Building the Union of Multiple Streams

User-Defined Functions (UDFs)

  1. Extending SQL with Python UDFs

Joins

  1. Regular Joins
  2. Interval Joins
  3. Temporal Table Join between a non-compacted and compacted Kafka Topic
  4. Lookup Joins
  5. Star Schema Denormalization (N-Way Join)
  6. Lateral Table Join

About Apache Flink

Apache Flink is an open source stream processing framework with powerful stream- and batch-processing capabilities.

Learn more about Flink at https://flink.apache.org/.

License

Copyright © 2020 Ververica GmbH

Distributed under Apache License, Version 2.0.

Note that the project description data, including the texts, logos, images, and/or trademarks, for each open source project belongs to its rightful owner. If you wish to add or remove any projects, please contact us at [email protected].