com.neurosys.feeds.etl

Class AbstractFeed<T,I extends FeedItem>

java.lang.Object

com.neurosys.feeds.etl.AbstractFeed<T,I>

Type Parameters:

T - as Feed output type

I - as FeedItem type

All Implemented Interfaces:

Process, Feed<T,I>, Serializable, Supplier<T>, org.apache.commons.collections.Transformer

Direct Known Subclasses:

RSS2ChannelFeed, SiteMapFeed

public abstract class AbstractFeed<T,I extends FeedItem>
extends Object
implements Feed<T,I>

Common methods and properties for a feed

Author:

Arjun Dhar

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface com.neurosys.etl.process.Process

Process.Event, Process.EventPoint

Field Summary

Fields

Modifier and Type	Field and Description
protected Consumer<T>	consumer Consumer for items being written
protected Collection<Supplier<Collection<I>>>	itemsSuppliers Collection of Suppliers that provide The items to be supplied for this channel
protected Collection<Consumer<T>>	subFeedConsumers These consume this Feed and add to it.
protected Collection<Supplier<T>>	subFeedSuppliers A sub-feed in the format.

Constructor Summary

Constructors

Constructor and Description
AbstractFeed()

Method Summary

Modifier and Type	Method and Description
Consumer<T>	getConsumer() Consumer for items being written
Collection<Supplier<Collection<I>>>	getItemsSuppliers() Collection of Suppliers that provide The items to be supplied for this channel
Collection<Consumer<T>>	getSubFeedConsumers() These consume this Feed and add to it.
Collection<Supplier<T>>	getSubFeedSuppliers() A sub-feed in the format.
void	setConsumer(Consumer<T> consumer) Consumer for items being written
void	setItemsSuppliers(Collection<Supplier<Collection<I>>> itemsSuppliers) Collection of Suppliers that provide The items to be supplied for this channel
void	setSubFeedConsumers(Collection<Consumer<T>> subFeedConsumers) These consume this Feed and add to it.
void	setSubFeedSuppliers(Collection<Supplier<T>> subFeedSuppliers) A sub-feed in the format.
protected abstract T	writeBaseItem(I item, T feed) Write the base Item for the FeedItem
protected void	writeItems(T feed)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.neurosys.feeds.etl.Feed

transform, writeItemToConsumer

Methods inherited from interface java.util.function.Supplier

get

Field Detail

itemsSuppliers

protected Collection<Supplier<Collection<I extends FeedItem>>> itemsSuppliers

Collection of Suppliers that provide The items to be supplied for this channel

subFeedSuppliers

protected Collection<Supplier<T>> subFeedSuppliers

A sub-feed in the format. Note another Feed can be a Sub-Feed.

subFeedConsumers

protected Collection<Consumer<T>> subFeedConsumers

These consume this Feed and add to it.

consumer

protected Consumer<T> consumer

Consumer for items being written

Constructor Detail

AbstractFeed

public AbstractFeed()

Method Detail

writeItems

protected void writeItems(T feed)

writeBaseItem

protected abstract T writeBaseItem(I item,
                                   T feed)
                            throws Continue

Write the base Item for the FeedItem

Parameters:

item - as FeedItem type

feed - as the feed being written

Returns:

the contribution to the feed due to this unit item

Throws:

{@link - Continue}

Continue

getItemsSuppliers

public Collection<Supplier<Collection<I>>> getItemsSuppliers()

Collection of Suppliers that provide The items to be supplied for this channel

Specified by:

getItemsSuppliers in interface Feed<T,I extends FeedItem>

setItemsSuppliers

public void setItemsSuppliers(Collection<Supplier<Collection<I>>> itemsSuppliers)

Collection of Suppliers that provide The items to be supplied for this channel

Specified by:

setItemsSuppliers in interface Feed<T,I extends FeedItem>

getConsumer

public Consumer<T> getConsumer()

Consumer for items being written

setConsumer

public void setConsumer(Consumer<T> consumer)

Consumer for items being written

getSubFeedSuppliers

public Collection<Supplier<T>> getSubFeedSuppliers()

A sub-feed in the format. Note another Feed can be a Sub-Feed.

setSubFeedSuppliers

public void setSubFeedSuppliers(Collection<Supplier<T>> subFeedSuppliers)

A sub-feed in the format. Note another Feed can be a Sub-Feed.

getSubFeedConsumers

public Collection<Consumer<T>> getSubFeedConsumers()

These consume this Feed and add to it.

setSubFeedConsumers

public void setSubFeedConsumers(Collection<Consumer<T>> subFeedConsumers)

These consume this Feed and add to it.