test_class.file: flink-contrib/flink-connector-wikiedits/src/test/java/org/apache/flink/streaming/connectors/wikiedits/WikipediaEditsSourceTest.java
test_class.identifier: WikipediaEditsSourceTest
test_case.body: @Test(timeout = 120 * 1000)
  	public void testWikipediaEditsSource() throws Exception {
  
  		StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
  		env.getConfig().disableSysoutLogging();
  
  		DataStream<WikipediaEditEvent> edits = env.addSource(new WikipediaEditsSource());
  
  		edits.addSink(new SinkFunction<WikipediaEditEvent>() {
  			@Override
  			public void invoke(WikipediaEditEvent value) throws Exception {
  				throw new Exception("Expected test exception");
  			}
  		});
  
  		try {
  			env.execute();
  			fail("Did not throw expected Exception.");
  		}
  		catch (Exception e) {
  			assertNotNull(e.getCause());
  			assertEquals("Expected test exception", e.getCause().getMessage());
  		}
  	}
test_case.class_method_signature: WikipediaEditsSourceTest.testWikipediaEditsSource()
test_case.full_signature: @Test(timeout = 120 * 1000) public void testWikipediaEditsSource()
test_case.identifier: testWikipediaEditsSource
test_case.invocations: getExecutionEnvironment disableSysoutLogging getConfig addSource addSink execute fail assertNotNull getCause assertEquals getMessage getCause
test_case.modifiers: @Test(timeout = 120 * 1000) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testWikipediaEditsSource()
focal_class.declarator: DEFAULT_HOST = "irc.wikimedia.org"
focal_class.modifier: public static final
focal_class.original_string: public static final String DEFAULT_HOST = "irc.wikimedia.org";
focal_class.type: String
focal_class.var_name: DEFAULT_HOST
focal_class.declarator: DEFAULT_PORT = 6667
focal_class.modifier: public static final
focal_class.original_string: public static final int DEFAULT_PORT = 6667;
focal_class.type: int
focal_class.var_name: DEFAULT_PORT
focal_class.declarator: DEFAULT_CHANNEL = "#en.wikipedia"
focal_class.modifier: public static final
focal_class.original_string: public static final String DEFAULT_CHANNEL = "#en.wikipedia";
focal_class.type: String
focal_class.var_name: DEFAULT_CHANNEL
focal_class.declarator: host
focal_class.modifier: private final
focal_class.original_string: private final String host;
focal_class.type: String
focal_class.var_name: host
focal_class.declarator: port
focal_class.modifier: private final
focal_class.original_string: private final int port;
focal_class.type: int
focal_class.var_name: port
focal_class.declarator: channel
focal_class.modifier: private final
focal_class.original_string: private final String channel;
focal_class.type: String
focal_class.var_name: channel
focal_class.declarator: isRunning = true
focal_class.modifier: private volatile
focal_class.original_string: private volatile boolean isRunning = true;
focal_class.type: boolean
focal_class.var_name: isRunning
focal_class.declarator: ircStream
focal_class.modifier: private
focal_class.original_string: private WikipediaEditEventIrcStream ircStream;
focal_class.type: WikipediaEditEventIrcStream
focal_class.var_name: ircStream
focal_class.file: flink-contrib/flink-connector-wikiedits/src/main/java/org/apache/flink/streaming/connectors/wikiedits/WikipediaEditsSource.java
focal_class.identifier: WikipediaEditsSource
focal_class.class_method_signature: WikipediaEditsSource.WikipediaEditsSource()
focal_class.full_signature: public  WikipediaEditsSource()
focal_class.identifier: WikipediaEditsSource
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.signature:  WikipediaEditsSource()
focal_class.class_method_signature: WikipediaEditsSource.WikipediaEditsSource(String host, int port, String channel)
focal_class.full_signature: public  WikipediaEditsSource(String host, int port, String channel)
focal_class.identifier: WikipediaEditsSource
focal_class.modifiers: public
focal_class.parameters: (String host, int port, String channel)
focal_class.signature:  WikipediaEditsSource(String host, int port, String channel)
focal_class.class_method_signature: WikipediaEditsSource.open(Configuration parameters)
focal_class.full_signature: @Override public void open(Configuration parameters)
focal_class.identifier: open
focal_class.modifiers: @Override public
focal_class.parameters: (Configuration parameters)
focal_class.return: void
focal_class.signature: void open(Configuration parameters)
focal_class.class_method_signature: WikipediaEditsSource.close()
focal_class.full_signature: @Override public void close()
focal_class.identifier: close
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void close()
focal_class.class_method_signature: WikipediaEditsSource.run(SourceContext ctx)
focal_class.full_signature: @Override public void run(SourceContext ctx)
focal_class.identifier: run
focal_class.modifiers: @Override public
focal_class.parameters: (SourceContext ctx)
focal_class.return: void
focal_class.signature: void run(SourceContext ctx)
focal_class.class_method_signature: WikipediaEditsSource.cancel()
focal_class.full_signature: @Override public void cancel()
focal_class.identifier: cancel
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void cancel()
focal_class.superclass: extends RichSourceFunction<WikipediaEditEvent>
focal_method.body: public WikipediaEditsSource() {
  		this(DEFAULT_HOST, DEFAULT_PORT, DEFAULT_CHANNEL);
  	}
focal_method.class_method_signature: WikipediaEditsSource.WikipediaEditsSource()
focal_method.full_signature: public  WikipediaEditsSource()
focal_method.identifier: WikipediaEditsSource
focal_method.modifiers: public
focal_method.parameters: ()
focal_method.signature:  WikipediaEditsSource()