#
apache-flink
Here are 144 public repositories matching this topic...
functicons
commented
Feb 29, 2020
Related question GoogleCloudPlatform/flink-on-k8s-operator#114
Yet Another UserAgent Analyzer
java
parse
user-agent
hive
snowplow
user-agent-parser
snowflake
analyzer
pig
apache-beam
apache-flink
udf
flink
nifi-processors
snowplowanalytics
apache-hive
nifi-processor
-
Updated
Nov 15, 2021 - Java
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.
-
Updated
Nov 2, 2021 - Dockerfile
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
Nov 15, 2021 - Java
A visual tool to define and run real-time decision algorithms. Brings agility to business teams, liberates developers to focus on technology.
-
Updated
Nov 15, 2021 - Scala
Distributed Graph Analytics with Apache Flink
-
Updated
Nov 14, 2021 - Java
flink-tensorflow - TensorFlow support for Apache Flink
-
Updated
Dec 16, 2017 - Scala
Framework for Apache Flink unit tests
-
Updated
Apr 28, 2019 - Java
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
nodejs
python
graphql
docker
machine-learning
angular
scala
kafka
big-data
apache-spark
mongodb
hadoop
avro
twitter-api
hbase
spark-streaming
parquet
apache-flink
kops
spark-sql
-
Updated
Feb 1, 2019 - TypeScript
prakharmathur82
commented
Aug 13, 2021
Currently, both Kafka and Influx sink logs only the data(Row) that is being sent.
Add support for logging column names as well along with data points similar to the implementation in log sink.
This will enable users to correlate the data points with column names.
A tool that help automate deployment to an Apache Flink cluster
-
Updated
Jul 15, 2020 - Go
flink-sql 在 flink 上运行 sql 和 构建数据流的平台 基于 apache flink 1.10.0
-
Updated
Jun 7, 2021 - Java
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
-
Updated
May 9, 2019 - Scala
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
A data generator source connector for Flink SQL based on java-faker.
-
Updated
Nov 15, 2021 - Java
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
Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.
-
Updated
Nov 8, 2021 - Go
Jupyter Integration for Flink SQL via Ververica Platform
-
Updated
Jun 2, 2021 - Python
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.
-
Updated
Jun 10, 2021 - Java
Sample project for Apache Flink with Streaming Engine and JDBC Sink
-
Updated
Apr 1, 2017 - Java
Stream processing guidelines and examples using Apache Flink and Apache Spark
-
Updated
Sep 4, 2019 - Java
A simple Twitter-Streaming Application for Apache Flink
-
Updated
Jan 27, 2016 - Scala
深圳地铁大数据客流分析系统
-
Updated
Jan 20, 2021 - Java
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
Flink SQL 实战 -中文博客专栏
-
Updated
Jan 14, 2020 - Java
The Proxima platform.
apache-spark
iot-platform
apache-beam
apache-flink
batch-processing
analytical-platform
streaming-processing
unified-data-processing
-
Updated
Nov 15, 2021 - Java
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
Nov 12, 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.
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."
User who use DataStream API should deal the timezone in their custom
deserializerlikeRowDataDebeziumDeserializeSchema