Mingzhou ZHUANG mingzhou

The introduction to Reactive Programming you've been missing

This tutorial as a series of videos

If you prefer to watch video tutorials with live-coding, then check out this series I recorded with the same contents as in this article: Egghead.io - Introduction to Reactive Programming.

chartFactory

/affini-tech/ChartFactory

Based on D3.JS and Dimple, ChartFactory provide the ability to build quickly D3.JS charts without coding any lines of javascript. Just define your dashboard in a JSON and voila !

charts: [
        {id:'chart1',
         width:800,height:250,

xAxis:{type:'Category',field: "Month",orderRule:'Date'},

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

tmux cheatsheet

As configured in my dotfiles.

start new:

tmux

start new with session name:

	name := "playground"

	version := "1.0"

	scalaVersion := "2.10.4"

	libraryDependencies += "org.apache.spark" %% "spark-core" % "1.1.0"

	libraryDependencies += "net.sf.opencsv" % "opencsv" % "2.3"

	import scala.slick.lifted.CanBeQueryCondition
	// optionally filter on a column with a supplied predicate
	case class MaybeFilter[X, Y](val query: scala.slick.lifted.Query[X, Y]) {
	def filter[T,R:CanBeQueryCondition](data: Option[T])(f: T => X => R) = {
	data.map(v => MaybeFilter(query.filter(f(v)))).getOrElse(this)
	}
	}

	// example use case
	import java.sql.Date

	"""
	Least Angle Regression algorithm. See the documentation on the
	Generalized Linear Model for a complete discussion.
	"""

	# Author: Fabian Pedregosa <fabian.pedregosa@inria.fr>
	# Alexandre Gramfort <alexandre.gramfort@inria.fr>
	# Gael Varoquaux
	#
	# License: BSD Style.

	import java.util.ArrayList;
	import java.util.Iterator;
	import java.util.List;
	import java.util.concurrent.Callable;
	import java.util.concurrent.ExecutorService;
	import java.util.concurrent.Future;
	import java.util.concurrent.LinkedBlockingQueue;
	import java.util.concurrent.ThreadPoolExecutor;
	import java.util.concurrent.TimeUnit;