Update application parameters

We will now update the application in Kinesis Data Analytics to start counting trips per borough by updating the configuration. This shows how we can use Beam to count trips that cumulates by this new metric.

The Beam Java class that does is PartitionByBorough.java.

  1. Go back to the Kinesis Data Analytics application and update the configuration. Select Confiuration and Scroll down to the Properties section you created earlier. Select Edit group for the group BeamApplicationProperties.

Update the property OutputBoroughs to true. Select update and wait a few minutes for the operator graph to update.

kda-updateborough

  1. Go back to the CloudWatch dashboard, and hit refresh in top right. In the bottom graph you should start seeing trips that are counted per borough, similar to this. It appears for this data set the borough of Manhattan has the most trips!

cw-dashboard-trips-by-borough