satendrakumar

import org.json4s._
import org.json4s.native.{JsonMethods, Serialization}

object JsonUtility {

  implicit val formats = DefaultFormats

  def write[T <: AnyRef](value: T): String = Serialization.write(value)

satendrakumar

Prelude> let forall :: (a -> Bool) -> [a] -> Bool ; forall f []= True; forall f (x:xs) = f x  &&  forall f  xs 
Prelude> forall even  [2,4,6] 
True
Prelude> forall even [2,4,5]
False
Prelude> let forall :: (a -> Bool) -> [a] -> Bool ; forall f []= True; forall f (x:xs) = if (f x)  then forall f  xs else False
Prelude> forall even [2,4,5]
False
Prelude> forall even  [2,4,6] 
True

satendrakumar

object GenericTypeConverter extends App{

  def convert[T: ClassTag](value:Any): Option[T] = {
    val ct = implicitly[ClassTag[T]]
        value match {
          case ct(x) => Some(x)
          case _     => None
        }
    }

satendrakumar

//Worker code
import org.apache.kafka.clients.consumer.ConsumerRecord;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.Callable;

public class Worker implements Callable<Boolean> {

    ConsumerRecord record;

satendrakumar

package slicks.docs.dao

import scala.slick.driver.PostgresDriver.simple._
import scala.slick.driver._


trait Profile {
  val profile: JdbcProfile
}

satendrakumar

Introduction to Kafka

Kafka acts as a kind of write-ahead log (WAL) that records messages to a persistent store (disk) and allows subscribers to read and apply these changes to their own stores in a system appropriate time-frame.

Terminology:

• Producers send messages to brokers
• Consumers read messages from brokers
• Messages are sent to a topic

satendrakumar

object play {
  println("Welcome to the Scala worksheet")
  
  case class User(id:Int, name:String)
  def getUser:User = null
  def processUser(u:User):String= u.name
 Option(getUser)
  
  Option(getUser).fold("Sky")(u=>processUser(u))