A C D G H I J L M N O P R S

A

addLanguageExtension(Activity, Article) - Static method in class org.apache.streams.moreover.MoreoverUtils

addLanguageExtension.

addLocationExtension(Activity, Source) - Static method in class org.apache.streams.moreover.MoreoverUtils

addLocationExtension.

C

cleanUp() - Method in class org.apache.streams.moreover.MoreoverProvider

convert(Article) - Static method in class org.apache.streams.moreover.MoreoverUtils

convert article into Activity.

convert(Source) - Static method in class org.apache.streams.moreover.MoreoverUtils

convert Source to Provider.

convert(Author, String) - Static method in class org.apache.streams.moreover.MoreoverUtils

convert Author and platformName to Actor.

convertObject(Article) - Static method in class org.apache.streams.moreover.MoreoverUtils

convertObject.

convertTarget(Source) - Static method in class org.apache.streams.moreover.MoreoverUtils

convertTarget.

D

DATE_FORMAT - Static variable in class org.apache.streams.moreover.MoreoverUtils

deserialize(String) - Method in class org.apache.streams.moreover.MoreoverJsonActivitySerializer

deserialize(String) - Method in class org.apache.streams.moreover.MoreoverXmlActivitySerializer

deserializeAll(List<String>) - Method in class org.apache.streams.moreover.MoreoverJsonActivitySerializer

deserializeAll(List<String>) - Method in class org.apache.streams.moreover.MoreoverXmlActivitySerializer

G

getArticlesAfter(String, int) - Method in class org.apache.streams.moreover.MoreoverClient

get limit ArticlesAfter sequenceId.

getClientId() - Method in class org.apache.streams.moreover.MoreoverResult

getEnd() - Method in class org.apache.streams.moreover.MoreoverResult

getId() - Method in class org.apache.streams.moreover.MoreoverProvider

getMaxSequencedId() - Method in class org.apache.streams.moreover.MoreoverResult

getNextBatch() - Method in class org.apache.streams.moreover.MoreoverClient

getStart() - Method in class org.apache.streams.moreover.MoreoverResult

getXmlString() - Method in class org.apache.streams.moreover.MoreoverResult

H

hasNext() - Method in class org.apache.streams.moreover.MoreoverResult.JsonStringIterator

I

isRunning() - Method in class org.apache.streams.moreover.MoreoverProvider

iterator() - Method in class org.apache.streams.moreover.MoreoverResult

J

JsonStringIterator(Iterator<Serializable>) - Constructor for class org.apache.streams.moreover.MoreoverResult.JsonStringIterator

L

LATENCY - Static variable in class org.apache.streams.moreover.MoreoverProviderTask

list - Variable in class org.apache.streams.moreover.MoreoverResult

M

main(String[]) - Static method in class org.apache.streams.moreover.MoreoverProvider

To use from command line:

Supply configuration similar to src/test/resources/rss.conf

Launch using:

mvn exec:java -Dexec.mainClass=org.apache.streams.moreover.MoreoverProvider -Dexec.args="rss.conf articles.json"

MoreoverClient - Class in org.apache.streams.moreover

MoreoverClient is a Client for Moreover.

MoreoverClient(String, String, String) - Constructor for class org.apache.streams.moreover.MoreoverClient

MoreoverClient constructor.

MoreoverJsonActivitySerializer - Class in org.apache.streams.moreover

Deserializes Moreover JSON format into Activities.

MoreoverJsonActivitySerializer() - Constructor for class org.apache.streams.moreover.MoreoverJsonActivitySerializer

MoreoverProvider - Class in org.apache.streams.moreover

Streams Provider for the Moreover Metabase API.

MoreoverProvider(MoreoverConfiguration) - Constructor for class org.apache.streams.moreover.MoreoverProvider

MoreoverProvider constructor.

MoreoverProviderTask - Class in org.apache.streams.moreover

Task that pulls from the Morever API on behalf of MoreoverProvider.

MoreoverProviderTask(String, String, Queue<StreamsDatum>, String) - Constructor for class org.apache.streams.moreover.MoreoverProviderTask

MoreoverProviderTask constructor.

MoreoverResult - Class in org.apache.streams.moreover

MoreoverResult(String, String, long, long) - Constructor for class org.apache.streams.moreover.MoreoverResult

MoreoverResult.JsonStringIterator - Class in org.apache.streams.moreover

MoreoverUtils - Class in org.apache.streams.moreover

Provides utilities for Moreover data.

MoreoverXmlActivitySerializer - Class in org.apache.streams.moreover

Deserializes the Moreover Article XML and converts it to an instance of Activity.

MoreoverXmlActivitySerializer() - Constructor for class org.apache.streams.moreover.MoreoverXmlActivitySerializer

N

next() - Method in class org.apache.streams.moreover.MoreoverResult.JsonStringIterator

O

org.apache.streams.moreover - package org.apache.streams.moreover

P

prepare(Object) - Method in class org.apache.streams.moreover.MoreoverProvider

process() - Method in class org.apache.streams.moreover.MoreoverResult

Process batch and

providerQueue - Variable in class org.apache.streams.moreover.MoreoverProvider

pullTime - Variable in class org.apache.streams.moreover.MoreoverClient

R

readCurrent() - Method in class org.apache.streams.moreover.MoreoverProvider

readNew(BigInteger) - Method in class org.apache.streams.moreover.MoreoverProvider

readRange(DateTime, DateTime) - Method in class org.apache.streams.moreover.MoreoverProvider

remove() - Method in class org.apache.streams.moreover.MoreoverResult.JsonStringIterator

REQUIRED_LATENCY - Static variable in class org.apache.streams.moreover.MoreoverProviderTask

response - Variable in class org.apache.streams.moreover.MoreoverResult

run() - Method in class org.apache.streams.moreover.MoreoverProviderTask

S

serializationFormat() - Method in class org.apache.streams.moreover.MoreoverJsonActivitySerializer

serializationFormat() - Method in class org.apache.streams.moreover.MoreoverXmlActivitySerializer

serialize(Activity) - Method in class org.apache.streams.moreover.MoreoverJsonActivitySerializer

serialize(Activity) - Method in class org.apache.streams.moreover.MoreoverXmlActivitySerializer

startStream() - Method in class org.apache.streams.moreover.MoreoverProvider

STREAMS_ID - Static variable in class org.apache.streams.moreover.MoreoverProvider

A C D G H I J L M N O P R S