Skip to content

Instantly share code, notes, and snippets.

View gupta-himanshu's full-sized avatar

Himanshu Gupta gupta-himanshu

62 followers · 45 following
View GitHub Profile
@gupta-himanshu
gupta-himanshu / application.conf
Created April 8, 2018 14:57
lagom.broker.kafka {
service-name = ""
brokers = "127.0.0.1:9092"
client {
default {
failure-exponential-backoff {
min = 3s
max = 30s
@gupta-himanshu
gupta-himanshu / application.conf
Created April 8, 2018 14:48
cassandra.default {
## list the contact points here
contact-points = ["127.0.0.1"]
## override Lagom’s ServiceLocator-based ConfigSessionProvider
session-provider = akka.persistence.cassandra.ConfigSessionProvider
}
cassandra-journal {
contact-points = ${cassandra.default.contact-points}
session-provider = ${cassandra.default.session-provider}
@gupta-himanshu
gupta-himanshu / spark-assignment1-solution.md
Created February 22, 2018 05:43
  1. Use List as parameter:
    sc.parallelize(List(line)).collect()

It will return:

    res1: Array[String] = Array(hello,world)
@gupta-himanshu
gupta-himanshu / MapExample.scala
Created August 13, 2017 06:48
package com.knoldus.kafka.examples
import java.util.Properties
import org.apache.kafka.common.serialization._
import org.apache.kafka.streams._
import org.apache.kafka.streams.kstream.{KStreamBuilder, KeyValueMapper}
/**
* Copyright Knoldus Software LLP, 2017. All rights reserved.
@gupta-himanshu
gupta-himanshu / StreamApplication.scala
Created July 22, 2017 09:08
package com.knoldus.kafka.examples
import java.util.Properties
import org.apache.kafka.common.serialization._
import org.apache.kafka.streams._
import org.apache.kafka.streams.kstream.KStreamBuilder
/**
* Copyright Knoldus Software LLP, 2017. All rights reserved.
@gupta-himanshu
gupta-himanshu / sample-react.html
Created April 9, 2017 15:59
<script src="https://unpkg.com/react@15/dist/react.js"></script>
<script src="https://unpkg.com/react-dom@15/dist/react-dom.js"></script>
<script src="https://unpkg.com/babel-standalone@6.15.0/babel.js"></script>
<script type = "text/babel">
ReactDOM.render(
<h1>Hello, world!</h1>,
document.getElementById('root')
);
</script>
@gupta-himanshu
gupta-himanshu / hello-react.html
Created April 9, 2017 15:58
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<title>Hello React</title>
</head>
<body>
<div id="root">
</div>
<script src="https://unpkg.com/react@15/dist/react.js"></script>
@gupta-himanshu
gupta-himanshu / Scala03Assignment1.scala
Created February 7, 2017 06:30
class Assignment1 {
def length(list: List[Any]): Int = list.foldRight(0) { (_, sum) => sum + 1 }
def hasSubsequence(list: List[Any], subList: List[Any]): Boolean = list.containsSlice(subList)
def splitList(list : List[Int], func: Int => Boolean) : (List[Int],List[Int]) = {
val l1 = for{ l <- list if(func(l))} yield l
val l2 = for{ l <- list if(!func(l))} yield l
(l1, l2)
}