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.file: storm/storm-benchmark/src/test/java/storm/benchmark/tools/producer/kafka/FileReadKafkaProducerTest.java
test_class.identifier: FileReadKafkaProducerTest
test_case.body: @Test
    public void spoutShouldBeKafkaFileReadSpout() {
      KafkaProducer producer = new FileReadKafkaProducer();
      producer.getTopology(new Config());
      assertThat(producer.getSpout()).isInstanceOf(FileReadSpout.class);
    }
test_case.class_method_signature: FileReadKafkaProducerTest.spoutShouldBeKafkaFileReadSpout()
test_case.full_signature: @Test public void spoutShouldBeKafkaFileReadSpout()
test_case.identifier: spoutShouldBeKafkaFileReadSpout
test_case.invocations: getTopology isInstanceOf assertThat getSpout
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void spoutShouldBeKafkaFileReadSpout()
focal_class.declarator: FILE = "/resources/A_Tale_of_Two_City.txt"
focal_class.modifier: public static final
focal_class.original_string: public static final String FILE = "/resources/A_Tale_of_Two_City.txt";
focal_class.type: String
focal_class.var_name: FILE
focal_class.file: storm/storm-benchmark/src/main/java/storm/benchmark/tools/producer/kafka/FileReadKafkaProducer.java
focal_class.identifier: FileReadKafkaProducer
focal_class.class_method_signature: FileReadKafkaProducer.getTopology(Config config)
focal_class.full_signature: @Override public StormTopology getTopology(Config config)
focal_class.identifier: getTopology
focal_class.modifiers: @Override public
focal_class.parameters: (Config config)
focal_class.return: StormTopology
focal_class.signature: StormTopology getTopology(Config config)
focal_class.superclass: extends KafkaProducer
focal_method.body: @Override
    public StormTopology getTopology(Config config) {
      spout = new FileReadSpout(FILE);
      return super.getTopology(config);
    }
focal_method.class_method_signature: FileReadKafkaProducer.getTopology(Config config)
focal_method.full_signature: @Override public StormTopology getTopology(Config config)
focal_method.identifier: getTopology
focal_method.invocations: getTopology
focal_method.modifiers: @Override public
focal_method.parameters: (Config config)
focal_method.return: StormTopology
focal_method.signature: StormTopology getTopology(Config config)