org.apache.streams.instagram.provider

Class InstagramEngagersCollector

java.lang.Object

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

org.apache.streams.instagram.provider.InstagramEngagersCollector

All Implemented Interfaces:

Runnable

public class InstagramEngagersCollector
extends InstagramDataCollector<UserInfo>

Executes on all of the Instagram requests to collect the media feed data.

If errors/exceptions occur when trying to gather data for a particular user, that user is skipped and the collector move on to the next user. If a rate limit exception occurs it employs an exponential back off strategy.

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
InstagramEngagersCollector(Instagram instagram, Queue<StreamsDatum> queue, InstagramEngagersProviderConfiguration config)

Method Summary

Modifier and Type	Method and Description
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

InstagramEngagersCollector

public InstagramEngagersCollector(Instagram instagram,
                                  Queue<StreamsDatum> queue,
                                  InstagramEngagersProviderConfiguration config)

Method Detail

run

public void run()

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