Alexander Gallego emaxerrno

💭

I may be slow to respond.

hacker; ceo & founder of redpanda.com

emaxerrno / ActionSeedTopology.scala

Created May 22, 2013 19:56

	package com.yieldmo.storm;

	import backtype.storm.Config
	import backtype.storm.LocalCluster
	import backtype.storm.StormSubmitter
	import backtype.storm.spout.Scheme
	import backtype.storm.tuple.Fields
	import backtype.storm.tuple.Values
	import com.yieldmo.common.kafka.KafkaConfigYieldmo
	import com.yieldmo.common.kafka.KafkaConfigYieldmo._

emaxerrno / ProtoScheme.scala

Created May 23, 2013 21:41

	package com.yieldmo.storm.scheme

	import backtype.storm.spout.Scheme
	import backtype.storm.tuple.Fields
	import com.google.protobuf._
	import collection.JavaConversions._

	class ProtoScheme[T <: Message: ClassManifest](emittedField: String) extends Scheme {
	val serialVersionUID = 1L;
	@transient lazy val builder =

emaxerrno / ProtoScheme.scala

Created May 28, 2013 14:46

	package com.yieldmo.storm.scheme

	import backtype.storm.spout.Scheme
	import backtype.storm.tuple.Fields
	import com.google.protobuf._
	import collection.JavaConversions._
	import java.lang.reflect.Modifier

	class ProtoScheme[T <: Message: ClassManifest](emittedField: String) extends Scheme {
	val serialVersionUID = 1L;

emaxerrno / ActionSeedFileCLI.scala

Created May 28, 2013 21:20

	package com.yieldmo.tools

	import com.google.common.cache._
	import com.yieldmo.common.DBUtil
	import com.yieldmo.storm.StateSaver
	import com.yieldmo.common.protobuf.Events._
	import com.github.theon.uri.Uri._
	import kafka.producer.ProducerConfig
	import scala.collection.JavaConversions._
	import scala.io.Source

emaxerrno / routes.txt

Created June 15, 2013 18:29

	# Routes
	# This file defines all application routes (Higher priority routes first)
	# ~~~~

	GET / com.tuplejump.playYeoman.Yeoman.redirectRoot(base="/ui/")
	GET /ui/ com.tuplejump.playYeoman.Yeoman.index
	-> /ui yeoman.Routes

	#controllers
	GET /foo controllers.Application.index

emaxerrno / Application.scala

Created June 15, 2013 18:30

	package controllers

	import play.api._
	import play.api.mvc._

	object Application extends Controller {

	def index = Action {
	Ok("Your new application is ready.")
	}

emaxerrno / Application.scala

Created June 15, 2013 18:31

	package controllers

	import play.api._
	import play.api.mvc._

	object Application extends Controller {

	def index = Action {
	Ok("Your new application is ready.")
	}

emaxerrno / AdvertiserDashboardUrlTopN.scala

Created June 19, 2013 15:53

	object TopURLHelper {
	// expects a list of aggregates of type 'only' URL or RR
	// def combine(l: List[Aggregate]): Aggregate = {
	// val builder = Aggregate.newBuilder()
	// }

	def combine(l: List[Event]): List[Aggregate] = {
	val map = new HashMap[ByteString, Aggregate.Builder]()

	l.map { x =>

emaxerrno / PublisherRevenueSplitCache.scala

Created June 27, 2013 19:17

	package com.yieldmo.common.publisher;

	import com.google.common.cache._
	import com.yieldmo.common.DBUtil
	import java.util.concurrent.TimeUnit
	import java.sql.Connection
	import anorm._
	import anorm.SqlParser._
	import resource._

emaxerrno / *frequencies*.txt

Created June 28, 2013 18:11