Olalekan Fuad Elesin OElesin

The introduction to Reactive Programming you've been missing

So you're curious in learning this new thing called Reactive Programming, particularly its variant comprising of Rx, Bacon.js, RAC, and others.

Learning it is hard, even harder by the lack of good material. When I started, I tried looking for tutorials. I found only a handful of practical guides, but they just scratched the surface and never tackled the challenge of building the whole architecture around it. Library documentations often don't help when you're trying to understand some function. I mean, honestly, look at this:

Rx.Observable.prototype.flatMapLatest(selector, [thisArg])

Projects each element of an observable sequence into a new sequence of observable sequences by incorporating the element's index and then transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.

This uses Twitter Bootstrap classes for CodeIgniter pagination.

Drop this file into application/config.

Examples for python and Spark

Link

Word Count

import sys
from operator import add
from pyspark import SparkContext

if __name__ == "__main__":
    if len(sys.argv) != 2:

	package botkop.sparti.receiver

	import com.rabbitmq.client._
	import org.apache.spark.Logging
	import org.apache.spark.storage.StorageLevel
	import org.apache.spark.streaming.StreamingContext
	import org.apache.spark.streaming.dstream.ReceiverInputDStream
	import org.apache.spark.streaming.receiver.Receiver

	import scala.reflect.ClassTag

	<?php if ( ! defined('BASEPATH')) exit('No direct script access allowed');

	/**
	* Rating Library
	* Using jQuery Raty plugin to rate products
	* @author Nikola Katsarov
	* @website http://katsarov.biz
	*/

	class Rating {

	package object mail {

	implicit def stringToSeq(single: String): Seq[String] = Seq(single)
	implicit def liftToOption[T](t: T): Option[T] = Some(t)

	sealed abstract class MailType
	case object Plain extends MailType
	case object Rich extends MailType
	case object MultiPart extends MailType

	-- This is a Hive program. Hive is an SQL-like language that compiles
	-- into Hadoop Map/Reduce jobs. It's very popular among analysts at
	-- Facebook, because it allows them to query enormous Hadoop data
	-- stores using a language much like SQL.

	-- Our logs are stored on the Hadoop Distributed File System, in the
	-- directory /logs/randomhacks.net/access. They're ordinary Apache
	-- logs in *.gz format.
	--
	-- We want to pretend that these gzipped log files are a database table,