override def open()

in tormenta-core/src/main/scala/com/twitter/tormenta/spout/BaseSpout.scala [42:45]

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

  override def open(conf: JMap[_, _], context: TopologyContext, coll: SpoutOutputCollector) {
    callOnOpen(context)
    collector = coll
  }