test_class.declarator: messageSize = 100
test_class.modifier: private static final
test_class.original_string: private static final int messageSize = 100;
test_class.type: int
test_class.var_name: messageSize
test_class.declarator: ANY_CONF = new HashMap()
test_class.modifier: private static final
test_class.original_string: private static final Map ANY_CONF = new HashMap();
test_class.type: Map
test_class.var_name: ANY_CONF
test_class.declarator: NEXT_LINE = "next line"
test_class.modifier: private static final
test_class.original_string: private static final String NEXT_LINE = "next line";
test_class.type: String
test_class.var_name: NEXT_LINE
test_class.declarator: declarer
test_class.modifier: private
test_class.original_string: private OutputFieldsDeclarer declarer;
test_class.type: OutputFieldsDeclarer
test_class.var_name: declarer
test_class.declarator: context
test_class.modifier: private
test_class.original_string: private TopologyContext context;
test_class.type: TopologyContext
test_class.var_name: context
test_class.declarator: collector
test_class.modifier: private
test_class.original_string: private SpoutOutputCollector collector;
test_class.type: SpoutOutputCollector
test_class.var_name: collector
test_class.declarator: reader
test_class.modifier: private
test_class.original_string: private FileReader reader;
test_class.type: FileReader
test_class.var_name: reader
test_class.file: storm/storm-benchmark/src/test/java/storm/benchmark/lib/spout/FileReadSpoutTest.java
test_class.identifier: FileReadSpoutTest
test_case.body: @Test
    public void shouldDeclareOutputFields() {
      FileReadSpout spout = new FileReadSpout(false, reader);
  
      spout.declareOutputFields(declarer);
  
      verify(declarer, times(1)).declare(any(Fields.class));
    }
test_case.class_method_signature: FileReadSpoutTest.shouldDeclareOutputFields()
test_case.full_signature: @Test public void shouldDeclareOutputFields()
test_case.identifier: shouldDeclareOutputFields
test_case.invocations: declareOutputFields declare verify times any
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void shouldDeclareOutputFields()
focal_class.declarator: LOG = Logger.getLogger(FileReadSpout.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = Logger.getLogger(FileReadSpout.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: serialVersionUID = -2582705611472467172L
focal_class.modifier: private static final
focal_class.original_string: private static final long serialVersionUID = -2582705611472467172L;
focal_class.type: long
focal_class.var_name: serialVersionUID
focal_class.declarator: DEFAULT_FILE = "/resources/A_Tale_of_Two_City.txt"
focal_class.modifier: public static final
focal_class.original_string: public static final String DEFAULT_FILE = "/resources/A_Tale_of_Two_City.txt";
focal_class.type: String
focal_class.var_name: DEFAULT_FILE
focal_class.declarator: DEFAULT_ACK = false
focal_class.modifier: public static final
focal_class.original_string: public static final boolean DEFAULT_ACK = false;
focal_class.type: boolean
focal_class.var_name: DEFAULT_ACK
focal_class.declarator: FIELDS = "sentence"
focal_class.modifier: public static final
focal_class.original_string: public static final String FIELDS = "sentence";
focal_class.type: String
focal_class.var_name: FIELDS
focal_class.declarator: ackEnabled
focal_class.modifier: public final
focal_class.original_string: public final boolean ackEnabled;
focal_class.type: boolean
focal_class.var_name: ackEnabled
focal_class.declarator: reader
focal_class.modifier: public final
focal_class.original_string: public final FileReader reader;
focal_class.type: FileReader
focal_class.var_name: reader
focal_class.declarator: collector
focal_class.modifier: private
focal_class.original_string: private SpoutOutputCollector collector;
focal_class.type: SpoutOutputCollector
focal_class.var_name: collector
focal_class.declarator: count = 0
focal_class.modifier: private
focal_class.original_string: private long count = 0;
focal_class.type: long
focal_class.var_name: count
focal_class.file: storm/storm-benchmark/src/main/java/storm/benchmark/lib/spout/FileReadSpout.java
focal_class.identifier: FileReadSpout
focal_class.class_method_signature: FileReadSpout.FileReadSpout()
focal_class.full_signature: public  FileReadSpout()
focal_class.identifier: FileReadSpout
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.signature:  FileReadSpout()
focal_class.class_method_signature: FileReadSpout.FileReadSpout(boolean ackEnabled)
focal_class.full_signature: public  FileReadSpout(boolean ackEnabled)
focal_class.identifier: FileReadSpout
focal_class.modifiers: public
focal_class.parameters: (boolean ackEnabled)
focal_class.signature:  FileReadSpout(boolean ackEnabled)
focal_class.class_method_signature: FileReadSpout.FileReadSpout(boolean ackEnabled, String file)
focal_class.full_signature: public  FileReadSpout(boolean ackEnabled, String file)
focal_class.identifier: FileReadSpout
focal_class.modifiers: public
focal_class.parameters: (boolean ackEnabled, String file)
focal_class.signature:  FileReadSpout(boolean ackEnabled, String file)
focal_class.class_method_signature: FileReadSpout.FileReadSpout(boolean ackEnabled, FileReader reader)
focal_class.full_signature: public  FileReadSpout(boolean ackEnabled, FileReader reader)
focal_class.identifier: FileReadSpout
focal_class.modifiers: public
focal_class.parameters: (boolean ackEnabled, FileReader reader)
focal_class.signature:  FileReadSpout(boolean ackEnabled, FileReader reader)
focal_class.class_method_signature: FileReadSpout.open(Map conf, TopologyContext context,
  			SpoutOutputCollector collector)
focal_class.full_signature: @Override public void open(Map conf, TopologyContext context,
  			SpoutOutputCollector collector)
focal_class.identifier: open
focal_class.modifiers: @Override public
focal_class.parameters: (Map conf, TopologyContext context,
  			SpoutOutputCollector collector)
focal_class.return: void
focal_class.signature: void open(Map conf, TopologyContext context,
  			SpoutOutputCollector collector)
focal_class.class_method_signature: FileReadSpout.nextTuple()
focal_class.full_signature: @Override public void nextTuple()
focal_class.identifier: nextTuple
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void nextTuple()
focal_class.class_method_signature: FileReadSpout.declareOutputFields(OutputFieldsDeclarer declarer)
focal_class.full_signature: @Override public void declareOutputFields(OutputFieldsDeclarer declarer)
focal_class.identifier: declareOutputFields
focal_class.modifiers: @Override public
focal_class.parameters: (OutputFieldsDeclarer declarer)
focal_class.return: void
focal_class.signature: void declareOutputFields(OutputFieldsDeclarer declarer)
focal_class.superclass: extends BaseRichSpout
focal_method.body: @Override
  	public void declareOutputFields(OutputFieldsDeclarer declarer) {
  		declarer.declare(new Fields(FIELDS));
  	}
focal_method.class_method_signature: FileReadSpout.declareOutputFields(OutputFieldsDeclarer declarer)
focal_method.full_signature: @Override public void declareOutputFields(OutputFieldsDeclarer declarer)
focal_method.identifier: declareOutputFields
focal_method.invocations: declare
focal_method.modifiers: @Override public
focal_method.parameters: (OutputFieldsDeclarer declarer)
focal_method.return: void
focal_method.signature: void declareOutputFields(OutputFieldsDeclarer declarer)