Details
-
New Feature
-
Status: Resolved
-
Major
-
Resolution: Duplicate
-
None
-
None
Description
This jira will add two implicit method to Spark DStream
1. kuduForeachPartition
2. kuduMapPartitions
These method will act like the basic foreach/map partition but they will provide the developer a live client to interact with Kudu
These methods will be accessable from two different call points.
1. Scala DStream
2. KuduContext (which will work for Java)