#

apache-flink

Here are 140 public repositories matching this topic...

ververica / flink-cdc-connectors

Star

Open

[docs] Add FAQ about mysql server timezone in DataStream API

1

leonardBang commented Aug 27, 2021

User who use DataStream API should deal the timezone in their custom deserializer like RowDataDebeziumDeserializeSchema

Read more

docs good first issue

Open

[docs] Add FAQ that the tableList is using full path rather than table name in datastream API

Open

[build] Optimize the document scripts to push only if current PR modified docs

2

Find more good first issues →

nielsbasjes / yauaa

Star

Yet Another UserAgent Analyzer

java parse user-agent hive user-agent-parser analyzer pig apache-beam apache-flink udf flink nifi-processors apache-hive nifi-processor

Updated Aug 31, 2021
Java

GoogleCloudPlatform / flink-on-k8s-operator

Star

Open

Add a doc for integrating with Prometheus

3

functicons commented Feb 29, 2020

Related question GoogleCloudPlatform/flink-on-k8s-operator#114

Read more

documentation good first issue

ververica / flink-sql-cookbook

Star

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.

sql stream-processing apache-flink flink flink-sql

Updated Aug 24, 2021
Dockerfile

streamnative / pulsar-flink

Star

Elastic data processing with Apache Pulsar and Apache Flink

schema sql catalog schema-registry stream-processing pulsar apache-flink flink data-processing batch-processing flink-stream-processing apache-pulsar flink-connector

Updated Aug 27, 2021
Java

dbs-leipzig / gradoop

Star

Distributed Graph Analytics with Apache Flink

graph pattern-matching apache-flink property-graph distributed-graph-analytics graph-mining

Updated Aug 16, 2021
Java

FlinkML / flink-tensorflow

Star

flink-tensorflow - TensorFlow support for Apache Flink

tensorflow apache-flink

Updated Dec 16, 2017
Scala

TouK / nussknacker

Star

A tool that allows business experts to define and manage the logic of real-time decisions

gui real-time decision-making apache-flink flink flink-kafka touk marketers

Updated Aug 31, 2021
Scala

ottogroup / flink-spector

Star

Framework for Apache Flink unit tests

unit-testing streaming apache-flink flink

Updated Apr 28, 2019
Java

Chabane / bigdata-playground

Star

A complete example of a big data application using : Kubernetes (kops/aws), Apache Spark SQL/Streaming/MLib, Apache Flink, Scala, Python, Apache Kafka, Apache Hbase, Apache Parquet, Apache Avro, Apache Storm, Twitter Api, MongoDB, NodeJS, Angular, GraphQL

Updated Feb 1, 2019
TypeScript

ing-bank / flink-deployer

Star

A tool that help automate deployment to an Apache Flink cluster

go docker golang deployment apache-flink flink

Updated Jul 15, 2020
Go

odpf / dagger

Star

Open

Use odpf stencil client

1

prakharmathur82 commented Aug 13, 2021

Dagger currently uses com.gojek.stencil, which is now being deprecated. Change it to use 'io.odpf.stencil from here.

Read more

enhancement good first issue

Open

Log column names in case of Kafka and Influx sink

Open

Make HashTransformer use common SerDe

Find more good first issues →

apengda / fiflow

Star

flink-sql 在 flink 上运行 sql 和构建数据流的平台基于 apache flink 1.10.0

streaming sql apache-flink flink

Updated Jun 7, 2021
Java

FlinkML / flink-jpmml

Star

flink-jpmml is a fresh-made library for dynamic real time machine learning predictions built on top of PMML standard models and Apache Flink streaming engine

prediction apache-flink pmml model-serving flink-jpmml

Updated May 9, 2019
Scala

seznam / euphoria

Star

Euphoria is an open source Java API for creating unified big-data processing flows. It provides an engine independent programming model which can express both batch and stream transformations.

kafka big-data apache-spark hadoop hdfs java-api apache-flink batch-processing streaming-data unified-bigdata-processing

Updated Jun 7, 2021
Java

streamnative / awesome-pulsar

Star

A curated list of Pulsar tools, integrations and resources.

spark apache-spark messaging prometheus apache-storm apache-flink apache-kafka pub-sub grafana-dashboard spark-sql elastic-beats spark-structured-streaming apache-bookkeeper apache-pulsar

Updated Dec 29, 2020

knaufk / flink-faker

Star

A data generator source connector for Flink SQL based on java-faker.

apache-flink flink flink-sql ververica-platform

Updated Aug 4, 2021
Java

sanderploegsma / flink-k8s

Star

Example Apache Flink cluster on Kubernetes

kubernetes apache-flink

Updated Aug 22, 2018
Kotlin

ververica / jupyter-vvp

Star

Jupyter Integration for Flink SQL via Ververica Platform

jupyter apache-flink flink

Updated Jun 2, 2021
Python

hey-johnnypark / apache-flink-jdbc-streaming

Star

Sample project for Apache Flink with Streaming Engine and JDBC Sink

mysql protobuf jdbc apache apache-flink flink flink-stream-processing

Updated Apr 1, 2017
Java

raycad / stream-processing

Star

Stream processing guidelines and examples using Apache Flink and Apache Spark

streaming apache-spark data-analysis apache-flink batch-processing

Updated Sep 4, 2019
Java

brakmic / TwitterFlink

Star

A simple Twitter-Streaming Application for Apache Flink

scala jvm bigdata apache-flink

Updated Jan 27, 2016
Scala

aws-samples / amazon-kinesis-data-analytics-flink-starter-kit

Star

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.

apache-flink real-time-stream-processing amazon-kinesis-streams amazon-kinesis-data-analytics-flink

Updated Jun 10, 2021
Java

elbaulp / DPASF

Star

My MSc on Data Science final project. This is a library for Data Pre-processing Algorithms for Streaming in Flink (DPASF)

scala machine-learning-algorithms feature-selection feature-extraction apache-flink data-preprocessing flink discretization flink-ml

Updated Jul 1, 2019
Scala

kailanyue / SZ-Metro

Star

深圳地铁大数据客流分析系统

redis elasticsearch kibana scala kafka hbase zookeeper hdfs apache-flink flink

Updated Jan 20, 2021
Java

spotify / flink-on-k8s-operator

Star

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

kubernetes apache-beam apache-flink kubernetes-operator flink-operator

Updated Aug 31, 2021
Go

StarPlatinumStudio / Flink-SQL-Practice

Star

Flink SQL 实战 -中文博客专栏

sql stream-processing apache-flink big-data-processing

Updated Jan 14, 2020
Java

QuakeWang / FlinkTutorial

Star

Apache Flink学习笔记

Updated Mar 12, 2021
Java

O2-Czech-Republic / proxima-platform

Star

The Proxima platform.

apache-spark iot-platform apache-beam apache-flink batch-processing analytical-platform streaming-processing unified-data-processing

Updated Aug 31, 2021
Java

GMAP / DSPBench

Star

a suite of benchmark applications for distributed data stream processing systems

big-data apache-spark storm data-stream bigdata evaluation stream-processing spark-streaming apache-storm apache-flink experiments big-data-analytics

Updated Jul 19, 2021
Java

Improve this page

Add a description, image, and links to the apache-flink topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the apache-flink topic, visit your repo's landing page and select "manage topics."