org.apache.streams.instagram.provider

Class InstagramAbstractProvider

java.lang.Object

org.apache.streams.instagram.provider.InstagramAbstractProvider

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsProvider

Direct Known Subclasses:

InstagramCommentsProvider, InstagramEngagersProvider, InstagramLikersProvider, InstagramRecentMediaProvider, InstagramUserInfoProvider

public abstract class InstagramAbstractProvider
extends Object
implements StreamsProvider

Instagram StreamsProvider that provides Instagram data for a group of users

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Instagram	client
protected InstagramConfiguration	config
protected Queue<StreamsDatum>	dataQueue
static String	STREAMS_ID

Constructor Summary

Constructors

Constructor and Description
InstagramAbstractProvider()
InstagramAbstractProvider(InstagramConfiguration config)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
String	getId()
protected abstract InstagramDataCollector	getInstagramDataCollector() Return the data collector to use to connect to instagram.
boolean	isRunning()
void	prepare(Object configurationObject)
StreamsResultSet	readCurrent()
StreamsResultSet	readNew(BigInteger sequence)
StreamsResultSet	readRange(org.joda.time.DateTime start, org.joda.time.DateTime end)
void	startStream()

Methods inherited from class java.lang.Object

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

Field Detail

STREAMS_ID

public static final String STREAMS_ID

See Also:

Constant Field Values

config

protected InstagramConfiguration config

client

protected Instagram client

dataQueue

protected Queue<StreamsDatum> dataQueue

Constructor Detail

InstagramAbstractProvider

public InstagramAbstractProvider()

InstagramAbstractProvider

public InstagramAbstractProvider(InstagramConfiguration config)

Method Detail

getId

public String getId()

Specified by:

getId in interface StreamsOperation

startStream

public void startStream()

Specified by:

startStream in interface StreamsProvider

getInstagramDataCollector

protected abstract InstagramDataCollector getInstagramDataCollector()

Return the data collector to use to connect to instagram.

Returns:

InstagramDataCollector

readCurrent

public StreamsResultSet readCurrent()

Specified by:

readCurrent in interface StreamsProvider

readNew

public StreamsResultSet readNew(BigInteger sequence)

Specified by:

readNew in interface StreamsProvider

readRange

public StreamsResultSet readRange(org.joda.time.DateTime start,
                                  org.joda.time.DateTime end)

Specified by:

readRange in interface StreamsProvider

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation

isRunning

public boolean isRunning()

Specified by:

isRunning in interface StreamsProvider