Awesome Open Source

Programming Languages

Search results for java flink

323 search results found

A Spatial Extension of Apache Flink

Bigdata_learning ⭐ 16

大数据组件学习代码

Streambench ⭐ 15

Amazon Kinesis Data Analytics Flinktableapi ⭐ 15

A walkthrough of setting up a Kinesis Data Analytics for Java Application which ingest streaming JSON data and leverages the Flink Table API.

Flink Quickstart ⭐ 15

Flink Streaming SQL | FlinkCEP | Some demos and notes

Flinkalarmopssys ⭐ 15

This project used to monitoring log data stream, Manage alarm rules、alarm's threshold and frequency. based on Apache Flink、Spring Boot、Alibaba Nacos and JQuery.

Flink Connector Hbase ⭐ 15

小白大数据学习笔记 ⭐

Bigdataguider ⭐ 15

大数据学习笔记: 涉及hadoop,spark,hive,zookeeper等内容

Incubator Retired Mrql ⭐ 15

Mirror of Apache MRQL (Incubating)

Flink Operator Library ⭐ 14

Collection of generic Apache Flink operators

Java_l2_2020.02.20 ⭐ 14

java高薪训练营2020.02.20

Flink Kinesis Data Analytics Sample ⭐ 14

Flink KDA Sample Application

Flink Connector Opensearch ⭐ 14

Flink Examples ⭐ 14

Flink jobs collection

Flinkdemos ⭐ 13

flink应用相关实例

Websockets Vertx Flink Kafka ⭐ 13

A simple request response cycle using Websockets, Eclipse Vert-x server, Apache Kafka, Apache Flink.

Flink Platform Backend ⭐ 13

Define and schedule workflow, support Flink Jar/SQL, ClickHouse/Hive/Mysql SQL, Shell, etc.

Realtime Bushfire Alert With Apache Flink Cep ⭐ 13

Code and documentation for the demonstration example of the real-time bushfire alerting with the Complex Event Processing (CEP) in Apache Flink on Amazon EMR and a simulated IoT sensor network as described on the AWS Big Data Blog: Real-time bushfire alerting with Complex Event Processing in Apache Flink on Amazon EMR and IoT sensor network.

Amazon Managed Service For Apache Flink Examples ⭐ 13

Collection of code examples for Amazon Managed Service for Apache Flink

Aws Kinesisanalytics Flink Connectors ⭐ 12

This library contains various Apache Flink connectors to connect to AWS data sources and sinks.

Opensourceteams All ⭐ 12

所有项目汇总

Flink Stream Join ⭐ 12

Flink Big Query Connector ⭐ 11

Flink connector for BigQuery

Registry ⭐ 11

Schema Registry

Bigdataguide ⭐ 11

秋招自学上岸，自学太难了，想总结一份详细的大数据开发资料，包括基础 | 架构 | 源码，让更多自学的伙伴少走弯路。有相关问题可以添加公众号：大数据老刘，联系老刘！

Flink Connector Dynamodb ⭐ 11

Apache Flink connector sink for AWS DynamoDB

CEPTA - Complex Event Processing Transportation Analysis

Flink Connector Rabbitmq ⭐ 10

Ldbc Flink Import ⭐ 10

Loads LDBC social graph data into Flink DataSets

Flinkparquet ⭐ 10

Using the Parquet file format (with Avro) to process data with Apache Flink

Flink Sql Computing Platform ⭐ 10

It is a kind of big data computing platform which is driven by the Flink SQL. In particular, it provides the SQL programming.

Flink Tools ⭐ 10

A collection of Flink applications for working with Pravega streams

Isc4flink ⭐ 10

The ISC Anomaly Detection and Classification Framework implemented for Apache Flink.

Streaming Ledger ⭐ 10

Serializable ACID transactions on streaming data

Stream Processing Kickstarter ⭐ 10

A comparison of stream-processing frameworks with Kafka integration

Rocketmq Flink ⭐ 10

新增功能：实现指定offset定点位置启动

Iot Traffic Monitor Flink ⭐ 10

Monitoring Traffinal monitoring signal using Apache Flink

Interview ⭐ 9

Java Interview 知识点总结与面试

Demo Project opencv + Flink streaming

Flink Kafka Consumer ⭐ 9

Demonstrates how one can integrate kafka, flink and cassandra with spring data. Please check the producer module in conjuction with the consumer for completion.

Proteus Incremental Analytics ⭐ 9

💻 💻 proteus-backend is a backend module that implements incremental version (~O(1) computational cost using approximations) of most common analytics operations. 💹 💹

Proteus Engine ⭐ 9

Proteus engine contains an overhauled version of Apache Flink supporting hybrid computation on batch datasets and data streams. Please refer to wiki for further details.

Streaming Flink File Source ⭐ 9

File source operator for Apache Flink

Streaming_benchmark ⭐ 9

Hologres Flink Examples ⭐ 9

Quickstart examples that show how to use Flink with Hologres connector

Query Window Example ⭐ 9

Queryable Window Example

Flink Elasticsearch2 Connector ⭐ 9

ElasticSearchOutputFormat for Flink DataSet

Hbase Elasticsearch ⭐ 9

Efficiency of hbase concurrent writing, hbase synchronization to elasticsearch and elasticsearch concurrent querying.

Flink10_learn ⭐ 9

flink 10 自我学习笔记和代码

Flinksupport ⭐ 8

Flink应用程序开发支持框架

Reasearch Bigdata ⭐ 8

看书看源码看第三方学习视频

Flink Connector Redis ⭐ 8

flink connector for redis

Linklyze 分布式短链系统 URL Shortener

Iot Streaming ⭐ 8

IoT Streaming using Flink to connect Kafka and Cassandra, Elastic

Flink Community Tools ⭐ 8

Major_show ⭐ 8

使用SpringBoot+Mybatis-Plus+Thymeleaf+Redis等技术编写的一个展

Kappa Streaming ⭐ 8

Implementation of Kappa Architecture, using Vert.x reactive libraries and Apache Flink to process large file using stream and Kafka immutable append log. Data is stored finally in Cassandra DB.

Adaptive Watermarks ⭐ 8

An approach to apply concept drifts and ADWIN on streams event time to reason about the progress of watermarks

Flink Tutorial ⭐ 8

第四代大数据计算引擎Flink - 从入门到实战

Flink Kafka Influx Grafana Framework ⭐ 8

This application is an example of basic Flink-Kafka-InfluxDB workflow

Flink Fault Tolerant Stream Example ⭐ 8

An example of using Flink for Fault-Tolerant Stream Processing

Flink Cep Examples ⭐ 8

Apache Flink CEP examples

Apache Beam Example ⭐ 7

Apache Beam Example 中国开源社区

Flink Connector Cassandra ⭐ 7

Flink Sql Practice ⭐ 7

Flink SQL 实战 -中文博客专栏

Ml Pipelines ⭐ 7

This repo is hosting all common ML pipeline abstractions built on Apache Flink.

Kda Metrics Dashboard ⭐ 7

This repository contains a CloudFormation template that you can customize to deploy a sample metrics dashboard for your Kinesis Data Analytics for Apache Flink application.

Imcs Demo ⭐ 7

Demo for the In Memory Computing conference. Many thanks to Dinesh Pillai for his work

Flink Connector Oceanbase ⭐ 7

Apache Flink Connector for OceanBase.

Code Example ⭐ 7

Examples for Java, include: flink, kafka, kafka-stream, flink, bloom-filter, netty and so on

Bigdata Mind Map ⭐ 7

🌟 大数据知识脑图 🌟

Cypherimplementation ⭐ 7

An implementation of Cypher core clauses on Flink

Flinkmultistreamoptimization ⭐ 7

优化flink的多流操作（例如join），优化点不限于数据丢失问题，以及性能问题

Flink Streaming Kmeans ⭐ 7

Simple implementation of KMeans clustering on Flink, using iterations

Dl_java_stream ⭐ 7

How to use ONNX models on Flink streams.

Flink Acorn ⭐ 7

🐿️ 基于Spring对远程Flink服务二次封装，实现FlinkSql执行、Job状态查询以及获取运行日

Flink Testing Pyramid ⭐ 6

Example of a tested Apache Flink application.

Flink Cdc Connectors ⭐ 6

Change Data Capture (CDC) connectors for Apache Flink

Bigdata Analysis ⭐ 6

大数据收集，实时分析，离线分析经典案例

Northstar ⭐ 6

北极星数据管理中台

Streamline Platform ⭐ 6

This repository contains the Streamlin platform. It is a fork of Apache Flink featuring side input implementation, which enables hybrid computation between data-at-rest and data-in-motion.

Socstream ⭐ 6

Real-time visual analytics for soccer matches, leveraging Apache Flink, Apache Kafka and the Elastic stack. Solution to DEBS 2013 Grand Challenge. Coursework in Systems and Architectures for Big Data 2016/2017.

Flink Questdb Connector ⭐ 6

QuestDB ILP connector for Apache Flink

Flink2kafka ⭐ 6

A Flink applcation that demonstrates reading and writing to/from Apache Kafka with Apache Flink

Flink Cdc ⭐ 6

CDC（变化数据捕获）实时同步方案，秒级延迟。

Flink Recommended System ⭐ 6

Up Up Flink ⭐ 6

我学习Flink之路

Graphalytics Platforms Gelly ⭐ 6

Bigdata 30 Days ⭐ 6

零基础大数据学习笔记

Flink Kafka Consumer ⭐ 6

A consumer of a Kafka topic based on Flink

Osm Flink Tools ⭐ 6

Tools for helping integrate OSM data in hdfs using csv or avro files, using flink (implements PBF stream reading). This project reconstruct the relations for ways, polygons to be used in GIS Analysis

Msk_kda_example ⭐ 6

Flink Orc ⭐ 6

Adds ORC support to Flink Streaming File Sink

Flink Kafka Producer ⭐ 6

Demonstrates how one can integrate kafka, flink and cassandra with spring data. Please check the consumer module in conjuction with the producer for completion.

Wiki4wiki ⭐ 6

Detecting trending Wikipedia articles and identifying anomalous page requests of articles based on past behavior using flink, spark, kafka and redis

Flink Esper ⭐ 6

Esper on Apache Flink

Mangolaa Streams Processing Flink ⭐ 6

Stream processing for the Mangolaa platform using Apache Kafka, Apache Flink, Java 8 and Lombok

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)

201-300 of 323 search results

Privacy | About | Terms | Follow Us On Twitter

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