项目作者: shaunmcglinchey

项目描述 :
TweetPipe Apache Flink AWS Kinesis Consumer. A Flink-based consumer that reads from an AWS Kinesis source and maps the input stream elements to a domain model. Future iterations will output the transformed data to a sink.
高级语言: Java
项目地址: git://github.com/shaunmcglinchey/tweetpipe-flink-kinesis-consumer.git


Tweetpipe Apache Flink Kinesis Consumer

Based on example code from the “Developing Stream Processing Applications with AWS Kinesis” course.

src - contains the source code of an Apache Flink-based Kinesis Consumer.