override def open()

in tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala [70:77]

• 6 lines of code
• 1 McCabe index (conditional complexity)

  override def open(conf: JMap[_, _], context: TopologyContext, coll: SpoutOutputCollector) {
    collector = coll
    stream = factory.getInstance
    stream.addListener(listener)

    // TODO: Add support beyond "sample". (GardenHose, for example.)
    stream.sample
  }