org.lenskit.data.dao

Class EventCollectionDAO

java.lang.Object

org.lenskit.data.dao.EventCollectionDAO

All Implemented Interfaces:

EventDAO

public class EventCollectionDAO
extends Object
implements EventDAO

Data source backed by a collection of events.

Compatibility

Public

Constructor Summary

Constructors

Constructor and Description
EventCollectionDAO(Collection<? extends Event> evts) Deprecated. use create(Collection) instead

Method Summary

Modifier and Type	Method and Description
static EventDAO	create(Collection<? extends Event> evts) Create a new data source from a collection of events.
static EventDAO	create(Event... evts) Create a new data source from an array of events.
static EventDAO	empty() Empty event collection DAO.
static EventDAO	fromStream(ObjectStream<Event> stream) Create a new data source from a stream of events.
static EventDAO	loadAndWrap(EventDAO eventDAO) Create a new data source from an EventDAO.
ObjectStream<Event>	streamEvents() Stream all events.
<E extends Event> ObjectStream<E>	streamEvents(Class<E> type) Stream all events of a given type.
<E extends Event> ObjectStream<E>	streamEvents(Class<E> type, SortOrder order) Stream all events of a given type in a specified order.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

EventCollectionDAO

@Deprecated
public EventCollectionDAO(Collection<? extends Event> evts)

Deprecated. use create(Collection) instead

Construct a new data source from a collection of events.

Parameters:

evts - The events to use.

Method Detail

empty

public static EventDAO empty()

Empty event collection DAO.

Returns:

An empty DAO.

create

public static EventDAO create(Collection<? extends Event> evts)

Create a new data source from a collection of events.

Parameters:

evts - The events collection to be used.

Returns:

A EventCollectionDao generated from events collection.

create

public static EventDAO create(Event... evts)

Create a new data source from an array of events.

Parameters:

evts - The events to be used.

Returns:

A EventCollectionDao generated from the events.

fromStream

public static EventDAO fromStream(@WillClose
                                  ObjectStream<Event> stream)

Create a new data source from a stream of events.

Parameters:

stream - The event stream to be used.

Returns:

An EventCollectionDao generated from events read from the stream.

loadAndWrap

public static EventDAO loadAndWrap(EventDAO eventDAO)

Create a new data source from an EventDAO.

Parameters:

eventDAO - The EventDAO to be used.

Returns:

A EventCollectionDao generated from events read from the DAO’s stream.

streamEvents

public ObjectStream<Event> streamEvents()

Description copied from interface: EventDAO

Stream all events.

Specified by:

streamEvents in interface EventDAO

Returns:

A stream over all events.

streamEvents

public <E extends Event> ObjectStream<E> streamEvents(Class<E> type)

Description copied from interface: EventDAO

Stream all events of a given type.

Specified by:

streamEvents in interface EventDAO

Parameters:

type - The event type.

Returns:

A stream over all events.

streamEvents

public <E extends Event> ObjectStream<E> streamEvents(Class<E> type,
                                                      SortOrder order)

Description copied from interface: EventDAO

Stream all events of a given type in a specified order.

Specified by:

streamEvents in interface EventDAO

Parameters:

type - The event type.

order - The order.

Returns:

A stream over all events.

toString

public String toString()

Overrides:

toString in class Object