[SPARK-10891] Add MessageHandler to KinesisUtils.createStream similar to Direct Kafka

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.6.0
• Component/s: DStreams
• Target Version/s: 1.6.0
• Assignee: Burak Yavuz
• Reporter: Burak Yavuz
• Created: 30/Sep/15 23:06
• Updated: 26/Oct/15 04:19
• Resolved: 26/Oct/15 04:19

Description

There is support for message handler in Direct Kafka Stream, which allows arbitrary T to be the output of the stream instead of Array[Byte]. This is a very useful function, therefore should exist in Kinesis as well.

Issue Links

• links to: [Github] Pull Request #8954 (brkyvz)