org.apache.streams.instagram.provider.userinfo

Class InstagramUserInfoCollector

java.lang.Object

org.apache.streams.instagram.provider.InstagramDataCollector<UserInfo>

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

All Implemented Interfaces:

Runnable

public class InstagramUserInfoCollector
extends InstagramDataCollector<UserInfo>

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, instagram, isCompleted

Constructor Summary

Constructors

Constructor and Description
InstagramUserInfoCollector(Instagram instagram, Queue<StreamsDatum> dataQueue, InstagramUserInfoProviderConfiguration config)

Method Summary

Modifier and Type	Method and Description
protected void	collectInstagramDataForUser(String userId)
protected StreamsDatum	convertToStreamsDatum(UserInfo item) Takes an Instagram Object and sets it as the document of a streams datum and sets the id of the streams datum.
void	run()

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

getNextInstagramClient, isCompleted, numAvailableTokens, queueData, swapUsernameForId

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(Instagram instagram,
                                  Queue<StreamsDatum> dataQueue,
                                  InstagramUserInfoProviderConfiguration config)

Method Detail

run

public void run()

collectInstagramDataForUser

protected void collectInstagramDataForUser(String userId)
                                    throws Exception

Throws:

Exception

convertToStreamsDatum

protected StreamsDatum convertToStreamsDatum(UserInfo 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<UserInfo>

Parameters:

item - item

Returns:

StreamsDatum