hbase自帶的原有過濾器，呼叫都沒問題
但是自己寫的過濾器卻始終報錯，顯示找不到類
CLASSPATH已經設定，指向 hbase/lib 檔案夾下， 自定義過濾器也打包jar 拷貝到每臺服務端 hbase/lib檔案夾下
hbase也重新啟動。
請問誰知道怎么回事？
報錯日志：
Exception in thread "main" java.lang.NoClassDefFoundError: hadoop/FlowFilter
at hadoop.shellcom.filterHbase(shellcom.java:471)
at hadoop.shellcom.main(shellcom.java:511)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.apache.hadoop.util.RunJar.main(RunJar.java:197)
Caused by: java.lang.ClassNotFoundException: hadoop.FlowFilter
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
自定義過濾器代碼：（拷貝的RowFilter原始碼）
package hadoop;
import org.apache.hadoop.hbase.filter.*;
import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.client.Scan;
import java.util.List;
public class FlowFilter extends CompareFilter {
private boolean filterOutRow = false;
/**
* Writable constructor, do not use.
*/
public FlowFilter() {
super();
}
/**
* Constructor.
* @param rowCompareOp the compare op for row matching
* @param rowComparator the comparator for row matching
*/
public FlowFilter(final CompareOp rowCompareOp,
final WritableByteArrayComparable rowComparator) {
super(rowCompareOp, rowComparator);
}
@Override
public void reset() {
this.filterOutRow = false;
}
@Override
public ReturnCode filterKeyValue(KeyValue v) {
if(this.filterOutRow) {
return ReturnCode.NEXT_ROW;
}
return ReturnCode.INCLUDE;
}
@Override
public boolean filterRowKey(byte[] data, int offset, int length) {
if(doCompare(this.compareOp, this.comparator, data, offset, length)) {
this.filterOutRow = true;
}
return this.filterOutRow;
}
@Override
public boolean filterRow() {
return this.filterOutRow;
}
}
uj5u.com熱心網友回復：
求各位大神幫忙呀轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/106446.html
標籤：其他數據庫
上一篇：新手求教 如何洗掉非整點時間資料