ch.ethz.mxquery.sms.MMimpl
Class SharedRandomFIFOStore

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

All Implemented Interfaces:

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

public class SharedRandomFIFOStore
extends FIFOStore
implements RandomRead

Field Summary

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

iterator, readThread

Constructor Summary

SharedRandomFIFOStore(int id, int blockSize, WindowBuffer container)

Method Summary

void	freeBuffers()
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

SharedRandomFIFOStore

public SharedRandomFIFOStore(int id,
                             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

freeBuffers

public void freeBuffers()