Ecosyste.ms: Repos

An open API service providing repository metadata for many open source software ecosystems.

GitHub topics: kinesis-data-analytics

jaehyeon-kim/flink-demos

Apache Flink (Pyflink) and Related Projects

Language: Python - Size: 2.18 MB - Last synced: 6 months ago - Pushed: 6 months ago - Stars: 7 - Forks: 1

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

aws-samples/kinesis-data-analytics-flink-aurora-sink

Showcases how to use Apache Flink on Kinesis Data Analytics to write to Amazon Aurora

Language: Java - Size: 10.7 KB - Last synced: 9 months ago - Pushed: 9 months ago - Stars: 5 - Forks: 4

aws-samples/kinesis-data-analytics-apache-flink-async-io

Showcases the AsyncIO Functionality within Apache Flink for Kinesis Data Analytics

Language: Java - Size: 210 KB - Last synced: 9 months ago - Pushed: 9 months ago - Stars: 5 - Forks: 3

aws-samples/kda-metrics-dashboard

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.

Language: Java - Size: 237 KB - Last synced: 9 months ago - Pushed: 9 months ago - Stars: 7 - Forks: 3

aws-samples/amazon-kinesis-data-analytics-apache-flink-server-sent-events-sse

When dealing with real-time data it is often required to send that data over the internet to various sources. Various technologies have enabled this such as web sockets and long polling. Recently server-sent events (SSE) has become a popular technology to push updates to clients. Ingesting this type of data source into AWS requires a client to be running continuously to receive those events. This sample shows how to connect to an SSE endpoint using an Amazon Kinesis Data Analytics application using Apache Flink. As the events arrive they are published to an Amazon Kinesis Data Streams stream then in this sample we simply store the event data in Amazon S3.

Language: Java - Size: 104 KB - Last synced: 9 months ago - Pushed: 9 months ago - Stars: 3 - 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

aws-samples/amazon-kinesis-data-analytics-snapshot-manager-for-flink

Snapshot manager for Amazon Kinesis Data Analytics for Apache Flink helps the users to generate a snapshot on a periodic basis.

Language: Python - Size: 321 KB - Last synced: 9 months ago - Pushed: 9 months ago - Stars: 14 - Forks: 6

build-on-aws/real-time-analytics-with-flink-sql

Sample code repository that contains the sample data set files and Zeppelin notes to run analytical queries with SQL.

Size: 15.6 KB - Last synced: 11 months ago - Pushed: 11 months ago - Stars: 0 - Forks: 0

aws-samples/sagemaker-feature-store-real-time-recommendations

Build a real-time recommendation engine for an e-commerce website leveraging SageMaker Feature Store as a core component of the solution.

Language: Jupyter Notebook - Size: 3.03 MB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 20 - Forks: 3

aws-samples/automate-deployment-and-version-update-of-kda-application

Automate deployment and version updates for Amazon Kinesis Data Analytics applications with AWS CodePipeline

Language: TypeScript - Size: 564 KB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 0 - Forks: 2

iarjunsk/flink-kinesis-data-analytics-sample

Flink KDA Sample Application

Language: Java - Size: 21.5 MB - Last synced: about 2 months ago - Pushed: about 3 years ago - Stars: 14 - Forks: 3

TechPrimers/eks-kinesis-example

Stream Processing Example using Spring Boot, Spring Cloud Stream, EKS, Kinesis Data Streams, Kinesis Data Analytics

Language: Java - Size: 232 KB - Last synced: over 1 year ago - Pushed: over 3 years ago - Stars: 9 - Forks: 7

aws-samples/efo-ltr-flink-sample

Sample showcasing the use of FlinkKinesisConsumer with EFO support

Language: Java - Size: 14.6 KB - Last synced: about 1 year ago - Pushed: over 3 years ago - Stars: 1 - Forks: 2