Hbase过滤器2
根据限定符只返回一行数据，不存在：
public static void addQualifierFilter(FilterList list, byte[] family, byte[] qualifier) { byte[] fakeValue = Bytes.toBytes("DOESNOTEXIST"); SingleColumnValueFilter filter = new SingleColumnValueFilter(family, qualifier, CompareOp.NOT_EQUAL, fakeValue); filter.setFilterIfMissing(true); list.addFilter(filter); }?根据限定符选出不包含没有数据的：
public static void addQualifierExcludeFilter(FilterList list, byte[] family, byte[] qualifier) { SkipFilter filter = new SkipFilter(new QualifierFilter(CompareOp.NOT_EQUAL, new BinaryComparator(qualifier))); list.addFilter(filter); }?根据时间来过滤：
public static void addTimeStampFilter(FilterList list, byte[] family, byte[] qualifier, byte[] timestamp) { SingleColumnValueFilter filter = new SingleColumnValueFilter(family, qualifier, CompareOp.GREATER_OR_EQUAL, timestamp); list.addFilter(filter); }?根据时间来过滤（不包含指定的时间）：
public static void addTimeStampExcludeFilter(FilterList list, byte[] family, byte[] qualifier, byte[] timestamp) { SingleColumnValueExcludeFilter filter = new SingleColumnValueExcludeFilter(family, qualifier, CompareOp.GREATER_OR_EQUAL, timestamp); list.addFilter(filter); }?使用方法:
FilterList list = new FilterList();HBaseManager.addQualifierFilter(list, HTableConstant.USER_HOBBY_HOBBY_COLUMN_FAMILY, HTableConstant.USER_HOBBY_USER_ID_QUALIFIER);HBaseManager.addTimeStampFilter(list,HTableConstant.USER_HOBBY_HOBBY_COLUMN_FAMILY,HTableConstant.USER_HOBBY_DATE_QUALIFIER, Bytes.toBytes(date));scan.setFilter(list);
?