conikeec’s gists

conikeec / ScalasticDemo.scala

Created December 25, 2011 20:10 — forked from ktoso/ScalasticDemo.scala

ScalasticSearch - v0.0.1 (simple Scala DSL for http://www.elasticsearch.org/guide/reference/query-dsl/bool-query.html )

	val query = ScalasticSearch.boolQuery(
	cond (
	must(
	'nickname -> "Superman", // is equivalent to...
	term('nickname -> "Superman"), // this
	term("nickname" -> "Superman") // or this
	),
	should(
	'nickname -> "Superman", // is equivalent to...
	term('nickname -> "Superman"), // this

conikeec / ScalasticDemo.scala

Created December 25, 2011 20:15 — forked from ktoso/ScalasticDemo.scala

ScalasticSearch - v0.0.1 (simple Scala DSL for http://www.elasticsearch.org/guide/reference/query-dsl/bool-query.html )

	val query = ScalasticSearch.boolQuery(
	cond (
	must(
	'nickname -> "Superman", // is equivalent to...
	term('nickname -> "Superman"), // this
	term("nickname" -> "Superman") // or this
	),
	should(
	'nickname -> "Superman", // is equivalent to...
	term('nickname -> "Superman"), // this

conikeec / Sensei Errors

Created January 21, 2012 01:27

Sensei Errors

	Building Sensei from Source

	---------------------------------------------

	==> ./bin/zookeeper-server-start.sh resources/zookeeper.properties
	12/01/20 17:22:40 INFO quorum.QuorumPeerConfig: Reading configuration from: resources/zookeeper.properties
	12/01/20 17:22:40 WARN quorum.QuorumPeerMain: Either no config or no quorum defined in config, running in standalone mode
	12/01/20 17:22:40 DEBUG SecurityLogger.additivity: preRegister called. Server=com.sun.jmx.mbeanserver.JmxMBeanServer@4157aa53, name=log4j:logger=SecurityLogger.additivity
	12/01/20 17:22:40 DEBUG SecurityLogger.additivity: preRegister called. Server=com.sun.jmx.mbeanserver.JmxMBeanServer@4157aa53, name=log4j:logger=SecurityLogger.additivity
	12/01/20 17:22:40 ERROR jmx.AppenderDynamicMBean: Could not add DynamicLayoutMBean for [console,layout=org.apache.log4j.PatternLayout].

conikeec / alternative, using regex

Created February 9, 2012 08:52 — forked from ArtemGr/alternative, using regex

CSV parser in Scala

	val pattern = java.util.regex.Pattern.compile ("""(?xs) ("(.?)"\|) ; ("(.?)"\|) (?: \r?\n \| \z ) """)
	val matcher = pattern.matcher (input)
	while (matcher.find) {
	val col1 = matcher.group (2)
	val col2 = matcher.group (4)
	// ...
	}

conikeec / gist:1807171

Created February 12, 2012 08:01 — forked from takscape/gist:1272336

Scala: Esper

	import com.espertech.esper.client.{Configuration, EventBean, UpdateListener, EPServiceProviderManager}
	import java.util.HashMap
	import scala.collection.JavaConversions._

	object Sandbox
	{
	def main(args: Array[String]) {
	val config = new Configuration();
	val eventType = new HashMap[String, AnyRef]()
	eventType.put("itemName", classOf[String])

conikeec / EsperUtil.scala

Created February 12, 2012 08:06 — forked from wangzaixiang/EsperUtil.scala

Using Esper with Scala

	package demo1

	import com.espertech.esper.client.EventBean
	import com.espertech.esper.client.EPAdministrator
	import com.espertech.esper.client.UpdateListener
	import com.espertech.esper.client.EPListenable
	import com.espertech.esper.client.EPServiceProvider

	object EsperUtil {

conikeec / mapreduce_akka.scala

Created February 14, 2012 07:12 — forked from gertjana/mapreduce_akka.scala

MapReduce example using Akka Actors

	package net.addictivesoftware.scala.akkaactors

	import akka.actor.{Actor, PoisonPill}
	import Actor._
	import akka.routing.{Routing, CyclicIterator}
	import Routing._

	import collection.mutable.{HashMap, Map}
	import java.util.concurrent.CountDownLatch

conikeec / ParseLines.scala

Created February 16, 2012 19:24 — forked from seanparsons/ParseLines.scala

Useful code snippet to use when parsing large files in the Scala REPL

	import scala.io.Source
	def parseLines[T](file: String, transform: (Iterator[String]) => T): T = {
	val log = Source.fromFile(file)
	val logLines = log.getLines()
	try { transform(logLines) } finally { log.close }
	}
	// Example usage.
	// parseLines("verybigfile.txt", iterator.take(100).foreach(println))

conikeec / ParseLines.scala

Created February 17, 2012 00:14 — forked from seanparsons/ParseLines.scala

Useful code snippet to use when parsing large files in the Scala REPL

	import scala.io.Source
	def parseLines[T](file: String, transform: (Iterator[String]) => T): T = {
	val log = Source.fromFile(file)
	val logLines = log.getLines()
	try { transform(logLines) } finally { log.close }
	}
	// Example usage.
	// parseLines("verybigfile.txt", iterator.take(100).foreach(println))

conikeec / AkkaUnfilteredSample.scala

Created February 17, 2012 17:40 — forked from chrsan/AkkaUnfilteredSample.scala

Akka 2.0 unfiltered RESTful sample

Chetan Conikee conikeec