ch.ethz.mxquery.sms.MMimpl
Class IndexFIFOStore

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

All Implemented Interfaces:

Source, ActiveStore, AppendUpdate, IndexInterface, IndexRead, RandomRead, ReadInterface, StreamStore, MXQueryAppendUpdate

public class IndexFIFOStore
extends RandomFIFOStore
implements IndexRead

Field Summary

Fields inherited from class ch.ethz.mxquery.sms.MMimpl.FIFOStore

iterator, readThread

Constructor Summary

IndexFIFOStore(int id, int blockSize, WindowBuffer container)

IndexFIFOStore(XDMIterator it, int secondsToStoreData, java.lang.String name, boolean wait, int blockSize, WindowBuffer container)

Method Summary

void	bufferItem(Token[] toks, int size)
void	putElement(Token tok, int event) materialize a new token from the stream; event for avoiding subsequent check for type
IndexSchema	registerIndex(IndexSchema schema) Index schema registration for read/update operations
XDMIterator	retrieve(IndexSchema schema, Token[] tokens)
void	start() Start the gathering of the active store

Methods inherited from class ch.ethz.mxquery.sms.MMimpl.FIFOStore

buffer, compare, copySource, deleteItems, get, get, getAttributePosFromNodeId, getAttributePosFromTokenId, getCurrentTokenId, getIterator, getMyId, getNodeIdFromTokenId, getSize, getTokenIdForNode, getURI, hasNode, newItem, setContainer, setContext, setIterator

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

get, getAttributePosFromNodeId, getAttributePosFromTokenId, getNodeIdFromTokenId, getTokenIdForNode, hasNode

Constructor Detail

IndexFIFOStore

public IndexFIFOStore(int id,
                      int blockSize,
                      WindowBuffer container)

IndexFIFOStore

public IndexFIFOStore(XDMIterator it,
                      int secondsToStoreData,
                      java.lang.String name,
                      boolean wait,
                      int blockSize,
                      WindowBuffer container)

Method Detail

start

public void start()

Description copied from interface: ActiveStore

Start the gathering of the active store

Specified by:

start in interface ActiveStore

Overrides:

start in class RandomFIFOStore

retrieve

public XDMIterator retrieve(IndexSchema schema,
                            Token[] tokens)

Specified by:

retrieve in interface IndexRead

Returns:

iterator with requested data

registerIndex

public IndexSchema registerIndex(IndexSchema schema)

Description copied from interface: IndexInterface

Index schema registration for read/update operations

Specified by:

registerIndex in interface IndexInterface

Parameters:

schema - for index construction

Returns:

-1 if error, else unique index id value ( id >= 0)

putElement

public void putElement(Token tok,
                       int event)
                throws MXQueryException

materialize a new token from the stream; event for avoiding subsequent check for type

Throws:

MXQueryException

bufferItem

public void bufferItem(Token[] toks,
                       int size)
                throws MXQueryException

Throws:

MXQueryException