63accc7962
This PR allows users to map a Kinesis `Record` to a generic `T` when creating a Kinesis stream. This is particularly useful, if you would like to do extra work with Kinesis metadata such as sequence number, and partition key. TODO: - [x] add tests Author: Burak Yavuz <brkyvz@gmail.com> Closes #8954 from brkyvz/kinesis-handler. |
||
---|---|---|
.. | ||
java8-tests | ||
kinesis-asl | ||
kinesis-asl-assembly | ||
spark-ganglia-lgpl | ||
README.md |
This directory contains build components not included by default in Spark's build.