id: 1 unit: def filter() file: tormenta-core/src/main/scala/com/twitter/tormenta/scheme/Scheme.scala start line: 62 end line: 86 size: 21 LOC McCabe index: 4 number of parameters: 1 id: 2 unit: public FixedTupleSpout() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 71 end line: 90 size: 20 LOC McCabe index: 3 number of parameters: 2 id: 3 unit: public void open() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 130 end line: 145 size: 16 LOC McCabe index: 4 number of parameters: 3 id: 4 unit: override def open() file: tormenta-core/src/main/scala/com/twitter/tormenta/spout/Proxy.scala start line: 22 end line: 35 size: 13 LOC McCabe index: 1 number of parameters: 4 id: 5 unit: public int getCompleted() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 96 end line: 107 size: 11 LOC McCabe index: 1 number of parameters: 0 id: 6 unit: public void nextTuple() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 150 end line: 159 size: 10 LOC McCabe index: 2 number of parameters: 0 id: 7 unit: def getSpout[R]() file: tormenta-core/src/main/scala/com/twitter/tormenta/spout/SchemeSpout.scala start line: 27 end line: 40 size: 10 LOC McCabe index: 1 number of parameters: 2 id: 8 unit: public Object cleanup() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 120 end line: 128 size: 9 LOC McCabe index: 1 number of parameters: 0 id: 9 unit: def onEmpty: Unit = Time.sleep() file: tormenta-core/src/main/scala/com/twitter/tormenta/spout/BaseSpout.scala start line: 58 end line: 68 size: 9 LOC McCabe index: 1 number of parameters: 1 id: 10 unit: def onEmpty: Unit = Time.sleep() file: tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala start line: 83 end line: 92 size: 9 LOC McCabe index: 3 number of parameters: 1 id: 11 unit: override def getSpout[R]() file: tormenta-kafka/src/main/scala/com/twitter/tormenta/spout/KafkaSpout.scala start line: 30 end line: 41 size: 9 LOC McCabe index: 2 number of parameters: 2 id: 12 unit: override def getSpout = spout.getSpout() file: tormenta-core/src/main/scala/com/twitter/tormenta/spout/FlatMappedSchemeSpout.scala start line: 30 end line: 38 size: 8 LOC McCabe index: 1 number of parameters: 1 id: 13 unit: def apply() file: tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala start line: 39 end line: 47 size: 8 LOC McCabe index: 1 number of parameters: 3 id: 14 unit: override def decode() file: tormenta-avro/src/main/scala/com/twitter/tormenta/scheme/avro/InjectionScheme.scala start line: 30 end line: 37 size: 8 LOC McCabe index: 3 number of parameters: 1 id: 15 unit: def module() file: build.sbt start line: 156 end line: 163 size: 8 LOC McCabe index: 1 number of parameters: 1 id: 16 unit: override def openHook() file: tormenta-core/src/main/scala/com/twitter/tormenta/spout/BaseSpout.scala start line: 32 end line: 38 size: 7 LOC McCabe index: 1 number of parameters: 1 id: 17 unit: public void ack() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 161 end line: 166 size: 6 LOC McCabe index: 1 number of parameters: 1 id: 18 unit: public void fail() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 168 end line: 173 size: 6 LOC McCabe index: 1 number of parameters: 1 id: 19 unit: def fromTraversable[T]() file: tormenta-core/src/main/scala/com/twitter/tormenta/spout/Spout.scala start line: 32 end line: 38 size: 6 LOC McCabe index: 1 number of parameters: 1 id: 20 unit: override def open() file: tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala start line: 70 end line: 77 size: 6 LOC McCabe index: 1 number of parameters: 4 id: 21 unit: public static int getNumAcked() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 40 end line: 44 size: 5 LOC McCabe index: 1 number of parameters: 1 id: 22 unit: public static int getNumFailed() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 46 end line: 50 size: 5 LOC McCabe index: 1 number of parameters: 1 id: 23 unit: public void declareOutputFields() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 184 end line: 188 size: 5 LOC McCabe index: 2 number of parameters: 1 id: 24 unit: def decode() file: tormenta-core/src/main/scala/com/twitter/tormenta/scheme/Scheme.scala start line: 46 end line: 54 size: 5 LOC McCabe index: 1 number of parameters: 1 id: 25 unit: def withHandler[U >: T]() file: tormenta-core/src/main/scala/com/twitter/tormenta/scheme/Scheme.scala start line: 56 end line: 60 size: 5 LOC McCabe index: 1 number of parameters: 1 id: 26 unit: def apply[T]() file: tormenta-core/src/main/scala/com/twitter/tormenta/Externalizer.scala start line: 28 end line: 32 size: 5 LOC McCabe index: 1 number of parameters: 1 id: 27 unit: public static void clear() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 52 end line: 55 size: 4 LOC McCabe index: 1 number of parameters: 1 id: 28 unit: def apply[T]() file: tormenta-core/src/main/scala/com/twitter/tormenta/scheme/Scheme.scala start line: 35 end line: 38 size: 4 LOC McCabe index: 1 number of parameters: 1 id: 29 unit: override def open() file: tormenta-core/src/main/scala/com/twitter/tormenta/spout/Proxy.scala start line: 38 end line: 41 size: 4 LOC McCabe index: 1 number of parameters: 4 id: 30 unit: def apply[T]() file: tormenta-core/src/main/scala/com/twitter/tormenta/spout/TraversableSpout.scala start line: 24 end line: 28 size: 4 LOC McCabe index: 1 number of parameters: 2 id: 31 unit: override def open() file: tormenta-core/src/main/scala/com/twitter/tormenta/spout/BaseSpout.scala start line: 42 end line: 45 size: 4 LOC McCabe index: 1 number of parameters: 4 id: 32 unit: def apply[T]() file: tormenta-avro/src/main/scala/com/twitter/tormenta/scheme/avro/InjectionScheme.scala start line: 25 end line: 29 size: 4 LOC McCabe index: 1 number of parameters: 2 id: 33 unit: def youngestForwardCompatible() file: build.sbt start line: 122 end line: 125 size: 4 LOC McCabe index: 1 number of parameters: 1 id: 34 unit: public FixedTupleSpout() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 67 end line: 69 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 35 unit: public List getSourceTuples() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 92 end line: 94 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 36 unit: public Object exhausted_QMARK_() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 110 end line: 112 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 37 unit: public Object startup() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 115 end line: 117 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 38 unit: public Map getComponentConfiguration() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 191 end line: 193 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 39 unit: private[spout] def register() file: tormenta-core/src/main/scala/com/twitter/tormenta/spout/Metric.scala start line: 30 end line: 32 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 40 unit: override def declareOutputFields() file: tormenta-core/src/main/scala/com/twitter/tormenta/spout/BaseSpout.scala start line: 79 end line: 81 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 41 unit: def onStatus() file: tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala start line: 54 end line: 56 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 42 unit: override def declareOutputFields() file: tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala start line: 66 end line: 68 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 43 unit: override def flatMap[U]() file: tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala start line: 94 end line: 97 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 44 unit: def apply[T <: SpecificRecordBase: ClassTag] = InjectionScheme() file: tormenta-avro/src/main/scala/com/twitter/tormenta/scheme/avro/specific/SpecificAvroScheme.scala start line: 29 end line: 32 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 45 unit: def apply[T <: SpecificRecordBase: ClassTag] = InjectionScheme() file: tormenta-avro/src/main/scala/com/twitter/tormenta/scheme/avro/specific/SpecificAvroScheme.scala start line: 33 end line: 36 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 46 unit: def apply[T <: GenericRecord]() file: tormenta-avro/src/main/scala/com/twitter/tormenta/scheme/avro/generic/GenericAvroScheme.scala start line: 26 end line: 29 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 47 unit: def apply[T <: GenericRecord]() file: tormenta-avro/src/main/scala/com/twitter/tormenta/scheme/avro/generic/GenericAvroScheme.scala start line: 30 end line: 33 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 48 unit: public void close() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 147 end line: 148 size: 2 LOC McCabe index: 1 number of parameters: 0 id: 49 unit: public void activate() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 176 end line: 177 size: 2 LOC McCabe index: 1 number of parameters: 0 id: 50 unit: public void deactivate() file: tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java start line: 180 end line: 181 size: 2 LOC McCabe index: 1 number of parameters: 0 id: 51 unit: protected ScalaInterop() file: tormenta-core/src/main/java/com/twitter/tormenta/ScalaInterop.java start line: 28 end line: 28 size: 1 LOC McCabe index: 1 number of parameters: 0 id: 52 unit: def callOnOpen:() file: tormenta-core/src/main/scala/com/twitter/tormenta/spout/BaseSpout.scala start line: 40 end line: 40 size: 1 LOC McCabe index: 1 number of parameters: 1 id: 53 unit: def onDeletionNotice() file: tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala start line: 57 end line: 57 size: 1 LOC McCabe index: 1 number of parameters: 1 id: 54 unit: def onScrubGeo() file: tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala start line: 58 end line: 58 size: 1 LOC McCabe index: 1 number of parameters: 2 id: 55 unit: def onStallWarning() file: tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala start line: 59 end line: 59 size: 1 LOC McCabe index: 1 number of parameters: 1 id: 56 unit: def onTrackLimitationNotice() file: tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala start line: 60 end line: 60 size: 1 LOC McCabe index: 1 number of parameters: 1 id: 57 unit: def onException() file: tormenta-twitter/src/main/scala/com/twitter/tormenta/spout/TwitterSpout.scala start line: 61 end line: 61 size: 1 LOC McCabe index: 1 number of parameters: 1