org.imemex.operators
Class AbstractPushOperator<E>

java.lang.Object
  java.util.Observable
      org.imemex.operators.AbstractPushOperator<E>

Type Parameters:

E -

All Implemented Interfaces:

Operator, PushOperator<E>

Direct Known Subclasses:

OIDPushMapper, PluginIdentifiableRVIdentifiableRVPushMapper

public class AbstractPushOperator<E>
extends java.util.Observable
implements PushOperator<E>

An abstract implementation of PushOperator based on the pull paradigm.

Author:

?

Nested Class Summary

Nested classes/interfaces inherited from interface org.imemex.operators.Operator

Operator.ExecTimeType

Constructor Summary

AbstractPushOperator()

Method Summary

void	addExecTime(long nanos, Operator.ExecTimeType type) If an operator implementor wants - and it would if everyone did, he may collect execution times using this method.
void	close() Does nothing.
java.lang.String	getDesc() Get description.
long	getExecTime(Operator.ExecTimeType type) Get collected execution times.
OperatorMetaData	getMetaData() Get additional information about this operator.
long	getNumberOfElementsPassed() Get the number of results produced so far.
void	open() Does nothing.
void	pass(E object) Passes the next
void	setDesc(java.lang.String description) Set description.
java.lang.String	toXML() Get an XML representation of this pull operator.

Methods inherited from class java.util.Observable

addObserver, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractPushOperator

public AbstractPushOperator()

Method Detail

open

public void open()

Does nothing.

Specified by:

open in interface Operator

pass

public void pass(E object)

Description copied from interface: PushOperator

Passes the next