Skip to content

Instantly share code, notes, and snippets.

View amedina's full-sized avatar

Alberto A. Medina amedina

View GitHub Profile
@amedina
amedina / exprolluprt_AdEngagementScheme.java
Created November 18, 2013 18:02
Storm: Light xprollup RT
package com.twitter.ads.batch.experimental.amedina.storm.exprolluprt;
import java.util.List;
import org.apache.thrift.TDeserializer;
import org.apache.thrift.protocol.TBinaryProtocol;
import com.twitter.ads.logging.AdEngagementLogEntry;
import com.twitter.ads.realtime.exprolluprt.ExpRollupRTEngKey;
@amedina
amedina / exprolluprt_AdEngagementScheme.java
Created November 10, 2013 00:24
Skeleton of STORM Exp Rollup Job
package com.twitter.ads.batch.experimental.amedina.storm.exprolluprt;
import java.util.List;
import org.apache.thrift.TDeserializer;
import org.apache.thrift.protocol.TBinaryProtocol;
import com.twitter.ads.logging.AdEngagementLogEntry;
import com.twitter.ads.realtime.exprolluprt.ExpRollupRTEngKey;
@amedina
amedina / exp_rollup_rt_BUILD
Created November 10, 2013 00:19
Summingbird Skeleton Exp Rollup Job
scala_library(name = 'exprollup_rt',
dependencies = [
pants('src/scala/com/twitter/ads/batch/experimental/amedina/summingbird/exp_rollup_rt/common'),
pants('src/scala/com/twitter/ads/batch/experimental/amedina/summingbird/exp_rollup_rt/job'),
pants('src/scala/com/twitter/ads/batch/experimental/amedina/summingbird/exp_rollup_rt/client'),
],
)