public class ExportObserver<K,V>
extends org.apache.fluo.api.observer.AbstractObserver
Constructor and Description |
---|
ExportObserver() |
Modifier and Type | Method and Description |
---|---|
org.apache.fluo.api.observer.Observer.ObservedColumn |
getObservedColumn() |
protected String |
getQueueId() |
void |
init(org.apache.fluo.api.observer.Observer.Context context) |
void |
process(org.apache.fluo.api.client.TransactionBase tx,
org.apache.fluo.api.data.Bytes row,
org.apache.fluo.api.data.Column column) |
protected String getQueueId()
public void init(org.apache.fluo.api.observer.Observer.Context context) throws Exception
init
in interface org.apache.fluo.api.observer.Observer
init
in class org.apache.fluo.api.observer.AbstractObserver
Exception
public org.apache.fluo.api.observer.Observer.ObservedColumn getObservedColumn()
Copyright © 2016 The Apache Software Foundation. All rights reserved.