Permalink
Browse files

exposing Storm config in Spout

  • Loading branch information...
1 parent 657a59c commit ea0d3385e2d83d78e476fef33588e2b0ed5d58b5 Erich Nachbar committed Dec 22, 2011
Showing with 3 additions and 1 deletion.
  1. +1 −1 build.sbt
  2. +2 −0 dsl/StormSpout.scala
View
@@ -1,6 +1,6 @@
name := "scala-storm"
-version := "0.2"
+version := "0.2.1"
// If you comment this out, SBT 0.10 will default to Scala 2.8.1
scalaVersion := "2.9.1"
View
@@ -14,10 +14,12 @@ abstract class StormSpout(val outputFields: List[String],
val isDistributed: Boolean = false) extends IRichSpout with SetupFunc {
var _context:TopologyContext = _
var _collector:SpoutOutputCollector = _
+ var _conf:java.util.Map[_, _] = _
def open(conf: Map[_, _], context: TopologyContext, collector: SpoutOutputCollector) = {
_context = context
_collector = collector
+ _conf = conf
_setup()
}

0 comments on commit ea0d338

Please sign in to comment.