org.deri.cqels.engine

Class IndexedTripleRouter

java.lang.Object

org.deri.cqels.engine.OpRouterBase

org.deri.cqels.engine.IndexedTripleRouter

All Implemented Interfaces:

OpRouter

public class IndexedTripleRouter
extends OpRouterBase

This class implements router that it data buffer is a window

Author:

Danh Le Phuoc, Chan Le Van

See Also:

OpRouterBase

Field Summary

Fields

Modifier and Type	Field and Description
static long	accT

Constructor Summary

Constructors

Constructor and Description
IndexedTripleRouter(ExecContext ctx, OpStream op)
IndexedTripleRouter(ExecContext ctx, com.hp.hpl.jena.sparql.algebra.op.OpTriple op, com.hp.hpl.jena.graph.Node graph, Window w)

Method Summary

Methods

Modifier and Type	Method and Description
MappingIterator	getBuff() Each specific router contains a data buffer in the form of mappings This method will get that data buffer out
Window	getWindow()
MappingIterator	searchBuff4Match(Mapping mapping) This method tries to search in the data mapping buffer whether there is any mapping that matches the specified mapping.
void	update(EnQuad enQuad) This method acts as a listener to catch data from Esper engine
void	visit(RouterVisitor rv)

Methods inherited from class org.deri.cqels.engine.OpRouterBase

_route, getId, getOp, route

Methods inherited from class java.lang.Object

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

Field Detail

accT

public static long accT

Constructor Detail

IndexedTripleRouter

public IndexedTripleRouter(ExecContext ctx,
                   com.hp.hpl.jena.sparql.algebra.op.OpTriple op,
                   com.hp.hpl.jena.graph.Node graph,
                   Window w)

Parameters:

ctx - execution context

op - triple

graph -

w - window

IndexedTripleRouter

public IndexedTripleRouter(ExecContext ctx,
                   OpStream op)

Parameters:

ctx - execution context

op - stream

Method Detail

update

public void update(EnQuad enQuad)

This method acts as a listener to catch data from Esper engine

Parameters:

enQuad - the quad coming in

searchBuff4Match

public MappingIterator searchBuff4Match(Mapping mapping)

Description copied from interface: OpRouter

This method tries to search in the data mapping buffer whether there is any mapping that matches the specified mapping.

Specified by:

searchBuff4Match in interface OpRouter

Overrides:

searchBuff4Match in class OpRouterBase

Parameters:

mapping - the specified mapping

Returns:

a mapping iterator of matched mappings in buffer

getBuff

public MappingIterator getBuff()

Description copied from interface: OpRouter

Each specific router contains a data buffer in the form of mappings This method will get that data buffer out

Specified by:

getBuff in interface OpRouter

Overrides:

getBuff in class OpRouterBase

visit

public void visit(RouterVisitor rv)

getWindow

public Window getWindow()