Awesome Open Source

Programming Languages

Search results for java flink

323 search results found

Amazon Kinesis Analytics Taxi Consumer ⭐ 85

Sample Apache Flink application that can be deployed to Kinesis Analytics for Java. It reads taxi events from a Kinesis data stream, processes and aggregates them, and ingests the result to an Amazon Elasticsearch Service cluster for visualization with Kibana.

The Immerok Apache Flink Cookbook is a collection of examples of Apache Flink applications in the format of "recipes". Each recipe explains how you can solve a specific problem by leveraging one or more of the APIs of Apache Flink. The recipes can be extended or provide a basis for solving your requirements with Apache Flink.

Flink Prometheus Example ⭐ 85

Example setup to demonstrate Prometheus integration of Apache Flink

Flink Dataflow ⭐ 83

Google Dataflow Runner for Apache Flink™ (deprecated; please use the up-to-date Beam Runner)

Advanced Books ⭐ 83

Java 核心技术,并发设计模式，数据结构与算法，SpringBoot ,OAuth2.0源码分析，Mysql进阶篇,Git 高级操作，Netty 教程，Redis设计与实战,Flink入门教程，Kafka入门与架构分析,Linux入门与Shell Keetle，ElasticSearch 希望更多的小伙伴一起加入共同维护，持续更新中！

Flink Connector Kafka ⭐ 80

Flink Connector Jdbc ⭐ 77

Flink Sql Security ⭐ 76

FlinkSQL数据脱敏和行级权限解决方案及源码，支持面向用户级别的数据脱敏和行级数据访问控制，即特 Ranger中的Row-level Filter和Column Masking方案。

本项目已废弃，笔记收藏整理参考：

Scotty Window Processor ⭐ 71

This repository provides Scotty, a framework for efficient window aggregations for out-of-order Stream Processing.

Real-time ETL developed by Flink, data from MySQL to Greenplum. Use canal to parse the MySQL binlog, put it into kafka, use Flink to consume kafka and assemble the data into Greenplum, and more data sources and target sources will be added in the future.

Hoptimator ⭐ 68

Multi-hop declarative data pipelines

Flink Stream Processing Refarch ⭐ 66

Reference architecture for real-time stream processing with Apache Flink on Amazon EMR, Amazon Kinesis, and Amazon Elasticsearch Service.

Mastering Flink ⭐ 64

Code repository for the book - Mastering Flink by Tanmay Deshpande

Amazon Kinesis Analytics Streaming Etl ⭐ 62

Streaming ETL with Apache Flink and Amazon Kinesis Data Analytics

Utilities for processing Flink checkpoints/savepoints

Flink Connector Elasticsearch ⭐ 59

Apache Flink connector for ElasticSearch

A temporary home for LinkedIn's changes to Apache Iceberg (incubating)

Pravega Samples ⭐ 53

Sample Applications for Pravega.

Cascading Flink ⭐ 52

Cascading on Apache Flink®

Abstract Operator ⭐ 49

Library/SDK for creating the operators for Kubernetes and Openshift.

Mongo Flink ⭐ 48

A MongoDB connector for Apache Flink prior to 1.16. For Flink 1.16+, please use the official MongoDB connector.

Flink Kudu ⭐ 48

Java library to integrate Flink and Kudu

Nebula Flink Connector ⭐ 45

Flink Connector for Nebula Graph

Flink Sql Client ⭐ 45

基于flink1.9.1,flink-sql-client模块SDK单独实现，支持Yarn集群的远程 sql任务的远程化执行

Flink On Azure ⭐ 44

Examples of Flink on Azure

Learnbasicbigdatatech ⭐ 44

🚀Some projects on Big Data Analysis like Spark, Hive, Presto and Data Visualization like Superset

Infoworld Post ⭐ 43

Code examples for a blog post on infoworld.com

Amazon Kinesis Data Analytics Flink Starter Kit ⭐ 42

Amazon Kinesis Data Analytics Flink Starter Kit helps you with the development of Flink Application with Kinesis Stream as a source and Amazon S3 as a sink. This demonstrates the use of Session Window with AggregateFunction.

Flink Demo ⭐ 41

Flink Client ⭐ 41

Java library for managing Apache Flink via the Monitoring REST API

Flink Connector Kudu ⭐ 40

基于Apache-bahir-kudu-connector的flink-connector-kudu DynamicTableSource/Sink，支持Range分区等

Nifi Streaming Examples ⭐ 40

Collection of examples integrating NiFi with stream process frameworks.

Flink Training Troubleshooting ⭐ 40

Garmadon ⭐ 39

Java event logs collector for hadoop and frameworks

Code from an Apache Flink™ talk I regularly give

Tweetmap ⭐ 39

A real time Tweet Trend Map and Sentiment Analysis web application with kafka, Angular, Spring Boot, Flink, Elasticsearch, Kibana, Docker and Kubernetes deployed on the cloud

Data Ingestion Platform ⭐ 39

Flink Book ⭐ 38

大数据，流计算，实时计算，Flink框架学习资料。畅销书籍《深入理解Flink核心设计与实践原理》随书代码,书中讲解的Flink特性均有完整可运行的代码供读者运行和测试。整个工程共有【182个Jav

Datasphere Integration ⭐ 38

an data-centric integration platform

Bigdata_code_tutorial ⭐ 37

Flink cdc 整库同步 & flink 代码 demo

Bigdata Getting Started ⭐ 37

大数据相关框架实战项目(Hadoop, Spark, Storm, Flink)

Java_l2_2020.04.20 ⭐ 37

java高薪训练营2020.04.20

Iteratorx ⭐ 37

Flinksql Remote Submit ⭐ 36

Flink Connector Pulsar ⭐ 36

Litemall Dw ⭐ 36

基于开源Litemall电商项目的大数据项目，包含前端埋点(openresty+lua)、后端埋点；

Flinkproj ⭐ 36

Flink 案例开发数据清洗、数据报表

Flink Connector Aws ⭐ 35

Flink Crawler ⭐ 35

Continuous scalable web crawler built on top of Flink and crawler-commons

Bullet Core ⭐ 34

Bullet is a streaming query engine that can be plugged into any singular data stream using a Stream Processing framework like Apache Storm, Spark or Flink.

Theodolite ⭐ 33

Theodolite is a framework for benchmarking the horizontal and vertical scalability of cloud-native applications.

Flink Streaming Spring Boot ⭐ 31

Spring Boot app which executes a remote Flink job.

Flinkinaction ⭐ 29

Source code for Flink in Action

Df_data_service ⭐ 29

DataFibers Data Service

Rzf.github.io ⭐ 27

✏️[计算机基础+java基础+大数据基础及进阶+面试指南] 一份涵盖计算机基础，java，大数据，面试宝典，大部分核心知识的项目，学习，面试，共同进步！

Flink Connector Mongodb ⭐ 27

Flink Perf ⭐ 27

Flink performance tests

Mastering Apache Flink ⭐ 27

Code files uploaded by Packt publishing

Review Notes ⭐ 27

团队分享学习、复盘笔记资料共享。Java、Scala、Flink...

Explore Flink ⭐ 27

This project uses Apache Flink as a stream engine that consumes data from the File system or Kafka brokers and exposes metrics using Prometheus and Grafana, everything deployed on Kubernetes (minikube).

Kafka Spark Flink Example ⭐ 26

Kafka streaming with Spark and Flink example

Kafka Flink 101 ⭐ 26

Simple Flink + Kafka application

Parquet Flinktacular ⭐ 26

How to use Parquet in Flink

Flink Streaming Source Analysis ⭐ 25

flink 流处理源码分析

Scalable Batch and Stream Data Processing

Flink Mongodb Test ⭐ 25

Flink 0.7 MongoDB example (for Hadoop2)

Flink In Action ⭐ 24

基于Flink的批流处理实战案例

Lab Fraud Detection ⭐ 24

Demo code for implementing and showcasing a Fraud Detection Engine with Apache Flink.

Springboot、SpringCloud、Nacos、JdbcTemplate、restTemp 、Jxls、Redisson、SpEL、Kettle、Skywalking、flyway、testn

Kafkaflinkelastic ⭐ 23

Streaming using Flink to connect Kafka and Elasticsearch

Flink code for TPC-DS competition，forked from Apache Flink，and cherry pick some new feature.

Video Samples ⭐ 23

Obsolete - see https://github.com/pravega/gstreamer-pravega

Java_l2_2020.05.21 ⭐ 22

java高薪训练营2020.05.21

Jaeger Analytics Flink ⭐ 21

Big data analytics for Jaeger using Apache Flink

Readandlearn ⭐ 21

Flink Queryable_state_demo ⭐ 21

Demo quering counts of a event stream with Apache Flink

Flink Neo4j ⭐ 21

Read Cypher query results into Apache Flink and write datasets to Neo4j using Cypher batches.

Streamkv ⭐ 21

A streaming key-value store implementation using native Flink Streaming operators

Terasort ⭐ 20

TeraSort for Spark and Flink which uses a range partitioner based on sampling

Sharedstreets Builder ⭐ 20

Making maps connectable: stable, non-proprietary IDs and data standards for streets

Temporal_graph_library ⭐ 20

Temporal_Graph_library

A free Open Source Tweet Map

Eskimo is a state of the art Big Data Infrastructure and Management Web Console to build, manage and operate Big Data 2.0 Analytics clusters on Kubernetes. This is the git repository of Eskimo Community Edition.

Flink Cep Dsl ⭐ 19

A simple pattern language for Apache Flink, inspired by Esper

Flink Sql Submit Client ⭐ 19

执行Flink SQL 文件的客户端

Flink Kafka Hbase ⭐ 19

功能：实现kafka消息实时落地hbase，支持csv/json字符串两种格式的消息，支持自定义组合支持at least once语义外部依赖：apollo配置中心，本项目依靠配置驱动，配置存储在apollo配置中心

Amazon Kinesis Connector Flink ⭐ 18

This is a fork of the Apache Flink Kinesis connector adding Enhanced Fanout support for Flink 1.8/1.11 on KDA.

Boontadata Streams ⭐ 18

compare stream processing engines in terms of code, features, and performances

Bigdata Book ⭐ 18

上百本大数据电子书，附带下载链接，包括计算机基础，Java，hadoop，spark，flink，k

Clickhouse Highlevel Sinker ⭐ 18

clickhouse-highlevel-sinker

Java_l2_2020.03.24 ⭐ 18

java高薪训练营2020.03.24

Realtime Dashboard Example ⭐ 18

This is a real-time dashboard example using Spark Streaming and Node.js

Flink Learning Note ⭐ 18

Flink 流式计算框架学习笔记✨

Qs Hadoop ⭐ 17

大数据生态圈学习

Streamers ⭐ 16

A realtime data streaming application to access, aggregate and format events

Flink Modelserver ⭐ 16

Generic Model Serving Implementation leveraging Flink

Amazon Kinesis Data Analytics Flink Benchmarking Utility ⭐ 16

Amazon Kinesis Data Analytics Flink Benchmarking Utility helps with capacity planning, integration testing, and benchmarking of Kinesis Data Analytics for Apache Flink applications.

Lab Flink Repository Analytics ⭐ 16

Filteringexample ⭐ 16

Flink stream filtering examples

Related Searches

Java Spring (21,350)

Java Spring Boot (11,982)

Java Jar (7,910)

Java Docker (6,180)

Java Database (6,015)

Java Mysql (5,954)

Java Testing (5,814)

Javascript Java (5,468)

Java Apache (4,283)

Java Cloud Computing (4,240)

101-200 of 323 search results

Privacy | About | Terms | Follow Us On Twitter

Copyright 2018-2024 Awesome Open Source. All rights reserved.