Lines Matching refs:DatanodeInfo

45 import org.apache.hadoop.hdfs.protocol.DatanodeInfo;
46 import org.apache.hadoop.hdfs.protocol.DatanodeInfo.AdminStates;
183 DatanodeInfo[] nodes = blk.getLocations(); in checkFile()
231 private DatanodeInfo decommissionNode(int nnIndex, in decommissionNode()
233 ArrayList<DatanodeInfo>decommissionedNodes, in decommissionNode()
237 DatanodeInfo[] info = client.datanodeReport(DatanodeReportType.LIVE); in decommissionNode()
268 for (DatanodeInfo dn : decommissionedNodes) { in decommissionNode()
275 DatanodeInfo ret = NameNodeAdapter.getDatanode( in decommissionNode()
284 private void recommissionNode(int nnIndex, DatanodeInfo decommissionedNode) throws IOException { in recommissionNode()
295 private void waitNodeState(DatanodeInfo node, in waitNodeState()
320 DatanodeInfo[] info = client.datanodeReport(DatanodeReportType.LIVE); in validateCluster()
344 DatanodeInfo info, DataNode node, boolean decommissioning) in verifyStats()
389 ArrayList<ArrayList<DatanodeInfo>> namenodeDecomList = new ArrayList<ArrayList<DatanodeInfo>>( in testDecommission2()
391 namenodeDecomList.add(0, new ArrayList<DatanodeInfo>(numDatanodes)); in testDecommission2()
397 ArrayList<DatanodeInfo> decommissionedNodes = namenodeDecomList.get(0); in testDecommission2()
407 DatanodeInfo decomNode = decommissionNode(0, null, decommissionedNodes, in testDecommission2()
494 DatanodeInfo decommissionedNodeFromANN = decommissionNode( in testDecommissionOnStandby()
498 DatanodeInfo decomNodeFromSBN = decommissionNode(1, firstDN.getDatanodeUuid(), null, in testDecommissionOnStandby()
564 ArrayList<ArrayList<DatanodeInfo>> namenodeDecomList = in testDecommission()
565 new ArrayList<ArrayList<DatanodeInfo>>(numNamenodes); in testDecommission()
567 namenodeDecomList.add(i, new ArrayList<DatanodeInfo>(numDatanodes)); in testDecommission()
575 ArrayList<DatanodeInfo> decommissionedNodes = namenodeDecomList.get(i); in testDecommission()
585 DatanodeInfo decomNode = decommissionNode(i, null, decommissionedNodes, in testDecommission()
634 ArrayList<DatanodeInfo> decommissionedNodes = Lists.newArrayList(); in testRecommission()
653 final DatanodeInfo decomNode = in testRecommission()
736 DatanodeInfo decomInfo = decommissionNode(i, null, null, in testClusterStats()
745 DatanodeInfo retInfo = NameNodeAdapter.getDatanode(fsn, decomInfo); in testClusterStats()
752 private DataNode getDataNode(DatanodeInfo decomInfo) { in getDataNode()
805 DatanodeInfo[] info = client.datanodeReport(DatanodeReportType.LIVE); in testHostsFile()
841 DatanodeInfo[] dnInfos4LastBlock = lbs.getLastLocatedBlock().getLocations(); in testDecommissionWithOpenfile()
842 DatanodeInfo[] dnInfos4FirstBlock = lbs.get(0).getLocations(); in testDecommissionWithOpenfile()
845 ArrayList<DatanodeInfo> dnInfos = new ArrayList<DatanodeInfo>(); in testDecommissionWithOpenfile()
848 for (DatanodeInfo datanodeInfo : dnInfos4FirstBlock) { in testDecommissionWithOpenfile()
849 DatanodeInfo found = datanodeInfo; in testDecommissionWithOpenfile()
850 for (DatanodeInfo dif: dnInfos4LastBlock) { in testDecommissionWithOpenfile()
866 for (DatanodeInfo dn : dnInfos) { in testDecommissionWithOpenfile()
892 DatanodeInfo[] info = client.datanodeReport(DatanodeReportType.LIVE); in testDecommissionWithNamenodeRestart()
905 DatanodeInfo datanodeInfo = NameNodeAdapter.getDatanode( in testDecommissionWithNamenodeRestart()
971 DatanodeInfo info[] = client.datanodeReport(DatanodeReportType.DEAD); in testIncludeByRegistrationName()
998 DatanodeInfo info[] = client.datanodeReport(DatanodeReportType.LIVE); in testIncludeByRegistrationName()
1075 ArrayList<DatanodeInfo> decommissionedNodes = Lists.newArrayList(); in doDecomCheck()
1077 DatanodeInfo dn = decommissionNode(0, d.getDatanodeUuid(), in doDecomCheck()
1087 for (DatanodeInfo dn : decommissionedNodes) { in doDecomCheck()
1120 ArrayList<DatanodeInfo> decommissionedNodes = Lists.newArrayList(); in testPendingNodes()
1123 DatanodeInfo dn = decommissionNode(0, d.getDatanodeUuid(), in testPendingNodes()
1137 DatanodeInfo dn = decommissionNode(0, d.getDatanodeUuid(), in testPendingNodes()