August 2017
Beginner to intermediate
278 pages
6h 40m
English
We haven't focused much on modularization in our code. The IP fraud detection application scans each record and filters those records which qualify as a the fraud record based on fraud IP lookup service. The lookup service can be changed to use any fast lookup database. We are using in memory lookup service for this application:
import com.packt.reader.PropertyReader;import org.apache.Spark.SparkConf;import org.apache.Spark.api.java.function.Function;import org.apache.Spark.streaming.api.java.JavaStreamingContext;import java.util.Set;import java.util.regex.Pattern;import java.util.HashMap;import java.util.HashSet;import java.util.Arrays;import java.util.Map;import scala.Tuple2;import kafka.serializer.StringDecoder;import
Read now
Unlock full access