ch.ethz.mxquery.sms.interfaces
Interface StreamStore

All Superinterfaces:

Source

All Known Subinterfaces:

AppendUpdate, IndexUpdate, MXQueryAppendUpdate, RandomUpdate

All Known Implementing Classes:

FIFOStore, FTTokenBufferStore, IndexFIFOStore, IndexInPlaceStore, IndexRandomStore, InPlaceStore, LazyFIFOStore, LazyRandomFIFOStore, LazySequentialFIFOStore, RandomFIFOStore, RandomFIFOStoreSchema, RandomStore, SeqFIFOStore, SharedRandomFIFOStore, SharedSeqFIFOStore, TokenBufferStore, UpdateTokenBuffer

public interface StreamStore
extends Source

Method Summary

void	buffer(Token tok, int event) Materialize the given token into the store instance
Token	get(int pos) Get Token at given position
int	getMyId() Returns the store id (mostly for debugging)
void	newItem() Specify the beginning of a new item
void	setIterator(XDMIterator it) For pull stores, add the iterator from which they should pull their data

Methods inherited from interface ch.ethz.mxquery.datamodel.Source

compare, copySource, getIterator, getURI

Method Detail

getMyId

int getMyId()

Returns the store id (mostly for debugging)

Returns:

id of the store given at creation time

get

Token get(int pos)
          throws MXQueryException

Get Token at given position

Parameters:

pos - Unique id given to the token inside this store instance (token position

Returns:

the Token at the given position

Throws:

MXQueryException

buffer

void buffer(Token tok,
            int event)
            throws MXQueryException

Materialize the given token into the store instance

Parameters:

tok -

event -

Throws:

MXQueryException

newItem

void newItem()

Specify the beginning of a new item

setIterator

void setIterator(XDMIterator it)
                 throws MXQueryException

For pull stores, add the iterator from which they should pull their data

Parameters:

it -

Throws:

MXQueryException