org.apache.streams.instagram.provider.userinfo

Class InstagramUserInfoCollector

java.lang.Object

org.apache.streams.instagram.provider.InstagramDataCollector<org.jinstagram.entity.users.basicinfo.UserInfoData>

org.apache.streams.instagram.provider.userinfo.InstagramUserInfoCollector

All Implemented Interfaces:

Runnable

public class InstagramUserInfoCollector
extends InstagramDataCollector<org.jinstagram.entity.users.basicinfo.UserInfoData>

InstagramDataCollector that pulls UserInfoData from Instagram

See Also:

InstagramDataCollector

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	MAX_ATTEMPTS

Fields inherited from class org.apache.streams.instagram.provider.InstagramDataCollector

backOffStrategy, dataQueue

Constructor Summary

Constructors

Constructor and Description
InstagramUserInfoCollector(Queue<StreamsDatum> dataQueue, InstagramConfiguration config)

Method Summary

Modifier and Type	Method and Description
protected void	collectInstagramDataForUser(User user) Pull instagram data for a user and queues the resulting data.
protected StreamsDatum	convertToStreamsDatum(org.jinstagram.entity.users.basicinfo.UserInfoData item) Takes an Instagram Object and sets it as the document of a streams datum and sets the id of the streams datum.

Methods inherited from class org.apache.streams.instagram.provider.InstagramDataCollector

getNextInstagramClient, isCompleted, numAvailableTokens, queueData, run

Methods inherited from class java.lang.Object

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

Field Detail

MAX_ATTEMPTS

protected static final int MAX_ATTEMPTS

See Also:

Constant Field Values

Constructor Detail

InstagramUserInfoCollector

public InstagramUserInfoCollector(Queue<StreamsDatum> dataQueue,
                                  InstagramConfiguration config)

Method Detail

collectInstagramDataForUser

protected void collectInstagramDataForUser(User user)
                                    throws Exception

Description copied from class: InstagramDataCollector

Pull instagram data for a user and queues the resulting data.

Specified by:

collectInstagramDataForUser in class InstagramDataCollector<org.jinstagram.entity.users.basicinfo.UserInfoData>

Throws:

Exception

convertToStreamsDatum

protected StreamsDatum convertToStreamsDatum(org.jinstagram.entity.users.basicinfo.UserInfoData item)

Description copied from class: InstagramDataCollector

Takes an Instagram Object and sets it as the document of a streams datum and sets the id of the streams datum.

Specified by:

convertToStreamsDatum in class InstagramDataCollector<org.jinstagram.entity.users.basicinfo.UserInfoData>

Returns: