Closed Pkrish15 closed 5 years ago
Create UberRTAnalysis.scala and add code to::
a] read in the .json saved in Lab 2 b] create a consumer that listens to the UberRawData topic c] write a function to assign incoming record to a cluster id d] publish the enriched record on UberEnrichedData topic
Create UberRTAnalysis.scala and add code to::
a] read in the .json saved in Lab 2 b] create a consumer that listens to the UberRawData topic c] write a function to assign incoming record to a cluster id d] publish the enriched record on UberEnrichedData topic