ch.ethz.mxquery.sms.interfaces
Interface AppendUpdate

All Superinterfaces:

Source, StreamStore

All Known Subinterfaces:

MXQueryAppendUpdate

All Known Implementing Classes:

FIFOStore, FTTokenBufferStore, IndexFIFOStore, LazyFIFOStore, LazyRandomFIFOStore, LazySequentialFIFOStore, RandomFIFOStore, RandomFIFOStoreSchema, SeqFIFOStore, SharedRandomFIFOStore, SharedSeqFIFOStore, TokenBufferStore

public interface AppendUpdate
extends StreamStore

Interface for FIFO udpates (new data - only inserts; update state - delete consumed)

Method Summary

void	deleteItems(int lastItemId) Mark as consumed all items up to lastItemId

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

buffer, get, getMyId, newItem, setIterator

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

compare, copySource, getIterator, getURI

Method Detail

deleteItems

void deleteItems(int lastItemId)
                 throws MXQueryException

Mark as consumed all items up to lastItemId

Parameters:

lastItemId - Id of the item that was consumed last

Throws:

MXQueryException