001/** 002 * Licensed to the Apache Software Foundation (ASF) under one 003 * or more contributor license agreements. See the NOTICE file 004 * distributed with this work for additional information 005 * regarding copyright ownership. The ASF licenses this file 006 * to you under the Apache License, Version 2.0 (the 007 * "License"); you may not use this file except in compliance 008 * with the License. You may obtain a copy of the License at 009 * 010 * http://www.apache.org/licenses/LICENSE-2.0 011 * 012 * Unless required by applicable law or agreed to in writing, software 013 * distributed under the License is distributed on an "AS IS" BASIS, 014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 015 * See the License for the specific language governing permissions and 016 * limitations under the License. 017 */ 018package org.apache.hadoop.hbase.filter; 019 020import static org.junit.Assert.assertFalse; 021import static org.junit.Assert.assertTrue; 022 023import org.apache.hadoop.hbase.HBaseClassTestRule; 024import org.apache.hadoop.hbase.KeyValueUtil; 025import org.apache.hadoop.hbase.testclassification.FilterTests; 026import org.apache.hadoop.hbase.testclassification.SmallTests; 027import org.apache.hadoop.hbase.util.Bytes; 028import org.junit.Before; 029import org.junit.ClassRule; 030import org.junit.Test; 031import org.junit.experimental.categories.Category; 032 033/** 034 * Tests the inclusive stop row filter 035 */ 036@Category({FilterTests.class, SmallTests.class}) 037public class TestInclusiveStopFilter { 038 039 @ClassRule 040 public static final HBaseClassTestRule CLASS_RULE = 041 HBaseClassTestRule.forClass(TestInclusiveStopFilter.class); 042 043 private final byte [] STOP_ROW = Bytes.toBytes("stop_row"); 044 private final byte [] GOOD_ROW = Bytes.toBytes("good_row"); 045 private final byte [] PAST_STOP_ROW = Bytes.toBytes("zzzzzz"); 046 047 Filter mainFilter; 048 049 @Before 050 public void setUp() throws Exception { 051 mainFilter = new InclusiveStopFilter(STOP_ROW); 052 } 053 054 /** 055 * Tests identification of the stop row 056 * @throws Exception 057 */ 058 @Test 059 public void testStopRowIdentification() throws Exception { 060 stopRowTests(mainFilter); 061 } 062 063 /** 064 * Tests serialization 065 * @throws Exception 066 */ 067 @Test 068 public void testSerialization() throws Exception { 069 // Decompose mainFilter to bytes. 070 byte[] buffer = mainFilter.toByteArray(); 071 072 // Recompose mainFilter. 073 Filter newFilter = InclusiveStopFilter.parseFrom(buffer); 074 075 // Ensure the serialization preserved the filter by running a full test. 076 stopRowTests(newFilter); 077 } 078 079 private void stopRowTests(Filter filter) throws Exception { 080 assertFalse("Filtering on " + Bytes.toString(GOOD_ROW), 081 filter.filterRowKey(KeyValueUtil.createFirstOnRow(GOOD_ROW))); 082 assertFalse("Filtering on " + Bytes.toString(STOP_ROW), 083 filter.filterRowKey(KeyValueUtil.createFirstOnRow(STOP_ROW))); 084 assertTrue("Filtering on " + Bytes.toString(PAST_STOP_ROW), 085 filter.filterRowKey(KeyValueUtil.createFirstOnRow(PAST_STOP_ROW))); 086 087 assertTrue("FilterAllRemaining", filter.filterAllRemaining()); 088 assertFalse("FilterNotNull", filter.filterRow()); 089 } 090 091} 092