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: 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.file: storm/storm-benchmark/src/test/java/storm/benchmark/lib/spout/RandomMessageSpoutTest.java
test_class.identifier: RandomMessageSpoutTest
test_case.body: @Test
    public void shouldDeclareOutputFields() {
      RandomMessageSpout spout = new RandomMessageSpout(messageSize, false);
  
      spout.declareOutputFields(declarer);
  
      verify(declarer, times(1)).declare(any(Fields.class));
    }
test_case.class_method_signature: RandomMessageSpoutTest.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: serialVersionUID = -4100642374496292646L
focal_class.modifier: private static final
focal_class.original_string: private static final long serialVersionUID = -4100642374496292646L;
focal_class.type: long
focal_class.var_name: serialVersionUID
focal_class.declarator: FIELDS = "message"
focal_class.modifier: public static final
focal_class.original_string: public static final String FIELDS = "message";
focal_class.type: String
focal_class.var_name: FIELDS
focal_class.declarator: MESSAGE_SIZE = "message.size"
focal_class.modifier: public static final
focal_class.original_string: public static final String MESSAGE_SIZE = "message.size";
focal_class.type: String
focal_class.var_name: MESSAGE_SIZE
focal_class.declarator: DEFAULT_MESSAGE_SIZE = 100
focal_class.modifier: public static final
focal_class.original_string: public static final int DEFAULT_MESSAGE_SIZE = 100;
focal_class.type: int
focal_class.var_name: DEFAULT_MESSAGE_SIZE
focal_class.declarator: sizeInBytes
focal_class.modifier: private final
focal_class.original_string: private final int sizeInBytes;
focal_class.type: int
focal_class.var_name: sizeInBytes
focal_class.declarator: messageCount = 0
focal_class.modifier: private
focal_class.original_string: private long messageCount = 0;
focal_class.type: long
focal_class.var_name: messageCount
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: messages = null
focal_class.modifier: private
focal_class.original_string: private String [] messages = null;
focal_class.type: String []
focal_class.var_name: messages
focal_class.declarator: ackEnabled
focal_class.modifier: private final
focal_class.original_string: private final boolean ackEnabled;
focal_class.type: boolean
focal_class.var_name: ackEnabled
focal_class.declarator: rand = null
focal_class.modifier: private
focal_class.original_string: private Random rand = null;
focal_class.type: Random
focal_class.var_name: rand
focal_class.file: storm/storm-benchmark/src/main/java/storm/benchmark/lib/spout/RandomMessageSpout.java
focal_class.identifier: RandomMessageSpout
focal_class.class_method_signature: RandomMessageSpout.RandomMessageSpout(boolean ackEnabled)
focal_class.full_signature: public  RandomMessageSpout(boolean ackEnabled)
focal_class.identifier: RandomMessageSpout
focal_class.modifiers: public
focal_class.parameters: (boolean ackEnabled)
focal_class.signature:  RandomMessageSpout(boolean ackEnabled)
focal_class.class_method_signature: RandomMessageSpout.RandomMessageSpout(int sizeInBytes, boolean ackEnabled)
focal_class.full_signature: public  RandomMessageSpout(int sizeInBytes, boolean ackEnabled)
focal_class.identifier: RandomMessageSpout
focal_class.modifiers: public
focal_class.parameters: (int sizeInBytes, boolean ackEnabled)
focal_class.signature:  RandomMessageSpout(int sizeInBytes, boolean ackEnabled)
focal_class.class_method_signature: RandomMessageSpout.open(Map conf, TopologyContext context, SpoutOutputCollector collector)
focal_class.full_signature: public void open(Map conf, TopologyContext context, SpoutOutputCollector collector)
focal_class.identifier: open
focal_class.modifiers: 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: RandomMessageSpout.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: RandomMessageSpout.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: RandomMessageSpout.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)