A B C D F G I M O P Q R S U

A

AbstractGPlusProvider - Class in org.apache.streams.gplus.provider

Provider that creates a GPlus client and will run task that queue data to an outing queue.

AbstractGPlusProvider() - Constructor for class org.apache.streams.gplus.provider.AbstractGPlusProvider

AbstractGPlusProvider(GPlusConfiguration) - Constructor for class org.apache.streams.gplus.provider.AbstractGPlusProvider

B

backoffAndIdentifyIfRetry(GoogleJsonResponseException, BackOffStrategy) - Method in class org.apache.streams.gplus.provider.GPlusDataCollector

Looks at the status code of the exception.

C

cleanUp() - Method in class org.apache.streams.gplus.processor.GooglePlusCommentProcessor

cleanUp() - Method in class org.apache.streams.gplus.processor.GooglePlusTypeConverter

cleanUp() - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

collectActivityData() - Method in class org.apache.streams.gplus.provider.GPlusUserActivityCollector

createPlusClient() - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

credential - Variable in class org.apache.streams.gplus.provider.AbstractGPlusProvider

D

deserialize(Activity) - Method in class org.apache.streams.gplus.provider.GPlusActivitySerializer

deserialize(JsonParser, DeserializationContext) - Method in class org.apache.streams.gplus.serializer.util.GPlusActivityDeserializer

Because the GooglePlus Activity object Activity contains complex objects within its hierarchy, we have to use a custom deserializer

deserialize(JsonParser, DeserializationContext) - Method in class org.apache.streams.gplus.serializer.util.GPlusCommentDeserializer

Because the GooglePlus Comment object Comment contains complex objects within its hierarchy, we have to use a custom deserializer

deserialize(JsonParser, DeserializationContext) - Method in class org.apache.streams.gplus.serializer.util.GPlusPersonDeserializer

Because the GooglePlus Person object contains complex objects within its hierarchy, we have to use a custom deserializer

deserializeAll(List<Activity>) - Method in class org.apache.streams.gplus.provider.GPlusActivitySerializer

detectClass(String) - Static method in class org.apache.streams.gplus.serializer.util.GPlusEventClassifier

Detect likely class of String json.

F

formatId(String...) - Static method in class org.apache.streams.gplus.serializer.util.GooglePlusActivityUtil

Formats the ID to conform with the Apache Streams activity ID convention

G

getConfig() - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

getDataCollector(BackOffStrategy, BlockingQueue<StreamsDatum>, Plus, UserInfo) - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

getDataCollector(BackOffStrategy, BlockingQueue<StreamsDatum>, Plus, UserInfo) - Method in class org.apache.streams.gplus.provider.GPlusUserActivityProvider

getDataCollector(BackOffStrategy, BlockingQueue<StreamsDatum>, Plus, UserInfo) - Method in class org.apache.streams.gplus.provider.GPlusUserDataProvider

getId() - Method in class org.apache.streams.gplus.processor.GooglePlusCommentProcessor

getId() - Method in class org.apache.streams.gplus.processor.GooglePlusTypeConverter

getId() - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

getId() - Method in class org.apache.streams.gplus.provider.GPlusUserActivityProvider

getId() - Method in class org.apache.streams.gplus.provider.GPlusUserDataProvider

getProcessorOutputQueue() - Method in class org.apache.streams.gplus.processor.GooglePlusTypeConverter

getProvider() - Static method in class org.apache.streams.gplus.serializer.util.GooglePlusActivityUtil

Gets the common googleplus Provider object

GooglePlusActivityUtil - Class in org.apache.streams.gplus.serializer.util

GooglePlusActivityUtil helps convert c.g.Person and c.g.Activity into o.a.s.p.j.o.Page and o.a.s.p.j.Activity.

GooglePlusActivityUtil() - Constructor for class org.apache.streams.gplus.serializer.util.GooglePlusActivityUtil

GooglePlusCommentProcessor - Class in org.apache.streams.gplus.processor

GooglePlusCommentProcessor collects comments about a google plus activity.

GooglePlusCommentProcessor() - Constructor for class org.apache.streams.gplus.processor.GooglePlusCommentProcessor

GooglePlusTypeConverter - Class in org.apache.streams.gplus.processor

GooglePlusTypeConverter is a StreamsProcessor that converts gplus activities to activitystreams activities.

GooglePlusTypeConverter() - Constructor for class org.apache.streams.gplus.processor.GooglePlusTypeConverter

GPlusActivityDeserializer - Class in org.apache.streams.gplus.serializer.util

Custom deserializer for GooglePlus' Person model.

GPlusActivityDeserializer() - Constructor for class org.apache.streams.gplus.serializer.util.GPlusActivityDeserializer

GPlusActivitySerializer - Class in org.apache.streams.gplus.provider

GPlusActivitySerializer converts gplus activities to as1 activities.

GPlusActivitySerializer(AbstractGPlusProvider) - Constructor for class org.apache.streams.gplus.provider.GPlusActivitySerializer

GPlusActivitySerializer() - Constructor for class org.apache.streams.gplus.provider.GPlusActivitySerializer

GPlusCommentDeserializer - Class in org.apache.streams.gplus.serializer.util

GPlusCommentDeserializer converts gplus comments to as1 comments.

GPlusCommentDeserializer() - Constructor for class org.apache.streams.gplus.serializer.util.GPlusCommentDeserializer

GPlusDataCollector - Class in org.apache.streams.gplus.provider

GPlusDataCollector collects GPlus Data on behalf of providers.

GPlusDataCollector() - Constructor for class org.apache.streams.gplus.provider.GPlusDataCollector

GPlusEventClassifier - Class in org.apache.streams.gplus.serializer.util

GPlusEventClassifier classifies GPlus Events.

GPlusEventClassifier() - Constructor for class org.apache.streams.gplus.serializer.util.GPlusEventClassifier

GPlusPersonDeserializer - Class in org.apache.streams.gplus.serializer.util

Custom deserializer for GooglePlus' Person model.

GPlusPersonDeserializer() - Constructor for class org.apache.streams.gplus.serializer.util.GPlusPersonDeserializer

GPlusUserActivityCollector - Class in org.apache.streams.gplus.provider

Collects the public activities of a GPlus user.

GPlusUserActivityCollector(Plus, BlockingQueue<StreamsDatum>, BackOffStrategy, UserInfo) - Constructor for class org.apache.streams.gplus.provider.GPlusUserActivityCollector

GPlusUserActivityCollector constructor.

GPlusUserActivityProvider - Class in org.apache.streams.gplus.provider

Retrieve recent activity from a list of accounts.

GPlusUserActivityProvider() - Constructor for class org.apache.streams.gplus.provider.GPlusUserActivityProvider

GPlusUserActivityProvider(GPlusConfiguration) - Constructor for class org.apache.streams.gplus.provider.GPlusUserActivityProvider

GPlusUserDataCollector - Class in org.apache.streams.gplus.provider

Collects user profile information for a specific GPlus user.

GPlusUserDataCollector(Plus, BackOffStrategy, BlockingQueue<StreamsDatum>, UserInfo) - Constructor for class org.apache.streams.gplus.provider.GPlusUserDataCollector

GPlusUserDataCollector constructor.

GPlusUserDataProvider - Class in org.apache.streams.gplus.provider

Retrieve current profile status for a list of accounts.

GPlusUserDataProvider() - Constructor for class org.apache.streams.gplus.provider.GPlusUserDataProvider

GPlusUserDataProvider(GPlusConfiguration) - Constructor for class org.apache.streams.gplus.provider.GPlusUserDataProvider

I

isRunning() - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

M

main(String[]) - Static method in class org.apache.streams.gplus.provider.GPlusUserActivityProvider

Retrieve recent activity from a list of accounts.

main(String[]) - Static method in class org.apache.streams.gplus.provider.GPlusUserDataProvider

Retrieve current profile status for a list of accounts.

O

org.apache.streams.gplus.processor - package org.apache.streams.gplus.processor

org.apache.streams.gplus.provider - package org.apache.streams.gplus.provider

org.apache.streams.gplus.serializer.util - package org.apache.streams.gplus.serializer.util

P

plus - Variable in class org.apache.streams.gplus.provider.AbstractGPlusProvider

prepare(Object) - Method in class org.apache.streams.gplus.processor.GooglePlusCommentProcessor

prepare(Object) - Method in class org.apache.streams.gplus.processor.GooglePlusTypeConverter

prepare(Object) - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

process(StreamsDatum) - Method in class org.apache.streams.gplus.processor.GooglePlusCommentProcessor

process(StreamsDatum) - Method in class org.apache.streams.gplus.processor.GooglePlusTypeConverter

Q

queueUserHistory() - Method in class org.apache.streams.gplus.provider.GPlusUserDataCollector

R

readCurrent() - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

readNew(BigInteger) - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

readRange(DateTime, DateTime) - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

run() - Method in class org.apache.streams.gplus.provider.GPlusUserActivityCollector

run() - Method in class org.apache.streams.gplus.provider.GPlusUserDataCollector

S

serializationFormat() - Method in class org.apache.streams.gplus.provider.GPlusActivitySerializer

serialize(Activity) - Method in class org.apache.streams.gplus.provider.GPlusActivitySerializer

setConfig(GPlusConfiguration) - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

setDefaultAfterDate(DateTime) - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

Set and overwrite the default after date that was read from teh configuration file.

setDefaultBeforeDate(DateTime) - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

Set and overwrite the default before date that was read from the configuration file.

setProcessorInputQueue(Queue<Person>) - Method in class org.apache.streams.gplus.processor.GooglePlusTypeConverter

setUserInfoWithAfterDate(Map<String, DateTime>) - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

Set and overwrite user into from the configuration file.

setUserInfoWithDefaultDates(Set<String>) - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

Sets and overwrite the user info from the configuaration file.

startStream() - Method in class org.apache.streams.gplus.provider.AbstractGPlusProvider

STREAMS_ID - Static variable in class org.apache.streams.gplus.processor.GooglePlusTypeConverter

STREAMS_ID - Static variable in class org.apache.streams.gplus.provider.AbstractGPlusProvider

STREAMS_ID - Static variable in class org.apache.streams.gplus.provider.GPlusUserDataProvider

U

updateActivity(Person, Activity) - Static method in class org.apache.streams.gplus.serializer.util.GooglePlusActivityUtil

Given a Person object and an Activity object, fill out the appropriate details.

updateActivity(List<Comment>, Activity) - Static method in class org.apache.streams.gplus.serializer.util.GooglePlusActivityUtil

Given a List of Comment objects and an Activity, update that Activity to contain all comments

updateActivity(Activity, Activity) - Static method in class org.apache.streams.gplus.serializer.util.GooglePlusActivityUtil

Given a Google Plus Activity, convert that into an Activity streams formatted Activity

A B C D F G I M O P Q R S U