SriramKeerthi

/**
 * After pulling my hair out trying to find a clean, small utility to parse JSON to Maps and back in Scala,
 * I finally decided to break out some elbow grease and write my own.
 *
 * This is what I came up with, and it took some trial and error to come up with this approach. It has lots
 * of room for improvement, so feel free to help out!
 */

package com.caffinc.utils

SriramKeerthi

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.URL;


/**
 * Fetches the IP address of the machine from http://caffinc.com/myip
 * @author Sriram
 */

SriramKeerthi

import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.Enumeration;
import java.util.List;

public class IPUtil
{
    /**

SriramKeerthi

import java.io.BufferedReader;
import java.io.FileReader;


/**
 * Reads a file from the command line parameter and counts the number of lines in it
 * @author Sriram
 */
public class FileLineCount
{

SriramKeerthi

import sun.reflect.generics.reflectiveObjects.NotImplementedException;

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.util.Iterator;
import java.util.concurrent.atomic.AtomicInteger;


/**

SriramKeerthi

import sun.reflect.generics.reflectiveObjects.NotImplementedException;

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.util.*;


/**
 * Reads a file from the command line parameter and counts the number of words in it

SriramKeerthi

import sun.reflect.generics.reflectiveObjects.NotImplementedException;

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.util.*;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

SriramKeerthi

import org.apache.spark.{SparkConf, SparkContext}

object WordCount extends App {
  val conf = new SparkConf().setAppName("WordCount").setMaster("local[*]")
  val sc = new SparkContext(conf)
  val rdd = sc.textFile(args(0))
  val counts = rdd
    .flatMap(line => line.split("[ _\\-'\",<>\\.]"))
    .filter(_.length > 0)
    .map(word => (word.toLowerCase(), 1))

SriramKeerthi

import backtype.storm.Config;
import backtype.storm.LocalCluster;
import backtype.storm.spout.SpoutOutputCollector;
import backtype.storm.task.OutputCollector;
import backtype.storm.task.TopologyContext;
import backtype.storm.topology.OutputFieldsDeclarer;
import backtype.storm.topology.TopologyBuilder;
import backtype.storm.topology.base.BaseRichBolt;
import backtype.storm.topology.base.BaseRichSpout;
import backtype.storm.tuple.Fields;

SriramKeerthi

package com.caffinc.grex.core;

/**
 * SPDX-License-Identifier: MIT
 *
 * Generates Load on the CPU by keeping it busy for the given load percentage
 * @author Sriram
 */
public class Load {
    /**