public class InstagramUserInfoCollector extends InstagramDataCollector<org.jinstagram.entity.users.basicinfo.UserInfoData>
InstagramDataCollector
Modifier and Type | Field and Description |
---|---|
protected static int |
MAX_ATTEMPTS |
backOffStrategy, dataQueue
Constructor and Description |
---|
InstagramUserInfoCollector(Queue<StreamsDatum> dataQueue,
InstagramConfiguration config) |
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.
|
getNextInstagramClient, isCompleted, numAvailableTokens, queueData, run
protected static final int MAX_ATTEMPTS
public InstagramUserInfoCollector(Queue<StreamsDatum> dataQueue, InstagramConfiguration config)
protected void collectInstagramDataForUser(User user) throws Exception
InstagramDataCollector
collectInstagramDataForUser
in class InstagramDataCollector<org.jinstagram.entity.users.basicinfo.UserInfoData>
Exception
protected StreamsDatum convertToStreamsDatum(org.jinstagram.entity.users.basicinfo.UserInfoData item)
InstagramDataCollector
convertToStreamsDatum
in class InstagramDataCollector<org.jinstagram.entity.users.basicinfo.UserInfoData>
Copyright © 2017 The Apache Software Foundation. All rights reserved.