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

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

C

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

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

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

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

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

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

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

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

MoreoverClient - Class in org.apache.streams.moreover

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

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 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"

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

MoreoverProviderTask - Class in org.apache.streams.moreover

Task to pull from the Morever API

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

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

MoreoverResultSetWrapper - Class in org.apache.streams.moreover

MoreoverResultSetWrapper(MoreoverResult) - Constructor for class org.apache.streams.moreover.MoreoverResultSetWrapper

MoreoverUtils - Class in org.apache.streams.moreover

Provides utilities for Moroever 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

parse(String) - Static method in class org.apache.streams.moreover.MoreoverUtils

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

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

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