Examples of addBlockReport()

Examples of org.apache.hadoop.hdfs.server.namenode.metrics.NameNodeMetrics.addBlockReport()

1746
1747
1748
1749
1750
1751
1752
1753
1754
1755
1756
    }

    // Log the block report processing stats from Namenode perspective
    final NameNodeMetrics metrics = NameNode.getNameNodeMetrics();
    if (metrics != null) {
      metrics.addBlockReport((int) (endTime - startTime));
    }
    blockLog.info("BLOCK* processReport: from storage " + storage.getStorageID()
        + " node " + nodeID + ", blocks: " + newReport.getNumberOfBlocks()
        + ", hasStaleStorages: " + node.hasStaleStorages()
        + ", processing time: " + (endTime - startTime) + " msecs");
View Full Code Here

Examples of org.apache.hadoop.hdfs.server.namenode.metrics.NameNodeMetrics.addBlockReport()

1384
1385
1386
1387
1388
1389
1390
1391
1392
1393
1394
    }

    // Log the block report processing stats from Namenode perspective
    final NameNodeMetrics metrics = NameNode.getNameNodeMetrics();
    if (metrics != null) {
      metrics.addBlockReport((int) (endTime - startTime));
    }
    blockLog.info("BLOCK* processReport: from "
        + nodeID.getName() + ", blocks: " + newReport.getNumberOfBlocks()
        + ", processing time: " + (endTime - startTime) + " msecs");
  }
View Full Code Here

Examples of org.apache.hadoop.hdfs.server.namenode.metrics.NameNodeMetrics.addBlockReport()

1640
1641
1642
1643
1644
1645
1646
1647
1648
1649
1650
    }

    // Log the block report processing stats from Namenode perspective
    final NameNodeMetrics metrics = NameNode.getNameNodeMetrics();
    if (metrics != null) {
      metrics.addBlockReport((int) (endTime - startTime));
    }
    blockLog.info("BLOCK* processReport: from "
        + nodeID + ", blocks: " + newReport.getNumberOfBlocks()
        + ", processing time: " + (endTime - startTime) + " msecs");
  }
View Full Code Here

Examples of org.apache.hadoop.hdfs.server.namenode.metrics.NameNodeMetrics.addBlockReport()

1671
1672
1673
1674
1675
1676
1677
1678
1679
1680
1681
    }

    // Log the block report processing stats from Namenode perspective
    final NameNodeMetrics metrics = NameNode.getNameNodeMetrics();
    if (metrics != null) {
      metrics.addBlockReport((int) (endTime - startTime));
    }
    blockLog.info("BLOCK* processReport: from "
        + nodeID + ", blocks: " + newReport.getNumberOfBlocks()
        + ", processing time: " + (endTime - startTime) + " msecs");
  }
View Full Code Here

Examples of org.apache.hadoop.hdfs.server.namenode.metrics.NameNodeMetrics.addBlockReport()

1716
1717
1718
1719
1720
1721
1722
1723
1724
1725
1726
    }

    // Log the block report processing stats from Namenode perspective
    final NameNodeMetrics metrics = NameNode.getNameNodeMetrics();
    if (metrics != null) {
      metrics.addBlockReport((int) (endTime - startTime));
    }
    blockLog.info("BLOCK* processReport: from storage " + storage.getStorageID()
        + " node " + nodeID + ", blocks: " + newReport.getNumberOfBlocks()
        + ", processing time: " + (endTime - startTime) + " msecs");
    return !node.hasStaleStorages();
View Full Code Here

Examples of org.apache.hadoop.hdfs.server.namenode.metrics.NameNodeMetrics.addBlockReport()

1382
1383
1384
1385
1386
1387
1388
1389
1390
1391
1392
    }

    // Log the block report processing stats from Namenode perspective
    final NameNodeMetrics metrics = NameNode.getNameNodeMetrics();
    if (metrics != null) {
      metrics.addBlockReport((int) (endTime - startTime));
    }
    blockLog.info("BLOCK* processReport: from "
        + nodeID.getName() + ", blocks: " + newReport.getNumberOfBlocks()
        + ", processing time: " + (endTime - startTime) + " msecs");
  }
View Full Code Here

Examples of org.apache.hadoop.hdfs.server.namenode.metrics.NameNodeMetrics.addBlockReport()

1577
1578
1579
1580
1581
1582
1583
1584
1585
1586
1587
    }

    // Log the block report processing stats from Namenode perspective
    final NameNodeMetrics metrics = NameNode.getNameNodeMetrics();
    if (metrics != null) {
      metrics.addBlockReport((int) (endTime - startTime));
    }
    blockLog.info("BLOCK* processReport: from "
        + nodeID + ", blocks: " + newReport.getNumberOfBlocks()
        + ", processing time: " + (endTime - startTime) + " msecs");
  }
View Full Code Here

Examples of org.apache.hadoop.hdfs.server.namenode.metrics.NameNodeMetrics.addBlockReport()

1705
1706
1707
1708
1709
1710
1711
1712
1713
1714
1715
    }

    // Log the block report processing stats from Namenode perspective
    final NameNodeMetrics metrics = NameNode.getNameNodeMetrics();
    if (metrics != null) {
      metrics.addBlockReport((int) (endTime - startTime));
    }
    blockLog.info("BLOCK* processReport: from storage " + storage.getStorageID()
        + " node " + nodeID + ", blocks: " + newReport.getNumberOfBlocks()
        + ", processing time: " + (endTime - startTime) + " msecs");
    return !node.hasStaleStorages();
View Full Code Here

Examples of org.apache.hadoop.hdfs.server.namenode.metrics.NameNodeMetrics.addBlockReport()

1393
1394
1395
1396
1397
1398
1399
1400
1401
1402
1403
    }

    // Log the block report processing stats from Namenode perspective
    final NameNodeMetrics metrics = NameNode.getNameNodeMetrics();
    if (metrics != null) {
      metrics.addBlockReport((int) (endTime - startTime));
    }
    blockLog.info("BLOCK* processReport: from "
        + nodeID.getName() + ", blocks: " + newReport.getNumberOfBlocks()
        + ", processing time: " + (endTime - startTime) + " msecs");
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.