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