September 2017
Beginner to intermediate
360 pages
8h 13m
English
We need to add the static value of the vehicle along with the user's phone number into Hazelcast so that, while processing the event, Storm will be able to calculate the distance between the starting point of the vehicle and the current location:
package com.book.simulator;import java.io.IOException;import java.util.HashMap;import java.util.Map;import java.util.Properties;import java.util.Random;import org.apache.kafka.common.serialization.StringDeserializer;import com.book.domain.Location;import com.book.domain.VehicleAlertInfo;import com.fasterxml.jackson.core.JsonParseException;import com.fasterxml.jackson.core.type.TypeReference;import com.fasterxml.jackson.databind.JsonMappingException;import com.fasterxml.jackson.databind.ObjectMapper; ...
Read now
Unlock full access