mrflip

Tuning Storm+Trident

Tuning a dataflow system is easy:

The First Rule of Dataflow Tuning:
* Ensure each stage is always ready to accept records, and
* Deliver each processed record promptly to its destination

bugwelle

/*
 *
 * There is now an Angular directive, filter and provider!
 * It can be found here: https://github.com/i18next/ng-i18next
 * ng-i18next is now part of the i18next rganization!
 *
 */

/*
 * AngularJS directive for using i18next (http://jamuhl.github.com/i18next)

mattt

Generate the list yourself:

$ cd /Applications/Xcode.app/Contents/Developer/Platforms/iPhoneOS.platform/Developer/SDKs/iPhoneOS*.sdk/System/Library/Frameworks/UIKit.framework/Headers
$ grep UI_APPEARANCE_SELECTOR ./*     | \
  sed 's/NS_AVAILABLE_IOS(.*)//g'     | \
  sed 's/NS_DEPRECATED_IOS(.*)//g'    | \
  sed 's/API_AVAILABLE(.*)//g'        | \
  sed 's/API_UNAVAILABLE(.*)//g'      | \
 sed 's/UI_APPEARANCE_SELECTOR//g' | \

MLnick

import spark.streaming.StreamingContext._
import spark.streaming.{Seconds, StreamingContext}
import spark.SparkContext._
import spark.storage.StorageLevel
import spark.streaming.examples.twitter.TwitterInputDStream
import com.twitter.algebird.HyperLogLog._
import com.twitter.algebird._

/**
 * Example of using HyperLogLog monoid from Twitter's Algebird together with Spark Streaming's

dyross

def blockingAndVerbose: Profile = {
    val futureName = name()
    val futureScore = score()
    val futureFriends = Friends()

    val nameResult = Await.result(futureName, 10 seconds)
    val scoreResult = Await.result(futureScore, 10 seconds)
    val friendsResult = Await.result(futureFriends, 10 seconds)

    Profile(nameResult, scoreResult, friendsResult)

haschek

{
    // --------------------------------------------------------------------
    // JSHint Configuration, Strict Edition
    // --------------------------------------------------------------------
    //
    // This is a options template for [JSHint][1], using [JSHint example][2]
    // and [Ory Band's example][3] as basis and setting config values to
    // be most strict:
    //
    // * set all enforcing options to true

wataru420

$ heroku config:add SBT_OPTS="-Xmx384m -Xss512k -XX:+UseCompressedOops -Dfile.encoding=UTF8"
$ heroku config:add BUILDPACK_URL="https://github.com/wataru420/heroku-buildpack-scala.git"
$ echo "web: target/start \${SBT_OPTS}" > Procfile
$ git commit -am 'Procfile using SBT_OPTS
$ git push heroku master

maxweber

(ns path.core
  (:use clojure.test)
  (:require [clojure.string :as s]))

(defn clean-component [component]
  (s/replace component #"/+" ""))

(defn path-prefix [components]
  (if (re-find #"/+" (first components))
    "/"

igstan

var push = function (value) {
  return function (stack) {
    var newStack = [value].concat(stack);
    return { value:undefined, stack:newStack };
  };
};

var pop = function () {
  return function (stack) {
    var value = stack[0];