Ecosyste.ms: Repos
An open API service providing repository metadata for many open source software ecosystems.
GitHub topics: flink-stream-processing
Bigsmooth68/flink-telecom-correlation
Apache Flink job to correlate telecom signaling messages for KPI extracted from streaming solutions
Size: 4.88 KB - Last synced: about 3 hours ago - Pushed: about 24 hours ago - Stars: 1 - Forks: 0
getindata/flink-http-connector
Http Connector for Apache Flink. Provides sources and sinks for Datastream , Table and SQL APIs.
Language: Java - Size: 533 KB - Last synced: 2 days ago - Pushed: 3 days ago - Stars: 126 - Forks: 36
suryadev99/stream_processing_website_click_data
Stream Processing of website click data using Kafka and monitored and visualised using Prometheus and Grafana
Language: Python - Size: 493 KB - Last synced: 4 days ago - Pushed: 4 days ago - Stars: 0 - Forks: 0
decodableco/examples
This repository will contain examples of use cases that utilize Decodable streaming solution
Language: Makefile - Size: 13.5 MB - Last synced: 7 days ago - Pushed: 7 days ago - Stars: 40 - Forks: 20
sparsecode/Streamy
Language: Scala - Size: 72.3 KB - Last synced: 14 days ago - Pushed: almost 5 years ago - Stars: 1 - Forks: 0
AditModi/streaming-analytics-workshop Fork of aws-samples/streaming-analytics-workshop
Learn how to build an end-to-end streaming architecture to ingest, analyze, and visualize streaming data in near real-time
Language: CSS - Size: 43.1 MB - Last synced: 14 days ago - Pushed: over 3 years ago - Stars: 0 - Forks: 0
philipgold/zday-kda-analytics-news-demo
Sample Apache Flink application that can be deployed to Kinesis Analytics for Java
Language: Java - Size: 21.5 KB - Last synced: 16 days ago - Pushed: almost 2 years ago - Stars: 0 - Forks: 0
hey-johnnypark/apache-flink-jdbc-streaming
Sample project for Apache Flink with Streaming Engine and JDBC Sink
Language: Java - Size: 5.86 KB - Last synced: 22 days ago - Pushed: about 7 years ago - Stars: 22 - Forks: 5
TU-Berlin-DIMA/scotty-window-processor
This repository provides Scotty, a framework for efficient window aggregations for out-of-order Stream Processing.
Language: Java - Size: 553 KB - Last synced: 29 days ago - Pushed: 8 months ago - Stars: 75 - Forks: 23
sdabhi23/kafka-data-pipeline
A streaming data pipeline uses Kafka as the backbone and Flink for data processing and transformations. Kafka Connect is used for writing the streams to S3 compatible blob stores and Redis (low latency KV store for real-time ML inference). Spark is used for the batch job to backfill the ml feature data.
Language: Python - Size: 159 KB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 0 - Forks: 0
elalfredoignacio/Real_time_ratings_monitoring
Arquitectura pipeline para streaming de tiempo real
Language: Jupyter Notebook - Size: 1.18 MB - Last synced: about 1 month ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0
nkonev/flink-pipe
A [single|uber|fat] jar standalone Apache Flink connected to PostgreSQL via Ververica CDC connector. Usage Flink SQL to replicate data from PostgreSQL to Elasticsearch/something else.
Language: Kotlin - Size: 77.1 KB - Last synced: 29 days ago - Pushed: 3 months ago - Stars: 1 - Forks: 0
ev2900/Flink_Kinesis_Data_Analytics
Apache Flink examples designed to be run by AWS Kinesis Data Analytics (KDA).
Language: Python - Size: 17.3 MB - Last synced: 29 days ago - Pushed: 5 months ago - Stars: 10 - Forks: 10
aws-samples/amazon-managed-service-for-apache-flink-examples
Collection of code examples for Amazon Managed Service for Apache Flink
Language: Java - Size: 16.1 MB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 16 - Forks: 6
innogames/flink-real-time-crm
Demo Flink and Kafka project to show how to react on tracking events in real-time and trigger offer for customer engagement based on campaign configurations. The project also utilizes the Broadcast State Pattern in order to update the rules (campaigns) at runtime without restarting the project, using a dedicated, low-frequency, Kafka topic.
Language: Java - Size: 1.21 MB - Last synced: about 1 month ago - Pushed: 3 months ago - Stars: 10 - Forks: 1
crate/cratedb-flink-jobs
This repository accompanies the article "Build a data ingestion pipeline using Kafka, Flink, and CrateDB" and the "CrateDB Community Day #2".
Language: Java - Size: 8.47 MB - Last synced: 2 months ago - Pushed: 2 months ago - Stars: 2 - Forks: 2
eBay/flink-kudu-streaming-connector
A flink source connector to provide the continuous, incremental and streaming events from Kudu tables
Language: Java - Size: 1.1 MB - Last synced: about 1 month ago - Pushed: 4 months ago - Stars: 7 - Forks: 5
streamnative/pulsar-flink 📦
Elastic data processing with Apache Pulsar and Apache Flink
Language: Java - Size: 2.16 MB - Last synced: 2 months ago - Pushed: over 1 year ago - Stars: 280 - Forks: 118
Stefen-Taime/Real-Time-Extraction-Transformation-and-Exposure-Architecture-for-Rail-Data
we are thrilled to announce our new PoC project aimed at providing a complete real-time extraction, transformation, and exposure architecture for the new provincial transportation systems.
Language: Python - Size: 87.9 KB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 0 - Forks: 0
SalmaHisham/Big-Data-Exploration
This repository contains my coursework projects for the Big Data course in my Master's degree program.
Language: Jupyter Notebook - Size: 19.9 MB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 0 - Forks: 0
skalskibukowa/Project-Kafka-Flink
Project to practice Python / Kafka / Flink
Language: Shell - Size: 17.6 KB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 0 - Forks: 0
luweizheng/flink-tutorials
Flink Tutorial Project
Language: Java - Size: 10.1 MB - Last synced: 3 months ago - Pushed: over 1 year ago - Stars: 175 - Forks: 55
BarriBarri20/flink-tuto
Health monitoring demo for checking glucose level of patients
Language: Java - Size: 1.08 MB - Last synced: 7 days ago - Pushed: 5 months ago - Stars: 2 - Forks: 1
pranav-patil/aws-kinesis-analytics
AWS Kinesis Analytics gather metrics from various computers (cpu, memory), perform aggregation on Kinesis stream data using Kinesis Analytics (with flink) and store the stream data into AWS S3 bucket which is used by Amazon Athena for running various Analytics queries and rending charts using Grafana.
Language: Java - Size: 1.29 MB - Last synced: 4 months ago - Pushed: 4 months ago - Stars: 0 - Forks: 0
dnosko/PDI
Project with Apache Flink for class Distributed Application Environment 2023
Language: Java - Size: 162 KB - Last synced: 4 months ago - Pushed: 5 months ago - Stars: 0 - Forks: 0
AhmetFurkanDEMIR/Flink-Example
Flink Example
Language: Scala - Size: 5.6 MB - Last synced: 7 days ago - Pushed: 6 months ago - Stars: 11 - Forks: 0
thomas-chauvet/predict-xgboost-flink
Use xgboost model to score data on Flink's datastream
Language: Scala - Size: 84 KB - Last synced: 5 months ago - Pushed: about 5 years ago - Stars: 6 - Forks: 2
microsoft/flink-on-azure
Examples of Flink on Azure
Language: Java - Size: 921 KB - Last synced: about 1 month ago - Pushed: 7 months ago - Stars: 45 - Forks: 8
sergio11/traffic_sentinel_architecture
🚀 Traffic Sentinel: A scalable IoT system using Fog nodes and Apache Flink to process 📷 IP camera streams, powered by YOLO for intelligent 🚗 traffic monitoring on highways. 🛣️
Language: Python - Size: 73.9 MB - Last synced: 5 months ago - Pushed: 5 months ago - Stars: 6 - Forks: 0
czy006/FlinkClub
这是我自己的Flink中文社区翻译稿存储仓库,用于提供给需要朋友进行二次创作。同时提供Flink一些课外的相关知识文档供大家学习
Size: 34.4 MB - Last synced: 5 months ago - Pushed: 5 months ago - Stars: 362 - Forks: 141
aws-samples/amazon-kinesis-data-analytics-flink-benchmarking-utility
Amazon Managed Service for Apache Flink Benchmarking Utility helps with capacity planning, integration testing, and benchmarking of Amazon Managed Service for Apache Flink applications.
Language: Java - Size: 281 KB - Last synced: 3 months ago - Pushed: 9 months ago - Stars: 18 - Forks: 5
innogames/flink-real-time-crm-ui
Demo UI for the flink-real-time-crm project using Spring Boot with Thymeleaf. The Demo UI is able to send messages to and consume from the related Kafka topics.
Language: Java - Size: 1.7 MB - Last synced: about 1 month ago - Pushed: 6 months ago - Stars: 2 - Forks: 0
crs4/Jeenk
Jeenk: scalable genomics tools, powered by Apache Flink
Language: Scala - Size: 489 KB - Last synced: 7 months ago - Pushed: 7 months ago - Stars: 3 - Forks: 2
tuancamtbtx/flink-streaming-example
Source code - Deploy Flink job by k8s operator
Language: Java - Size: 86.9 KB - Last synced: 8 months ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0
mfcardenas/ParraEProjectBD
Project EPBD
Language: Java - Size: 342 KB - Last synced: 8 months ago - Pushed: about 6 years ago - Stars: 0 - Forks: 0
aws-samples/amazon-managed-service-for-apache-flink-taxi-consumer
Sample Apache Flink application that can be deployed to Amazon Managed Service for Apache Flink. It reads taxi events from a Kinesis data stream, processes and aggregates them, and ingests the result to an Amazon OpenSearch Service cluster for visualization with Dashboard.
Language: Java - Size: 25.4 KB - Last synced: 8 months ago - Pushed: 8 months ago - Stars: 1 - Forks: 1
DataSystemsGroupUT/DISGD
A distributed shared-nothing variant of the incremental stochastic gradient descent algorithm
Language: Java - Size: 711 KB - Last synced: 9 months ago - Pushed: over 4 years ago - Stars: 1 - Forks: 0
triviadata/streaming-playground
Language: Java - Size: 101 KB - Last synced: 9 months ago - Pushed: almost 6 years ago - Stars: 1 - Forks: 0
ehabqadah/Spark_Streaming_vs_Flink
A Comparative Evaluation of Spark and Flink Stream Processing.
Language: Java - Size: 16.2 MB - Last synced: 9 months ago - Pushed: over 6 years ago - Stars: 5 - Forks: 1
aws-samples/amazon-kinesis-data-analytics-blueprints
Kinesis Data Analytics Blueprints are a curated collection of Apache Flink applications. Each blueprint will walk you through how to solve a practical problem related to stream processing using Apache Flink. These blueprints can be leveraged to create more complex applications to solve your business challenges in Apache Flink.
Language: TypeScript - Size: 73.6 MB - Last synced: 9 months ago - Pushed: 9 months ago - Stars: 17 - Forks: 5
jwsmai/ScalaTools
This project provides Apache Spark SQL, Flink DataStream API examples in Scala language
Language: Scala - Size: 3.19 MB - Last synced: 9 months ago - Pushed: 9 months ago - Stars: 0 - Forks: 0
anjijava16/ApacheFlink_Utils_Prv
Apache Flink Utils
Language: Java - Size: 2.19 MB - Last synced: 9 months ago - Pushed: over 1 year ago - Stars: 2 - Forks: 2
CodeLionX/FastFlinkStreams
A Flink demo project using Scala and SBT that analyzes HTTP log data from NASA.
Language: Scala - Size: 23.4 KB - Last synced: 9 months ago - Pushed: over 5 years ago - Stars: 0 - Forks: 0
fediazgon/flink-vehicle-telematics
Stream processing of simulated on-vehicle sensors data
Language: Java - Size: 1.2 MB - Last synced: 10 months ago - Pushed: almost 5 years ago - Stars: 6 - Forks: 2
arkady-emelyanov/toy-data-platform
Toy data platform for a company that provides web analytics
Language: HCL - Size: 485 KB - Last synced: 10 months ago - Pushed: about 3 years ago - Stars: 5 - Forks: 0
tj---/iceberg-demo
A sample implementation of stream writes to an Iceberg table on GCS using Flink and reading it using Trino
Language: Java - Size: 13.7 KB - Last synced: 10 months ago - Pushed: almost 2 years ago - Stars: 8 - Forks: 3
BrooksIan/Flink2Kafka
A Flink applcation that demonstrates reading and writing to/from Apache Kafka with Apache Flink
Language: Java - Size: 2.98 MB - Last synced: 10 months ago - Pushed: almost 4 years ago - Stars: 18 - Forks: 6
Bosmansc/thesis_stockTrading
Language: Scala - Size: 1.85 MB - Last synced: 10 months ago - Pushed: almost 6 years ago - Stars: 0 - Forks: 0
Anant/Cassandra.Realtime
Different ways to process data into Cassandra in realtime with technologies such as Kafka, Spark, Akka, Flink
Language: Scala - Size: 575 MB - Last synced: 21 days ago - Pushed: almost 2 years ago - Stars: 29 - Forks: 24
CristianAbrante/FlinkPredictionProject
Flink introductory project for the subject cloud computing of the EIT Digital Master's degree in Data Science and innovation at UPM
Language: Java - Size: 27.3 KB - Last synced: 28 days ago - Pushed: over 3 years ago - Stars: 2 - Forks: 0
galgus/flink-connector-http
Flink HTTP Sink Connector
Language: Java - Size: 10.7 KB - Last synced: 4 months ago - Pushed: about 3 years ago - Stars: 10 - Forks: 9
atullal/flink-placement
Developing a cost model and modifying the Apache Flink scheduler to efficiently offload tasks to edge systems, ultimately improving latency problems over the WAN.
Language: Java - Size: 22.4 MB - Last synced: 12 months ago - Pushed: 12 months ago - Stars: 0 - Forks: 0
sygnowski/flink-todo-app
Todo List as Flink statefult job. Create, Add, Remove Todo Items via REST interface and keep everithing as Flink State.
Language: Java - Size: 102 KB - Last synced: 6 months ago - Pushed: 6 months ago - Stars: 1 - Forks: 1
mikeroyal/Apache-Beam-Guide
Apache Beam Guide
Size: 170 KB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 3 - Forks: 1
riferrei/is-using-kop-a-good-idea
Is using KoP (Kafka-On-Pulsar) a good idea? Use the scenarios implemented in this repository to check whether Pulsar with KoP enabled is a good fit for your most common Kafka workloads.
Language: Java - Size: 898 KB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 6 - Forks: 2
mikeroyal/Apache-Flink-Guide
Apache Flink Guide
Size: 171 KB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 16 - Forks: 4
zlzhang0122/flink-in-action
基于Flink的批流处理实战案例
Language: Java - Size: 8.02 MB - Last synced: about 1 year ago - Pushed: almost 2 years ago - Stars: 35 - Forks: 15
cjermain/flink-onnx-pytorch
Streaming machine learning using PyTorch, Flink, and ONNX
Language: Scala - Size: 33.2 KB - Last synced: about 1 year ago - Pushed: almost 3 years ago - Stars: 19 - Forks: 7
keshavksingh/flink-streaming-project
Flink Tutorial
Language: Scala - Size: 5.75 MB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0
mickey0524/flink-streaming-source-analysis
flink 流处理源码分析
Language: Java - Size: 4.58 MB - Last synced: about 1 year ago - Pushed: over 4 years ago - Stars: 49 - Forks: 18
tonvanbart/flink-mqtt
Simple Flink job with MQTT sink function
Language: Scala - Size: 39.1 KB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 2 - Forks: 0
haxxorsid/flink-datalake-bulk-upload 📦
Bulk image streaming and upload using Flink (+ Kubernetes), Kafka, Data Lake, and SQL (Provided with React UI and Node server for Demo).
Language: Java - Size: 417 KB - Last synced: about 1 year ago - Pushed: about 2 years ago - Stars: 1 - Forks: 0
dyrnq/cdc-vagrant
CDC(Change Data Capture) is made up of two components, the CDD and the CDT. CDD is stand for Change Data Detection and CDT is stand for Change Data Transfer.
Language: Shell - Size: 73.2 KB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0
zBrainiac/StreamAnalytics
Language: Java - Size: 2.94 MB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 3 - Forks: 2
librity/rtjvm_flink
Rock The JVM - Apache Flink with Scala
Language: Scala - Size: 17.6 MB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0
yahah100/flink_streaming_twitter
Twitter Flink Streaming data project
Language: Java - Size: 44.2 MB - Last synced: about 1 year ago - Pushed: almost 2 years ago - Stars: 1 - Forks: 0
ankushs92/apache-flink-aggregations-clickstreams
Count clicks in an unbounded clickstream over a Time window using Apache Flink's DataStream API
Language: Java - Size: 27.3 KB - Last synced: about 1 year ago - Pushed: about 6 years ago - Stars: 5 - Forks: 4
e3oroush/flink-tutorial
A simple introduction to Apache/Flink CEP. Working with time window aggregation and simple match expression.
Language: Java - Size: 16.6 KB - Last synced: about 1 year ago - Pushed: almost 5 years ago - Stars: 3 - Forks: 0
mainakchhari/apache-flink-quickstart
Starter templates for getting started with Apache Flink ( java-based stream processing library)
Language: Java - Size: 1.95 KB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0
montevideolabs-org/flink-kafka-real-time-pipeline
Pipeline components for real time data processing. Consists on a Flink module written on Scala.
Language: Scala - Size: 2.93 KB - Last synced: 8 months ago - Pushed: almost 2 years ago - Stars: 1 - Forks: 0
mojeskamlapure/streaming-application-examples
An ETL project that consumes data from distributed message queue such as kafka and transform the data using flink stand alone job which in-turn stores data to the nosql database such as Cassandra distributed database.
Language: Java - Size: 269 KB - Last synced: about 1 year ago - Pushed: almost 2 years ago - Stars: 0 - Forks: 0
appuv/KafkaTemperatureAnalyticsFlink
Temperature Analytics using Kafka and Flink
Language: Java - Size: 173 KB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 0 - Forks: 1
jwsmai/flink-java
learn flink with java
Language: Java - Size: 8.79 KB - Last synced: 11 months ago - Pushed: almost 2 years ago - Stars: 0 - Forks: 0
mk-hasan/Flink-Kuberenets
Run Flink program with kubernets
Language: Java - Size: 12.7 KB - Last synced: about 1 year ago - Pushed: over 3 years ago - Stars: 2 - Forks: 0
snigdhasambitak/flink-app-example
simple flink app and kubernetes deployment configurations
Language: Java - Size: 12.7 KB - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 1 - Forks: 0
MetaArivu/Kinesis-Quickstart
AWS Kinesis: Data Streams | Data Firehose | Data Analytics
Language: Java - Size: 40.9 MB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 3 - Forks: 3
wuzguo/hadoop-study
hadoop study project
Language: Scala - Size: 28.4 MB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 3 - Forks: 0
charleswu52/UserBehaviorAnalysis
E-commerce user behavior analysis system based on Flink.
Language: Java - Size: 5.61 MB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 0 - Forks: 0
mehmetozanguven/flink_examples
Includes examples for Apache Flink
Language: Java - Size: 52.7 KB - Last synced: about 1 year ago - Pushed: about 4 years ago - Stars: 1 - Forks: 0
froblesmartin/BachFinalProject
Project to compare Apache Spark Streaming vs Apache Flink.
Language: Java - Size: 42 KB - Last synced: about 1 year ago - Pushed: almost 3 years ago - Stars: 1 - Forks: 1
marlesson/simple_weblog_analysis_flink
Simple example for access count in Apache logs using Apache Flink
Language: Python - Size: 28.3 KB - Last synced: about 1 year ago - Pushed: over 6 years ago - Stars: 3 - Forks: 2
mdesilva/debs-2020
Detect and output energy consumption events by analyzing an unbounded stream of voltage and current data
Language: Java - Size: 7.7 MB - Last synced: about 1 year ago - Pushed: about 4 years ago - Stars: 0 - Forks: 0
raymondtay/tube
Apache Flink Data Pipelines for processing Slack data
Language: Scala - Size: 925 KB - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 2 - Forks: 0
nagyf/coinbase-kafka-flink-streaming
This is an example application that streams real-time market data from Coinbase, and uses Apache Flink to process the stream
Language: Java - Size: 6.84 KB - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 0 - Forks: 0
Adsizzlerlabs/mangolaa-streams-processing-flink
Stream processing for the Mangolaa platform using Apache Kafka, Apache Flink, Java 8 and Lombok
Language: Java - Size: 55.7 KB - Last synced: about 1 year ago - Pushed: about 6 years ago - Stars: 7 - Forks: 3
AzarguNazari/FlinkStreaming
A sample of Flink Streaming in Java
Language: Java - Size: 61.5 KB - Last synced: about 1 year ago - Pushed: almost 4 years ago - Stars: 0 - Forks: 1
jjanczur/CloudComputing-assignment4
TU Berlin Cloud Computing - correctly implemented assignment4
Language: Java - Size: 5.73 MB - Last synced: about 1 year ago - Pushed: about 4 years ago - Stars: 0 - Forks: 0
HungUnicorn/flink-test-udf-example
show how to test flink udf including stateful and stateless
Language: Java - Size: 28.3 KB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0
galgus/flink-connector-rabbitmq
Flink rabbitmq source connector
Language: Java - Size: 8.79 KB - Last synced: about 1 year ago - Pushed: over 4 years ago - Stars: 0 - Forks: 0
isaias/data-engineering
Stream processing
Size: 13.7 KB - Last synced: about 1 year ago - Pushed: over 4 years ago - Stars: 0 - Forks: 0
himansh-23/ApacheFlinkDemo
A Flink Project for Practice
Language: Java - Size: 17.6 KB - Last synced: 11 months ago - Pushed: about 5 years ago - Stars: 0 - Forks: 0
mgoblin/streaming_examples
Language: Scala - Size: 77.1 KB - Last synced: about 1 year ago - Pushed: about 6 years ago - Stars: 1 - Forks: 1
ale93p/g5k-flink-cluster
Automated deployment of an Apache Flink cluster in your Grid'5000 reserved nodes.
Language: Python - Size: 6.84 KB - Last synced: 11 months ago - Pushed: about 5 years ago - Stars: 0 - Forks: 2
user3301/flink_automobile_monitor Fork of DataseekCN/flink_automobile_monitor
:car:使用flink流式计算框架监控以及计算电动车辆行驶以及充电指标的计算引擎
Language: Java - Size: 8.52 MB - Last synced: about 1 year ago - Pushed: over 5 years ago - Stars: 0 - Forks: 0
mgoblin/streams
Pet project to grow Apache Flink skills
Language: Scala - Size: 102 KB - Last synced: about 1 year ago - Pushed: about 6 years ago - Stars: 1 - Forks: 0
shankarganesh1234/DistributedProcessing
Simple example of using Apache Flink to perform stream processing
Language: Java - Size: 19.5 KB - Last synced: about 1 year ago - Pushed: about 6 years ago - Stars: 0 - Forks: 1
HungUnicorn/flink-UDF
Some functions for using flink
Language: Java - Size: 10.7 KB - Last synced: about 1 year ago - Pushed: over 6 years ago - Stars: 0 - Forks: 0