test_class.file: flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/util/StormStreamSelectorTest.java
test_class.identifier: StormStreamSelectorTest
test_case.body: @Test
  	public void testSelector() {
  		StormStreamSelector<Object> selector = new StormStreamSelector<Object>();
  		SplitStreamType<Object> tuple = new SplitStreamType<Object>();
  		Iterator<String> result;
  
  		tuple.streamId = "stream1";
  		result = selector.select(tuple).iterator();
  		Assert.assertEquals("stream1", result.next());
  		Assert.assertFalse(result.hasNext());
  
  		tuple.streamId = "stream2";
  		result = selector.select(tuple).iterator();
  		Assert.assertEquals("stream2", result.next());
  		Assert.assertFalse(result.hasNext());
  
  		tuple.streamId = "stream1";
  		result = selector.select(tuple).iterator();
  		Assert.assertEquals("stream1", result.next());
  		Assert.assertFalse(result.hasNext());
  	}
test_case.class_method_signature: StormStreamSelectorTest.testSelector()
test_case.full_signature: @Test public void testSelector()
test_case.identifier: testSelector
test_case.invocations: iterator select assertEquals next assertFalse hasNext iterator select assertEquals next assertFalse hasNext iterator select assertEquals next assertFalse hasNext
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testSelector()
focal_class.declarator: serialVersionUID = 2553423379715401023L
focal_class.modifier: private static final
focal_class.original_string: private static final long serialVersionUID = 2553423379715401023L;
focal_class.type: long
focal_class.var_name: serialVersionUID
focal_class.declarator: streams = new HashMap<String, List<String>>()
focal_class.modifier: private final
focal_class.original_string: private final HashMap<String, List<String>> streams = new HashMap<String, List<String>>();
focal_class.type: HashMap<String, List<String>>
focal_class.var_name: streams
focal_class.file: flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/util/StormStreamSelector.java
focal_class.identifier: StormStreamSelector
focal_class.interfaces: implements OutputSelector<SplitStreamType<T>>
focal_class.class_method_signature: StormStreamSelector.select(SplitStreamType<T> value)
focal_class.full_signature: @Override public Iterable<String> select(SplitStreamType<T> value)
focal_class.identifier: select
focal_class.modifiers: @Override public
focal_class.parameters: (SplitStreamType<T> value)
focal_class.return: Iterable<String>
focal_class.signature: Iterable<String> select(SplitStreamType<T> value)
focal_method.body: @Override
  	public Iterable<String> select(SplitStreamType<T> value) {
  		String sid = value.streamId;
  		List<String> streamId = this.streams.get(sid);
  		if (streamId == null) {
  			streamId = new ArrayList<String>(1);
  			streamId.add(sid);
  			this.streams.put(sid, streamId);
  		}
  		return streamId;
  	}
focal_method.class_method_signature: StormStreamSelector.select(SplitStreamType<T> value)
focal_method.full_signature: @Override public Iterable<String> select(SplitStreamType<T> value)
focal_method.identifier: select
focal_method.invocations: get add put
focal_method.modifiers: @Override public
focal_method.parameters: (SplitStreamType<T> value)
focal_method.return: Iterable<String>
focal_method.signature: Iterable<String> select(SplitStreamType<T> value)