test_class.file: flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/api/FlinkTopologyTest.java
test_class.identifier: FlinkTopologyTest
test_case.body: @Test
  	public void testFieldsGroupingOnMultipleBoltOutputStreams() {
  		TopologyBuilder builder = new TopologyBuilder();
  
  		builder.setSpout("spout", new TestDummySpout());
  		builder.setBolt("bolt", new TestDummyBolt()).shuffleGrouping("spout");
  		builder.setBolt("sink", new TestSink()).fieldsGrouping("bolt",
  				TestDummyBolt.groupingStreamId, new Fields("id"));
  
  		FlinkTopology.createTopology(builder);
  	}
test_case.class_method_signature: FlinkTopologyTest.testFieldsGroupingOnMultipleBoltOutputStreams()
test_case.full_signature: @Test public void testFieldsGroupingOnMultipleBoltOutputStreams()
test_case.identifier: testFieldsGroupingOnMultipleBoltOutputStreams
test_case.invocations: setSpout shuffleGrouping setBolt fieldsGrouping setBolt createTopology
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testFieldsGroupingOnMultipleBoltOutputStreams()
focal_class.declarator: outputStreams = new HashMap<String, HashMap<String, Fields>>()
focal_class.modifier: private final
focal_class.original_string: private final HashMap<String, HashMap<String, Fields>> outputStreams = new HashMap<String, HashMap<String, Fields>>();
focal_class.type: HashMap<String, HashMap<String, Fields>>
focal_class.var_name: outputStreams
focal_class.declarator: declarers = new HashMap<String, FlinkOutputFieldsDeclarer>()
focal_class.modifier: private final
focal_class.original_string: private final HashMap<String, FlinkOutputFieldsDeclarer> declarers = new HashMap<String, FlinkOutputFieldsDeclarer>();
focal_class.type: HashMap<String, FlinkOutputFieldsDeclarer>
focal_class.var_name: declarers
focal_class.declarator: unprocessdInputsPerBolt =
  			new HashMap<String, Set<Entry<GlobalStreamId, Grouping>>>()
focal_class.modifier: private final
focal_class.original_string: private final HashMap<String, Set<Entry<GlobalStreamId, Grouping>>> unprocessdInputsPerBolt =
  			new HashMap<String, Set<Entry<GlobalStreamId, Grouping>>>();
focal_class.type: HashMap<String, Set<Entry<GlobalStreamId, Grouping>>>
focal_class.var_name: unprocessdInputsPerBolt
focal_class.declarator: availableInputs = new HashMap<>()
focal_class.modifier: final
focal_class.original_string: final HashMap<String, HashMap<String, DataStream<Tuple>>> availableInputs = new HashMap<>();
focal_class.type: HashMap<String, HashMap<String, DataStream<Tuple>>>
focal_class.var_name: availableInputs
focal_class.declarator: builder
focal_class.modifier: private final
focal_class.original_string: private final TopologyBuilder builder;
focal_class.type: TopologyBuilder
focal_class.var_name: builder
focal_class.declarator: stormTopology
focal_class.modifier: private final
focal_class.original_string: private final StormTopology stormTopology;
focal_class.type: StormTopology
focal_class.var_name: stormTopology
focal_class.declarator: spouts
focal_class.modifier: private final
focal_class.original_string: private final Map<String, IRichSpout> spouts;
focal_class.type: Map<String, IRichSpout>
focal_class.var_name: spouts
focal_class.declarator: bolts
focal_class.modifier: private final
focal_class.original_string: private final Map<String, IRichBolt> bolts;
focal_class.type: Map<String, IRichBolt>
focal_class.var_name: bolts
focal_class.declarator: env
focal_class.modifier: private final
focal_class.original_string: private final StreamExecutionEnvironment env;
focal_class.type: StreamExecutionEnvironment
focal_class.var_name: env
focal_class.file: flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/api/FlinkTopology.java
focal_class.identifier: FlinkTopology
focal_class.class_method_signature: FlinkTopology.FlinkTopology(TopologyBuilder builder)
focal_class.full_signature: private  FlinkTopology(TopologyBuilder builder)
focal_class.identifier: FlinkTopology
focal_class.modifiers: private
focal_class.parameters: (TopologyBuilder builder)
focal_class.signature:  FlinkTopology(TopologyBuilder builder)
focal_class.class_method_signature: FlinkTopology.createTopology(TopologyBuilder stormBuilder)
focal_class.full_signature: public static FlinkTopology createTopology(TopologyBuilder stormBuilder)
focal_class.identifier: createTopology
focal_class.modifiers: public static
focal_class.parameters: (TopologyBuilder stormBuilder)
focal_class.return: FlinkTopology
focal_class.signature: FlinkTopology createTopology(TopologyBuilder stormBuilder)
focal_class.class_method_signature: FlinkTopology.getExecutionEnvironment()
focal_class.full_signature: public StreamExecutionEnvironment getExecutionEnvironment()
focal_class.identifier: getExecutionEnvironment
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: StreamExecutionEnvironment
focal_class.signature: StreamExecutionEnvironment getExecutionEnvironment()
focal_class.class_method_signature: FlinkTopology.execute()
focal_class.full_signature: public JobExecutionResult execute()
focal_class.identifier: execute
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: JobExecutionResult
focal_class.signature: JobExecutionResult execute()
focal_class.class_method_signature: FlinkTopology.getPrivateField(String field)
focal_class.full_signature: @SuppressWarnings("unchecked") private Map<String, T> getPrivateField(String field)
focal_class.identifier: getPrivateField
focal_class.modifiers: @SuppressWarnings("unchecked") private
focal_class.parameters: (String field)
focal_class.return: Map<String, T>
focal_class.signature: Map<String, T> getPrivateField(String field)
focal_class.class_method_signature: FlinkTopology.copyObject(T object)
focal_class.full_signature: private T copyObject(T object)
focal_class.identifier: copyObject
focal_class.modifiers: private
focal_class.parameters: (T object)
focal_class.return: T
focal_class.signature: T copyObject(T object)
focal_class.class_method_signature: FlinkTopology.translateTopology()
focal_class.full_signature: private void translateTopology()
focal_class.identifier: translateTopology
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void translateTopology()
focal_class.class_method_signature: FlinkTopology.processInput(String boltId, IRichBolt userBolt,
  			GlobalStreamId streamId, Grouping grouping,
  			Map<String, DataStream<Tuple>> producer)
focal_class.full_signature: private DataStream<Tuple> processInput(String boltId, IRichBolt userBolt,
  			GlobalStreamId streamId, Grouping grouping,
  			Map<String, DataStream<Tuple>> producer)
focal_class.identifier: processInput
focal_class.modifiers: private
focal_class.parameters: (String boltId, IRichBolt userBolt,
  			GlobalStreamId streamId, Grouping grouping,
  			Map<String, DataStream<Tuple>> producer)
focal_class.return: DataStream<Tuple>
focal_class.signature: DataStream<Tuple> processInput(String boltId, IRichBolt userBolt,
  			GlobalStreamId streamId, Grouping grouping,
  			Map<String, DataStream<Tuple>> producer)
focal_class.class_method_signature: FlinkTopology.createOutput(String boltId, IRichBolt bolt,
  			Map<GlobalStreamId, DataStream<Tuple>> inputStreams)
focal_class.full_signature: @SuppressWarnings({ "unchecked", "rawtypes" }) private SingleOutputStreamOperator<?> createOutput(String boltId, IRichBolt bolt,
  			Map<GlobalStreamId, DataStream<Tuple>> inputStreams)
focal_class.identifier: createOutput
focal_class.modifiers: @SuppressWarnings({ "unchecked", "rawtypes" }) private
focal_class.parameters: (String boltId, IRichBolt bolt,
  			Map<GlobalStreamId, DataStream<Tuple>> inputStreams)
focal_class.return: SingleOutputStreamOperator<?>
focal_class.signature: SingleOutputStreamOperator<?> createOutput(String boltId, IRichBolt bolt,
  			Map<GlobalStreamId, DataStream<Tuple>> inputStreams)
focal_class.class_method_signature: FlinkTopology.getStormTopology()
focal_class.full_signature: public StormTopology getStormTopology()
focal_class.identifier: getStormTopology
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: StormTopology
focal_class.signature: StormTopology getStormTopology()
focal_method.body: public static FlinkTopology createTopology(TopologyBuilder stormBuilder) {
  		return new FlinkTopology(stormBuilder);
  	}
focal_method.class_method_signature: FlinkTopology.createTopology(TopologyBuilder stormBuilder)
focal_method.full_signature: public static FlinkTopology createTopology(TopologyBuilder stormBuilder)
focal_method.identifier: createTopology
focal_method.modifiers: public static
focal_method.parameters: (TopologyBuilder stormBuilder)
focal_method.return: FlinkTopology
focal_method.signature: FlinkTopology createTopology(TopologyBuilder stormBuilder)