public interface ObserverProvider
Observers to process notifications. Implementations of this class should register zero or more
When Fluo is initialized
provideColumns(BiConsumer, Context) is called. The columns it
registers are stored in Zookeeper. Transactions will use the columns stored in Zookeeper to
determine when to set notifications. When Workers call
provide(Registry, Context), the
columns registered must be the same as those registered during initialization. If this is not the
case, then the worker will fail to start.
|Modifier and Type||Interface and Description|
Observers are registered with the worker using this interface.
|Modifier and Type||Method and Description|
This is method is called by Fluo Workers to register observers to process notifications.
Called during Fluo initialization to determine what columns are being observed.
void provide(ObserverProvider.Registry or, ObserverProvider.Context ctx)
Observers registered may be called concurrently by multiple threads to process different notifications. Observers should be tolerant of this.
or- Register observers with this.
default void provideColumns(BiConsumer<Column,Observer.NotificationType> colRegistry, ObserverProvider.Context ctx)
provide(Registry, Context)and ignores Observers.
colRegistry- register all observed columns with this consumer
Copyright © 2016–2017 The Apache Software Foundation. All rights reserved.