org.apache.fluo.api.observer

Class AbstractObserver

java.lang.Object

org.apache.fluo.api.observer.AbstractObserver

All Implemented Interfaces:

Observer

public abstract class AbstractObserver
extends Object
implements Observer

Implemented by users to a watch a Column and be notified of changes to the Column via the Observer.process(TransactionBase, org.apache.fluo.api.data.Bytes, org.apache.fluo.api.data.Column) method. AbstractObserver extends Observer but provides a default implementation for the Observer.init(Context) and close() method so that they can be optionally implemented by user.

Since:

1.0.0

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.fluo.api.observer.Observer

Observer.Context, Observer.NotificationType, Observer.ObservedColumn

Constructor Summary

Constructors

Constructor and Description
AbstractObserver()

Method Summary

Modifier and Type	Method and Description
void	close() Implemented by user to close resources used by Observer
void	init(Observer.Context context) Implemented by user to initialize Observer.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.fluo.api.observer.Observer

getObservedColumn, process

Constructor Detail

AbstractObserver

public AbstractObserver()

Method Detail

init

public void init(Observer.Context context)
          throws Exception

Description copied from interface: Observer

Implemented by user to initialize Observer.

Specified by:

init in interface Observer

Parameters:

context - Observer context

Throws:

Exception

close

public void close()

Description copied from interface: Observer

Implemented by user to close resources used by Observer

Specified by:

close in interface Observer