C D E F G H I M O P Q R S T W

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

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

deserializeWithRomeExtension ObjectNode entry withExtension.

E

equals(Object) - Method in class org.apache.streams.rss.FeedDetails

equals(Object) - Method in class org.apache.streams.rss.RssStreamConfiguration

F

FeedDetails - Class in org.apache.streams.rss

FeedDetails() - Constructor for class org.apache.streams.rss.FeedDetails

G

getAdditionalProperties() - Method in class org.apache.streams.rss.FeedDetails

getAdditionalProperties() - Method in class org.apache.streams.rss.RssStreamConfiguration

getFeeds() - Method in class org.apache.streams.rss.RssStreamConfiguration

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

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

getPollIntervalMillis() - Method in class org.apache.streams.rss.FeedDetails

Polling interval in ms

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

getUrl() - Method in class org.apache.streams.rss.FeedDetails

The feed url

H

hashCode() - Method in class org.apache.streams.rss.FeedDetails

hashCode() - Method in class org.apache.streams.rss.RssStreamConfiguration

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

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"

O

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

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

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

RssEventProcessor processes Rss Events.

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

RssEventProcessor constructor.

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

RssEventProcessor constructor.

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

RssFeedScheduler launches threads to collect data from rss feeds.

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

RssFeedScheduler constructor.

RssStreamConfiguration - Class in org.apache.streams.rss

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

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

RSS StreamsProvider that provides content from rss feeds in boilerpipe format

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

Schedule Feeds.

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

setAdditionalProperty(String, Object) - Method in class org.apache.streams.rss.FeedDetails

setAdditionalProperty(String, Object) - Method in class org.apache.streams.rss.RssStreamConfiguration

setFeeds(List<FeedDetails>) - Method in class org.apache.streams.rss.RssStreamConfiguration

setPollIntervalMillis(Long) - Method in class org.apache.streams.rss.FeedDetails

Polling interval in ms

setUrl(String) - Method in class org.apache.streams.rss.FeedDetails

The feed url

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

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

toString() - Method in class org.apache.streams.rss.FeedDetails

toString() - Method in class org.apache.streams.rss.RssStreamConfiguration

W

withAdditionalProperty(String, Object) - Method in class org.apache.streams.rss.FeedDetails

withAdditionalProperty(String, Object) - Method in class org.apache.streams.rss.RssStreamConfiguration

withFeeds(List<FeedDetails>) - Method in class org.apache.streams.rss.RssStreamConfiguration

withPollIntervalMillis(Long) - Method in class org.apache.streams.rss.FeedDetails

withUrl(String) - Method in class org.apache.streams.rss.FeedDetails

C D E F G H I M O P Q R S T W