项目作者: 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
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.