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.rest.model; 019 020import static org.junit.Assert.assertEquals; 021import static org.junit.Assert.assertFalse; 022import static org.junit.Assert.assertTrue; 023 024import java.util.Iterator; 025import org.apache.hadoop.hbase.HBaseClassTestRule; 026import org.apache.hadoop.hbase.TableName; 027import org.apache.hadoop.hbase.testclassification.RestTests; 028import org.apache.hadoop.hbase.testclassification.SmallTests; 029import org.apache.hadoop.hbase.util.Bytes; 030import org.junit.ClassRule; 031import org.junit.experimental.categories.Category; 032 033@Category({RestTests.class, SmallTests.class}) 034public class TestStorageClusterStatusModel extends TestModelBase<StorageClusterStatusModel> { 035 036 @ClassRule 037 public static final HBaseClassTestRule CLASS_RULE = 038 HBaseClassTestRule.forClass(TestStorageClusterStatusModel.class); 039 040 public TestStorageClusterStatusModel() throws Exception { 041 super(StorageClusterStatusModel.class); 042 043 AS_XML = 044 "<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"yes\"?>" + 045 "<ClusterStatus averageLoad=\"1.0\" regions=\"2\" requests=\"0\">" + 046 "<DeadNodes/><LiveNodes>" + 047 "<Node heapSizeMB=\"128\" maxHeapSizeMB=\"1024\" name=\"test1\" requests=\"0\" startCode=\"1245219839331\">" + 048 "<Region currentCompactedKVs=\"1\" memstoreSizeMB=\"0\" name=\"aGJhc2U6cm9vdCwsMA==\" readRequestsCount=\"1\" " + 049 "rootIndexSizeKB=\"1\" storefileIndexSizeKB=\"0\" storefileSizeMB=\"0\" storefiles=\"1\" stores=\"1\" " + 050 "totalCompactingKVs=\"1\" totalStaticBloomSizeKB=\"1\" totalStaticIndexSizeKB=\"1\" writeRequestsCount=\"2\"/>" + 051 "</Node>" + 052 "<Node heapSizeMB=\"512\" maxHeapSizeMB=\"1024\" name=\"test2\" requests=\"0\" startCode=\"1245239331198\">" + 053 "<Region currentCompactedKVs=\"1\" memstoreSizeMB=\"0\" name=\"aGJhc2U6bWV0YSwsMTI0NjAwMDA0MzcyNA==\" " + 054 "readRequestsCount=\"1\" rootIndexSizeKB=\"1\" storefileIndexSizeKB=\"0\" storefileSizeMB=\"0\" " + 055 "storefiles=\"1\" stores=\"1\" totalCompactingKVs=\"1\" totalStaticBloomSizeKB=\"1\" " + 056 "totalStaticIndexSizeKB=\"1\" writeRequestsCount=\"2\"/></Node></LiveNodes></ClusterStatus>"; 057 058 AS_PB = 059 "Cj8KBXRlc3QxEOO6i+eeJBgAIIABKIAIMicKDWhiYXNlOnJvb3QsLDAQARgBIAAoADAAOAFAAkgB" + 060 "UAFYAWABaAEKSwoFdGVzdDIQ/pKx8J4kGAAggAQogAgyMwoZaGJhc2U6bWV0YSwsMTI0NjAwMDA0" + 061 "MzcyNBABGAEgACgAMAA4AUACSAFQAVgBYAFoARgCIAApAAAAAAAA8D8="; 062 063 064 //Using jackson will break json backward compatibilty for this representation 065 //but the original one was broken as it would only print one Node element 066 //so the format itself was broken 067 AS_JSON = 068 "{\"regions\":2,\"requests\":0,\"averageLoad\":1.0,\"LiveNodes\":[{\"name\":\"test1\"," + 069 "\"Region\":[{\"name\":\"aGJhc2U6cm9vdCwsMA==\",\"stores\":1,\"storefiles\":1," + 070 "\"storefileSizeMB\":0,\"memStoreSizeMB\":0,\"storefileIndexSizeKB\":0," + 071 "\"readRequestsCount\":1,\"writeRequestsCount\":2,\"rootIndexSizeKB\":1," + 072 "\"totalStaticIndexSizeKB\":1,\"totalStaticBloomSizeKB\":1,\"totalCompactingKVs\":1," + 073 "\"currentCompactedKVs\":1}],\"requests\":0,\"startCode\":1245219839331," + 074 "\"heapSizeMB\":128,\"maxHeapSizeMB\":1024},{\"name\":\"test2\"," + 075 "\"Region\":[{\"name\":\"aGJhc2U6bWV0YSwsMTI0NjAwMDA0MzcyNA==\",\"stores\":1," + 076 "\"storefiles\":1,\"storefileSizeMB\":0,\"memStoreSizeMB\":0,\"storefileIndexSizeKB\":0," + 077 "\"readRequestsCount\":1,\"writeRequestsCount\":2,\"rootIndexSizeKB\":1," + 078 "\"totalStaticIndexSizeKB\":1,\"totalStaticBloomSizeKB\":1,\"totalCompactingKVs\":1," + 079 "\"currentCompactedKVs\":1}],\"requests\":0,\"startCode\":1245239331198," + 080 "\"heapSizeMB\":512,\"maxHeapSizeMB\":1024}],\"DeadNodes\":[]}"; 081 } 082 083 @Override 084 protected StorageClusterStatusModel buildTestModel() { 085 StorageClusterStatusModel model = new StorageClusterStatusModel(); 086 model.setRegions(2); 087 model.setRequests(0); 088 model.setAverageLoad(1.0); 089 model.addLiveNode("test1", 1245219839331L, 128, 1024) 090 .addRegion(Bytes.toBytes("hbase:root,,0"), 1, 1, 0, 0, 0, 1, 2, 1, 1, 1, 1, 1); 091 model.addLiveNode("test2", 1245239331198L, 512, 1024) 092 .addRegion(Bytes.toBytes(TableName.META_TABLE_NAME+",,1246000043724"),1, 1, 0, 0, 0, 093 1, 2, 1, 1, 1, 1, 1); 094 return model; 095 } 096 097 @Override 098 protected void checkModel(StorageClusterStatusModel model) { 099 assertEquals(2, model.getRegions()); 100 assertEquals(0, model.getRequests()); 101 assertEquals(1.0, model.getAverageLoad(), 0.0); 102 Iterator<StorageClusterStatusModel.Node> nodes = 103 model.getLiveNodes().iterator(); 104 StorageClusterStatusModel.Node node = nodes.next(); 105 assertEquals("test1", node.getName()); 106 assertEquals(1245219839331L, node.getStartCode()); 107 assertEquals(128, node.getHeapSizeMB()); 108 assertEquals(1024, node.getMaxHeapSizeMB()); 109 Iterator<StorageClusterStatusModel.Node.Region> regions = 110 node.getRegions().iterator(); 111 StorageClusterStatusModel.Node.Region region = regions.next(); 112 assertTrue(Bytes.toString(region.getName()).equals( 113 "hbase:root,,0")); 114 assertEquals(1, region.getStores()); 115 assertEquals(1, region.getStorefiles()); 116 assertEquals(0, region.getStorefileSizeMB()); 117 assertEquals(0, region.getMemStoreSizeMB()); 118 assertEquals(0, region.getStorefileIndexSizeKB()); 119 assertEquals(1, region.getReadRequestsCount()); 120 assertEquals(2, region.getWriteRequestsCount()); 121 assertEquals(1, region.getRootIndexSizeKB()); 122 assertEquals(1, region.getTotalStaticIndexSizeKB()); 123 assertEquals(1, region.getTotalStaticBloomSizeKB()); 124 assertEquals(1, region.getTotalCompactingKVs()); 125 assertEquals(1, region.getCurrentCompactedKVs()); 126 assertFalse(regions.hasNext()); 127 node = nodes.next(); 128 assertEquals("test2", node.getName()); 129 assertEquals(1245239331198L, node.getStartCode()); 130 assertEquals(512, node.getHeapSizeMB()); 131 assertEquals(1024, node.getMaxHeapSizeMB()); 132 regions = node.getRegions().iterator(); 133 region = regions.next(); 134 assertEquals(Bytes.toString(region.getName()), 135 TableName.META_TABLE_NAME+",,1246000043724"); 136 assertEquals(1, region.getStores()); 137 assertEquals(1, region.getStorefiles()); 138 assertEquals(0, region.getStorefileSizeMB()); 139 assertEquals(0, region.getMemStoreSizeMB()); 140 assertEquals(0, region.getStorefileIndexSizeKB()); 141 assertEquals(1, region.getReadRequestsCount()); 142 assertEquals(2, region.getWriteRequestsCount()); 143 assertEquals(1, region.getRootIndexSizeKB()); 144 assertEquals(1, region.getTotalStaticIndexSizeKB()); 145 assertEquals(1, region.getTotalStaticBloomSizeKB()); 146 assertEquals(1, region.getTotalCompactingKVs()); 147 assertEquals(1, region.getCurrentCompactedKVs()); 148 149 assertFalse(regions.hasNext()); 150 assertFalse(nodes.hasNext()); 151 } 152} 153