C D G I M O P Q R S T

C

cleanUp() - Method in class org.apache.streams.rss.processor.RssTypeConverter

cleanUp() - Method in class org.apache.streams.rss.provider.RssStreamProvider

D

deserialize(ObjectNode) - Method in class org.apache.streams.rss.serializer.SyndEntryActivitySerializer

deserialize(SyndEntry) - Method in class org.apache.streams.rss.serializer.SyndEntrySerializer

deserializeAll(List<ObjectNode>) - Method in class org.apache.streams.rss.serializer.SyndEntryActivitySerializer

deserializeAll(Collection<SyndEntry>) - Method in class org.apache.streams.rss.serializer.SyndEntrySerializer

deserializeWithRomeExtension(ObjectNode, boolean) - Method in class org.apache.streams.rss.serializer.SyndEntryActivitySerializer

detectClass(ObjectNode) - Static method in class org.apache.streams.rss.provider.RssEventClassifier

G

getId() - Method in class org.apache.streams.rss.processor.RssTypeConverter

getId() - Method in class org.apache.streams.rss.provider.RssStreamProvider

getRssFeed() - Method in class org.apache.streams.rss.provider.RssStreamProviderTask

The rss feed url that this task is responsible for reading

getScheduler(BlockingQueue<StreamsDatum>) - Method in class org.apache.streams.rss.provider.RssStreamProvider

I

isComplete() - Method in class org.apache.streams.rss.provider.perpetual.RssFeedScheduler

isRunning() - Method in class org.apache.streams.rss.provider.RssStreamProvider

M

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

O

org.apache.streams.rss.processor - package org.apache.streams.rss.processor

org.apache.streams.rss.provider - package org.apache.streams.rss.provider

org.apache.streams.rss.provider.perpetual - package org.apache.streams.rss.provider.perpetual

org.apache.streams.rss.serializer - package org.apache.streams.rss.serializer

P

prepare(Object) - Method in class org.apache.streams.rss.processor.RssTypeConverter

prepare(Object) - Method in class org.apache.streams.rss.provider.RssStreamProvider

PREVIOUSLY_SEEN - Static variable in class org.apache.streams.rss.provider.RssStreamProviderTask

Map that contains the Set of previously seen articles by an rss feed.

process(StreamsDatum) - Method in class org.apache.streams.rss.processor.RssTypeConverter

Q

queueFeedEntries(URL) - Method in class org.apache.streams.rss.provider.RssStreamProviderTask

Reads the url and queues the data

R

readCurrent() - Method in class org.apache.streams.rss.provider.RssStreamProvider

readNew(BigInteger) - Method in class org.apache.streams.rss.provider.RssStreamProvider

readRange(DateTime, DateTime) - Method in class org.apache.streams.rss.provider.RssStreamProvider

RssEventClassifier - Class in org.apache.streams.rss.provider

Created by sblackmon on 12/13/13.

RssEventClassifier() - Constructor for class org.apache.streams.rss.provider.RssEventClassifier

RssEventProcessor - Class in org.apache.streams.rss.provider

RssEventProcessor(Queue<SyndEntry>, Queue<StreamsDatum>, Class, Class) - Constructor for class org.apache.streams.rss.provider.RssEventProcessor

RssEventProcessor(Queue<SyndEntry>, Queue<StreamsDatum>, Class) - Constructor for class org.apache.streams.rss.provider.RssEventProcessor

RssFeedScheduler - Class in org.apache.streams.rss.provider.perpetual

RssFeedScheduler(ExecutorService, List<FeedDetails>, BlockingQueue<StreamsDatum>) - Constructor for class org.apache.streams.rss.provider.perpetual.RssFeedScheduler

RssFeedScheduler(ExecutorService, List<FeedDetails>, BlockingQueue<StreamsDatum>, int) - Constructor for class org.apache.streams.rss.provider.perpetual.RssFeedScheduler

RssStreamProvider - Class in org.apache.streams.rss.provider

RSS StreamsProvider that provides content from rss feeds in boilerpipe format To use from command line: Supply configuration similar to src/test/resources/rss.conf Launch using: mvn exec:java -Dexec.mainClass=org.apache.streams.rss.provider.RssStreamProvider -Dexec.args="rss.conf articles.json"

RssStreamProvider() - Constructor for class org.apache.streams.rss.provider.RssStreamProvider

RssStreamProvider(boolean) - Constructor for class org.apache.streams.rss.provider.RssStreamProvider

RssStreamProvider(RssStreamConfiguration) - Constructor for class org.apache.streams.rss.provider.RssStreamProvider

RssStreamProvider(RssStreamConfiguration, boolean) - Constructor for class org.apache.streams.rss.provider.RssStreamProvider

RssStreamProviderTask - Class in org.apache.streams.rss.provider

A Runnable task that queues rss feed data.

RssStreamProviderTask(BlockingQueue<StreamsDatum>, String) - Constructor for class org.apache.streams.rss.provider.RssStreamProviderTask

Non-perpetual mode, no date filter, time out of 10 sec

RssStreamProviderTask(BlockingQueue<StreamsDatum>, String, int) - Constructor for class org.apache.streams.rss.provider.RssStreamProviderTask

Non-perpetual mode, no date filter

RssStreamProviderTask(BlockingQueue<StreamsDatum>, String, DateTime) - Constructor for class org.apache.streams.rss.provider.RssStreamProviderTask

Non-perpetual mode, time out of 10 sec

RssStreamProviderTask(BlockingQueue<StreamsDatum>, String, DateTime, int, boolean) - Constructor for class org.apache.streams.rss.provider.RssStreamProviderTask

RssStreamProviderTask that reads an rss feed url and queues the resulting articles as StreamsDatums with the documents being object nodes.

RssTypeConverter - Class in org.apache.streams.rss.processor

Converts ObjectNode representations of Rome SyndEntries to activities.

RssTypeConverter() - Constructor for class org.apache.streams.rss.processor.RssTypeConverter

run() - Method in class org.apache.streams.rss.provider.perpetual.RssFeedScheduler

run() - Method in class org.apache.streams.rss.provider.RssEventProcessor

run() - Method in class org.apache.streams.rss.provider.RssStreamProviderTask

S

scheduleFeeds() - Method in class org.apache.streams.rss.provider.perpetual.RssFeedScheduler

scheduler - Variable in class org.apache.streams.rss.provider.RssStreamProvider

serializationFormat() - Method in class org.apache.streams.rss.serializer.SyndEntryActivitySerializer

serialize(Activity) - Method in class org.apache.streams.rss.serializer.SyndEntryActivitySerializer

setConfig(RssStreamConfiguration) - Method in class org.apache.streams.rss.provider.RssStreamProvider

setRssFeeds(Set<String>) - Method in class org.apache.streams.rss.provider.RssStreamProvider

setRssFeeds(Map<String, Long>) - Method in class org.apache.streams.rss.provider.RssStreamProvider

startStream() - Method in class org.apache.streams.rss.provider.RssStreamProvider

stop() - Method in class org.apache.streams.rss.provider.perpetual.RssFeedScheduler

STREAMS_ID - Static variable in class org.apache.streams.rss.processor.RssTypeConverter

STREAMS_ID - Static variable in class org.apache.streams.rss.provider.RssStreamProvider

SyndEntryActivitySerializer - Class in org.apache.streams.rss.serializer

SyndEntryActivitySerializer() - Constructor for class org.apache.streams.rss.serializer.SyndEntryActivitySerializer

SyndEntryActivitySerializer(boolean) - Constructor for class org.apache.streams.rss.serializer.SyndEntryActivitySerializer

SyndEntrySerializer - Class in org.apache.streams.rss.serializer

Since SyndEntry is not Serializable, we cannot emit them from any StreamOperation.

SyndEntrySerializer() - Constructor for class org.apache.streams.rss.serializer.SyndEntrySerializer

T

TERMINATE - Static variable in class org.apache.streams.rss.provider.RssEventProcessor

C D G I M O P Q R S T