ch.ethz.mxquery.sms.MMimpl
Class FIFOStore

java.lang.Object
  ch.ethz.mxquery.sms.MMimpl.FIFOStore

All Implemented Interfaces:

Source, ActiveStore, AppendUpdate, StreamStore, MXQueryAppendUpdate

Direct Known Subclasses:

RandomFIFOStore, RandomFIFOStoreSchema, SeqFIFOStore, SharedRandomFIFOStore, SharedSeqFIFOStore, TokenBufferStore

public abstract class FIFOStore
extends java.lang.Object
implements MXQueryAppendUpdate, ActiveStore

Field Summary

XDMIterator	iterator
ReadDataThread	readThread

Method Summary

void	buffer(Token token, int event) Materialize the given token into the store instance
int	compare(Source store)
Source	copySource(Context ctx, java.util.Vector nestedPredCtxStack)
void	deleteItems(int nodeId) Mark as consumed all items up to lastItemId
Token	get(int activeTokenId) Get Token at given position
Token	get(int activeTokenId, int endNode)
int	getAttributePosFromNodeId(java.lang.String attrName, int nodeId)
int	getAttributePosFromTokenId(java.lang.String attrName, int activeTokenId)
int	getCurrentTokenId()
Window	getIterator(Context ctx) Returns Iterator that points on the first token in the store.
int	getMyId() Returns the store id (mostly for debugging)
int	getNodeIdFromTokenId(int lastKnownNodeId, int activeTokenId)
int	getSize()
int	getTokenIdForNode(int nodeId)
java.lang.String	getURI() Returns the URI of the source.
boolean	hasNode(int nodeId)
void	newItem() Specify the beginning of a new item
void	setContainer(WindowBuffer buf)
void	setContext(Context context)
void	setIterator(XDMIterator it) For pull stores, add the iterator from which they should pull their data

Methods inherited from class java.lang.Object

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

Methods inherited from interface ch.ethz.mxquery.sms.interfaces.ActiveStore

start

Field Detail

iterator

public XDMIterator iterator

readThread

public ReadDataThread readThread

Method Detail

getMyId

public int getMyId()

Description copied from interface: StreamStore

Returns the store id (mostly for debugging)

Specified by:

getMyId in interface StreamStore

Returns:

id of the store given at creation time

setContainer

public void setContainer(WindowBuffer buf)

Specified by:

setContainer in interface MXQueryAppendUpdate

setIterator

public void setIterator(XDMIterator it)

Description copied from interface: StreamStore

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

Specified by:

setIterator in interface StreamStore

setContext

public void setContext(Context context)
                throws MXQueryException

Specified by:

setContext in interface MXQueryAppendUpdate

Throws:

MXQueryException

get

public Token get(int activeTokenId)
          throws MXQueryException

Description copied from interface: StreamStore

Get Token at given position

Specified by:

get in interface StreamStore

Specified by:

get in interface MXQueryAppendUpdate

Parameters:

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

Returns:

the Token at the given position

Throws:

MXQueryException

get

public Token get(int activeTokenId,
                 int endNode)
          throws MXQueryException

Specified by:

get in interface MXQueryAppendUpdate

Throws:

MXQueryException

getNodeIdFromTokenId

public int getNodeIdFromTokenId(int lastKnownNodeId,
                                int activeTokenId)
                         throws MXQueryException

Specified by:

getNodeIdFromTokenId in interface MXQueryAppendUpdate

Throws:

MXQueryException

hasNode

public boolean hasNode(int nodeId)
                throws MXQueryException

Specified by:

hasNode in interface MXQueryAppendUpdate

Throws:

MXQueryException

getTokenIdForNode

public int getTokenIdForNode(int nodeId)
                      throws MXQueryException

Specified by:

getTokenIdForNode in interface MXQueryAppendUpdate

Throws:

MXQueryException

deleteItems

public void deleteItems(int nodeId)
                 throws MXQueryException

Description copied from interface: AppendUpdate

Mark as consumed all items up to lastItemId

Specified by:

deleteItems in interface AppendUpdate

Parameters:

nodeId - Id of the item that was consumed last

Throws:

MXQueryException

getSize

public int getSize()

newItem

public void newItem()

Description copied from interface: StreamStore

Specify the beginning of a new item

Specified by:

newItem in interface StreamStore

buffer

public void buffer(Token token,
                   int event)
            throws MXQueryException

Description copied from interface: StreamStore

Materialize the given token into the store instance

Specified by:

buffer in interface StreamStore

Throws:

MXQueryException

getAttributePosFromNodeId

public int getAttributePosFromNodeId(java.lang.String attrName,
                                     int nodeId)
                              throws MXQueryException

Throws:

MXQueryException

getAttributePosFromTokenId

public int getAttributePosFromTokenId(java.lang.String attrName,
                                      int activeTokenId)
                               throws MXQueryException

Throws:

MXQueryException

getCurrentTokenId

public int getCurrentTokenId()

getIterator

public Window getIterator(Context ctx)
                   throws MXQueryException

Description copied from interface: Source

Returns Iterator that points on the first token in the store.

Specified by:

getIterator in interface Source

Returns:

Iterator a (Window) Iterator to access the contents of this source

Throws:

MXQueryException

compare

public int compare(Source store)

Specified by:

compare in interface Source

copySource

public Source copySource(Context ctx,
                         java.util.Vector nestedPredCtxStack)
                  throws MXQueryException

Specified by:

copySource in interface Source

Throws:

MXQueryException

getURI

public java.lang.String getURI()

Description copied from interface: Source

Returns the URI of the source.

Specified by:

getURI in interface Source

Returns:

a String representing the URI/Identifier of this source