org.apache.streams.instagram.provider

Class InstagramCommentsCollector

java.lang.Object

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

org.apache.streams.instagram.provider.InstagramCommentsCollector

All Implemented Interfaces:

Runnable

public class InstagramCommentsCollector
extends InstagramDataCollector<Comment>

Collects Instagram comments on a list of media.

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

Method Summary

Modifier and Type	Method and Description
protected void	collectInstagramCommentsForMedia(String mediaId) Pull Comments on a specific media and queues the resulting data.
protected StreamsDatum	convertToStreamsDatum(Comment 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

InstagramCommentsCollector

public InstagramCommentsCollector(Instagram instagram,
                                  Queue<StreamsDatum> queue,
                                  InstagramCommentsProviderConfiguration config)

Method Detail

run

public void run()

collectInstagramCommentsForMedia

protected void collectInstagramCommentsForMedia(String mediaId)
                                         throws Exception

Pull Comments on a specific media and queues the resulting data.

Parameters:

mediaId - mediaId

Throws:

Exception - Exception

convertToStreamsDatum

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

Parameters:

item - item

Returns:

StreamsDatum