org.apache.streams.youtube.provider

Class YoutubeProvider

java.lang.Object

org.apache.streams.youtube.provider.YoutubeProvider

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsProvider

Direct Known Subclasses:

YoutubeChannelProvider, YoutubeUserActivityProvider

public abstract class YoutubeProvider
extends Object
implements StreamsProvider

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected YoutubeConfiguration	config
protected com.google.api.services.youtube.YouTube	youtube

Constructor Summary

Constructors

Constructor and Description
YoutubeProvider() YoutubeProvider constructor.
YoutubeProvider(YoutubeConfiguration config) YoutubeProvider constructor - uses supplied YoutubeConfiguration.

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
protected com.google.api.services.youtube.YouTube	createYouTubeClient()
YoutubeConfiguration	getConfig()
protected abstract Runnable	getDataCollector(BackOffStrategy strategy, BlockingQueue<StreamsDatum> queue, com.google.api.services.youtube.YouTube youtube, UserInfo userInfo)
String	getId()
boolean	isRunning()
void	prepare(Object configurationObject)
StreamsResultSet	readCurrent()
StreamsResultSet	readNew(BigInteger sequence)
StreamsResultSet	readRange(org.joda.time.DateTime start, org.joda.time.DateTime end)
void	setConfig(YoutubeConfiguration config)
void	setDefaultAfterDate(org.joda.time.DateTime defaultAfterDate) Set and overwrite the default after date that was read from teh configuration file.
void	setDefaultBeforeDate(org.joda.time.DateTime defaultBeforeDate) Set and overwrite the default before date that was read from the configuration file.
void	setUserInfoWithAfterDate(Map<String,org.joda.time.DateTime> usersAndAfterDates) Set and overwrite user into from teh configuration file.
void	setUserInfoWithDefaultDates(Set<String> userIds) Sets and overwrite the user info from the configuaration file.
void	startStream()

Methods inherited from class java.lang.Object

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

Field Detail

youtube

protected com.google.api.services.youtube.YouTube youtube

config

protected YoutubeConfiguration config

Constructor Detail

YoutubeProvider

public YoutubeProvider()

YoutubeProvider constructor.

YoutubeProvider

public YoutubeProvider(YoutubeConfiguration config)

YoutubeProvider constructor - uses supplied YoutubeConfiguration.

Parameters:

config - YoutubeConfiguration

Method Detail

getId

public String getId()

Specified by:

getId in interface StreamsOperation

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

startStream

public void startStream()

Specified by:

startStream in interface StreamsProvider

getDataCollector

protected abstract Runnable getDataCollector(BackOffStrategy strategy,
                                             BlockingQueue<StreamsDatum> queue,
                                             com.google.api.services.youtube.YouTube youtube,
                                             UserInfo userInfo)

readCurrent

public StreamsResultSet readCurrent()

Specified by:

readCurrent in interface StreamsProvider

readNew

public StreamsResultSet readNew(BigInteger sequence)

Specified by:

readNew in interface StreamsProvider

readRange

public StreamsResultSet readRange(org.joda.time.DateTime start,
                                  org.joda.time.DateTime end)

Specified by:

readRange in interface StreamsProvider

createYouTubeClient

protected com.google.api.services.youtube.YouTube createYouTubeClient()
                                                               throws IOException,
                                                                      GeneralSecurityException

Throws:

IOException

GeneralSecurityException

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation

getConfig

public YoutubeConfiguration getConfig()

setConfig

public void setConfig(YoutubeConfiguration config)

setDefaultBeforeDate

public void setDefaultBeforeDate(org.joda.time.DateTime defaultBeforeDate)

Set and overwrite the default before date that was read from the configuration file.

Parameters:

defaultBeforeDate - defaultBeforeDate

setDefaultAfterDate

public void setDefaultAfterDate(org.joda.time.DateTime defaultAfterDate)

Set and overwrite the default after date that was read from teh configuration file.

Parameters:

defaultAfterDate - defaultAfterDate

setUserInfoWithDefaultDates

public void setUserInfoWithDefaultDates(Set<String> userIds)

Sets and overwrite the user info from the configuaration file. Uses the defaults before and after dates.

Parameters:

userIds - Set of String userIds

setUserInfoWithAfterDate

public void setUserInfoWithAfterDate(Map<String,org.joda.time.DateTime> usersAndAfterDates)

Set and overwrite user into from teh configuration file. Only sets after dater.

Parameters:

usersAndAfterDates - usersAndAfterDates

isRunning

public boolean isRunning()

Specified by:

isRunning in interface StreamsProvider