org.openimaj.stream.provider

Class WikipediaEditsDataset

java.lang.Object

org.openimaj.util.stream.AbstractStream<T>

org.openimaj.util.stream.BlockingDroppingBufferedStream<T>

org.openimaj.stream.provider.irc.AbstractIRCStreamDataset<WikipediaEditsDataset.WikipediaEdit>

org.openimaj.stream.provider.WikipediaEditsDataset

All Implemented Interfaces:

Iterable<WikipediaEditsDataset.WikipediaEdit>, Iterator<WikipediaEditsDataset.WikipediaEdit>, Dataset<WikipediaEditsDataset.WikipediaEdit>, StreamingDataset<WikipediaEditsDataset.WikipediaEdit>, Stream<WikipediaEditsDataset.WikipediaEdit>

public class WikipediaEditsDataset
extends AbstractIRCStreamDataset<WikipediaEditsDataset.WikipediaEdit>

Streaming dataset based on the Wikipedia/Wikimedia edits published in real-time on the wikimedia IRC channels.

Author:

Sina Samangooei (ss@ecs.soton.ac.uk), Jonathon Hare (jsh2@ecs.soton.ac.uk)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WikipediaEditsDataset.WikipediaEdit An edit

Constructor Summary

Constructors

Constructor and Description
WikipediaEditsDataset(BlockingDroppingQueue<WikipediaEditsDataset.WikipediaEdit> buffer, String language) Construct the edit stream with the given buffer and language.
WikipediaEditsDataset(String lang) Construct the edit stream with an ArrayBlockingDroppingQueue of capacity 1.

Method Summary

Modifier and Type	Method and Description
WikipediaEditsDataset.WikipediaEdit	construct(String channel, String sender, String login, String hostname, String message) Called by PircBot.onMessage(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String)

Methods inherited from class org.openimaj.stream.provider.irc.AbstractIRCStreamDataset

getRandomInstance, numInstances, register

Methods inherited from class org.openimaj.util.stream.BlockingDroppingBufferedStream

close, getBuffer, hasNext, next

Methods inherited from class org.openimaj.util.stream.AbstractStream

filter, forEach, forEach, forEach, iterator, map, map, parallelForEach, parallelForEach, remove, transform

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.openimaj.util.stream.Stream

filter, forEach, forEach, forEach, map, map, parallelForEach, parallelForEach, transform

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext, next, remove

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Constructor Detail

WikipediaEditsDataset

public WikipediaEditsDataset(BlockingDroppingQueue<WikipediaEditsDataset.WikipediaEdit> buffer,
                             String language)
                      throws IOException

Construct the edit stream with the given buffer and language.

Parameters:

buffer - the buffer

language - the language id; currently only English "en" is supported

Throws:

IOException - if there is a problem connecting

WikipediaEditsDataset

public WikipediaEditsDataset(String lang)
                      throws IOException

Construct the edit stream with an ArrayBlockingDroppingQueue of capacity 1.

Parameters:

lang - the language id; currently only English "en" is supported

Throws:

IOException - if there is a problem connecting

Method Detail

construct

public WikipediaEditsDataset.WikipediaEdit construct(String channel,
                                                     String sender,
                                                     String login,
                                                     String hostname,
                                                     String message)

Description copied from class: AbstractIRCStreamDataset

Called by PircBot.onMessage(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String)

Specified by:

construct in class AbstractIRCStreamDataset<WikipediaEditsDataset.WikipediaEdit>

Parameters:

channel - the channel to which the message was sent

sender - the sender of the message (their nick)

login - the login of the message sender

hostname - the hostname of the message sender

message - the message itself

Returns:

the object the stream produces