http://git-wip-us.apache.org/repos/asf/ambari/blob/041e4e9a/ambari-metrics/ambari-metrics-timelineservice/src/main/resources/metrics_def/MASTER_HBASE.dat ---------------------------------------------------------------------- diff --git a/ambari-metrics/ambari-metrics-timelineservice/src/main/resources/metrics_def/MASTER_HBASE.dat b/ambari-metrics/ambari-metrics-timelineservice/src/main/resources/metrics_def/MASTER_HBASE.dat index 9ba90f1..bce85f2 100644 --- a/ambari-metrics/ambari-metrics-timelineservice/src/main/resources/metrics_def/MASTER_HBASE.dat +++ b/ambari-metrics/ambari-metrics-timelineservice/src/main/resources/metrics_def/MASTER_HBASE.dat @@ -25,29 +25,213 @@ ipc.IPC.QueueCallTime_num_ops ipc.IPC.queueSize ipc.IPC.receivedBytes ipc.IPC.sentBytes -jvm.JvmMetrics.GcCount -jvm.JvmMetrics.GcCountConcurrentMarkSweep -jvm.JvmMetrics.GcCountCopy -jvm.JvmMetrics.GcTimeMillis -jvm.JvmMetrics.GcTimeMillisConcurrentMarkSweep -jvm.JvmMetrics.GcTimeMillisCopy -jvm.JvmMetrics.LogError -jvm.JvmMetrics.LogFatal -jvm.JvmMetrics.LogInfo -jvm.JvmMetrics.LogWarn -jvm.JvmMetrics.MemHeapCommittedM -jvm.JvmMetrics.MemHeapMaxM -jvm.JvmMetrics.MemHeapUsedM -jvm.JvmMetrics.MemMaxM -jvm.JvmMetrics.MemNonHeapCommittedM -jvm.JvmMetrics.MemNonHeapMaxM -jvm.JvmMetrics.MemNonHeapUsedM -jvm.JvmMetrics.ThreadsBlocked -jvm.JvmMetrics.ThreadsNew -jvm.JvmMetrics.ThreadsRunnable -jvm.JvmMetrics.ThreadsTerminated -jvm.JvmMetrics.ThreadsTimedWaiting -jvm.JvmMetrics.ThreadsWaiting +jvm.Master.JvmMetrics.GcCount +jvm.Master.JvmMetrics.GcCountConcurrentMarkSweep +jvm.Master.JvmMetrics.GcCountParNew +jvm.Master.JvmMetrics.GcTimeMillis +jvm.Master.JvmMetrics.GcTimeMillisConcurrentMarkSweep +jvm.Master.JvmMetrics.GcTimeMillisParNew +jvm.Master.JvmMetrics.LogError +jvm.Master.JvmMetrics.LogFatal +jvm.Master.JvmMetrics.LogInfo +jvm.Master.JvmMetrics.LogWarn +jvm.Master.JvmMetrics.MemHeapCommittedM +jvm.Master.JvmMetrics.MemHeapMaxM +jvm.Master.JvmMetrics.MemHeapUsedM +jvm.Master.JvmMetrics.MemMaxM +jvm.Master.JvmMetrics.MemNonHeapCommittedM +jvm.Master.JvmMetrics.MemNonHeapMaxM +jvm.Master.JvmMetrics.MemNonHeapUsedM +jvm.Master.JvmMetrics.ThreadsBlocked +jvm.Master.JvmMetrics.ThreadsNew +jvm.Master.JvmMetrics.ThreadsRunnable +jvm.Master.JvmMetrics.ThreadsTerminated +jvm.Master.JvmMetrics.ThreadsTimedWaiting +jvm.Master.JvmMetrics.ThreadsWaiting +master.AssignmentManger.Assign_25th_percentile +master.AssignmentManger.Assign_75th_percentile +master.AssignmentManger.Assign_90th_percentile +master.AssignmentManger.Assign_95th_percentile +master.AssignmentManger.Assign_98th_percentile +master.AssignmentManger.Assign_99.9th_percentile +master.AssignmentManger.Assign_99th_percentile +master.AssignmentManger.Assign_max +master.AssignmentManger.Assign_mean +master.AssignmentManger.Assign_median +master.AssignmentManger.Assign_min +master.AssignmentManger.Assign_num_ops +master.AssignmentManger.BulkAssign_25th_percentile +master.AssignmentManger.BulkAssign_75th_percentile +master.AssignmentManger.BulkAssign_90th_percentile +master.AssignmentManger.BulkAssign_95th_percentile +master.AssignmentManger.BulkAssign_98th_percentile +master.AssignmentManger.BulkAssign_99.9th_percentile +master.AssignmentManger.BulkAssign_99th_percentile +master.AssignmentManger.BulkAssign_max +master.AssignmentManger.BulkAssign_mean +master.AssignmentManger.BulkAssign_median +master.AssignmentManger.BulkAssign_min +master.AssignmentManger.BulkAssign_num_ops +master.AssignmentManger.ritCount +master.AssignmentManger.ritCountOverThreshold +master.AssignmentManger.ritOldestAge +master.Balancer.BalancerCluster_25th_percentile +master.Balancer.BalancerCluster_75th_percentile +master.Balancer.BalancerCluster_90th_percentile +master.Balancer.BalancerCluster_95th_percentile +master.Balancer.BalancerCluster_98th_percentile +master.Balancer.BalancerCluster_99.9th_percentile +master.Balancer.BalancerCluster_99th_percentile +master.Balancer.BalancerCluster_max +master.Balancer.BalancerCluster_mean +master.Balancer.BalancerCluster_median +master.Balancer.BalancerCluster_min +master.Balancer.BalancerCluster_num_ops +master.Balancer.miscInvocationCount +master.FileSystem.HlogSplitSize_25th_percentile +master.FileSystem.HlogSplitSize_75th_percentile +master.FileSystem.HlogSplitSize_90th_percentile +master.FileSystem.HlogSplitSize_95th_percentile +master.FileSystem.HlogSplitSize_98th_percentile +master.FileSystem.HlogSplitSize_99.9th_percentile +master.FileSystem.HlogSplitSize_99th_percentile +master.FileSystem.HlogSplitSize_max +master.FileSystem.HlogSplitSize_mean +master.FileSystem.HlogSplitSize_median +master.FileSystem.HlogSplitSize_min +master.FileSystem.HlogSplitSize_num_ops +master.FileSystem.HlogSplitTime_25th_percentile +master.FileSystem.HlogSplitTime_75th_percentile +master.FileSystem.HlogSplitTime_90th_percentile +master.FileSystem.HlogSplitTime_95th_percentile +master.FileSystem.HlogSplitTime_98th_percentile +master.FileSystem.HlogSplitTime_99.9th_percentile +master.FileSystem.HlogSplitTime_99th_percentile +master.FileSystem.HlogSplitTime_max +master.FileSystem.HlogSplitTime_mean +master.FileSystem.HlogSplitTime_median +master.FileSystem.HlogSplitTime_min +master.FileSystem.HlogSplitTime_num_ops +master.FileSystem.MetaHlogSplitSize_25th_percentile +master.FileSystem.MetaHlogSplitSize_75th_percentile +master.FileSystem.MetaHlogSplitSize_90th_percentile +master.FileSystem.MetaHlogSplitSize_95th_percentile +master.FileSystem.MetaHlogSplitSize_98th_percentile +master.FileSystem.MetaHlogSplitSize_99.9th_percentile +master.FileSystem.MetaHlogSplitSize_99th_percentile +master.FileSystem.MetaHlogSplitSize_max +master.FileSystem.MetaHlogSplitSize_mean +master.FileSystem.MetaHlogSplitSize_median +master.FileSystem.MetaHlogSplitSize_min +master.FileSystem.MetaHlogSplitSize_num_ops +master.FileSystem.MetaHlogSplitTime_25th_percentile +master.FileSystem.MetaHlogSplitTime_75th_percentile +master.FileSystem.MetaHlogSplitTime_90th_percentile +master.FileSystem.MetaHlogSplitTime_95th_percentile +master.FileSystem.MetaHlogSplitTime_98th_percentile +master.FileSystem.MetaHlogSplitTime_99.9th_percentile +master.FileSystem.MetaHlogSplitTime_99th_percentile +master.FileSystem.MetaHlogSplitTime_max +master.FileSystem.MetaHlogSplitTime_mean +master.FileSystem.MetaHlogSplitTime_median +master.FileSystem.MetaHlogSplitTime_min +master.FileSystem.MetaHlogSplitTime_num_ops +master.Master.ProcessCallTime_25th_percentile +master.Master.ProcessCallTime_75th_percentile +master.Master.ProcessCallTime_90th_percentile +master.Master.ProcessCallTime_95th_percentile +master.Master.ProcessCallTime_98th_percentile +master.Master.ProcessCallTime_99.9th_percentile +master.Master.ProcessCallTime_99th_percentile +master.Master.ProcessCallTime_TimeRangeCount_0-1 +master.Master.ProcessCallTime_max +master.Master.ProcessCallTime_mean +master.Master.ProcessCallTime_median +master.Master.ProcessCallTime_min +master.Master.ProcessCallTime_num_ops +master.Master.QueueCallTime_25th_percentile +master.Master.QueueCallTime_75th_percentile +master.Master.QueueCallTime_90th_percentile +master.Master.QueueCallTime_95th_percentile +master.Master.QueueCallTime_98th_percentile +master.Master.QueueCallTime_99.9th_percentile +master.Master.QueueCallTime_99th_percentile +master.Master.QueueCallTime_TimeRangeCount_0-1 +master.Master.QueueCallTime_TimeRangeCount_1-3 +master.Master.QueueCallTime_max +master.Master.QueueCallTime_mean +master.Master.QueueCallTime_median +master.Master.QueueCallTime_min +master.Master.QueueCallTime_num_ops +master.Master.RequestSize_25th_percentile +master.Master.RequestSize_75th_percentile +master.Master.RequestSize_90th_percentile +master.Master.RequestSize_95th_percentile +master.Master.RequestSize_98th_percentile +master.Master.RequestSize_99.9th_percentile +master.Master.RequestSize_99th_percentile +master.Master.RequestSize_SizeRangeCount_100-1000 +master.Master.RequestSize_max +master.Master.RequestSize_mean +master.Master.RequestSize_median +master.Master.RequestSize_min +master.Master.RequestSize_num_ops +master.Master.ResponseSize_25th_percentile +master.Master.ResponseSize_75th_percentile +master.Master.ResponseSize_90th_percentile +master.Master.ResponseSize_95th_percentile +master.Master.ResponseSize_98th_percentile +master.Master.ResponseSize_99.9th_percentile +master.Master.ResponseSize_99th_percentile +master.Master.ResponseSize_SizeRangeCount_0-10 +master.Master.ResponseSize_max +master.Master.ResponseSize_mean +master.Master.ResponseSize_median +master.Master.ResponseSize_min +master.Master.ResponseSize_num_ops +master.Master.TotalCallTime_25th_percentile +master.Master.TotalCallTime_75th_percentile +master.Master.TotalCallTime_90th_percentile +master.Master.TotalCallTime_95th_percentile +master.Master.TotalCallTime_98th_percentile +master.Master.TotalCallTime_99.9th_percentile +master.Master.TotalCallTime_99th_percentile +master.Master.TotalCallTime_TimeRangeCount_0-1 +master.Master.TotalCallTime_TimeRangeCount_1-3 +master.Master.TotalCallTime_max +master.Master.TotalCallTime_mean +master.Master.TotalCallTime_median +master.Master.TotalCallTime_min +master.Master.TotalCallTime_num_ops +master.Master.authenticationFailures +master.Master.authenticationSuccesses +master.Master.authorizationFailures +master.Master.authorizationSuccesses +master.Master.exceptions +master.Master.exceptions.FailedSanityCheckException +master.Master.exceptions.NotServingRegionException +master.Master.exceptions.OutOfOrderScannerNextException +master.Master.exceptions.RegionMovedException +master.Master.exceptions.RegionTooBusyException +master.Master.exceptions.ScannerResetException +master.Master.exceptions.UnknownScannerException +master.Master.numActiveHandler +master.Master.numCallsInGeneralQueue +master.Master.numCallsInPriorityQueue +master.Master.numCallsInReplicationQueue +master.Master.numGeneralCallsDropped +master.Master.numLifoModeSwitches +master.Master.numOpenConnections +master.Master.queueSize +master.Master.receivedBytes +master.Master.sentBytes +master.Procedure.numMasterWALs +master.Server.averageLoad +master.Server.clusterRequests +master.Server.masterActiveTime +master.Server.masterStartTime +master.Server.numDeadRegionServers +master.Server.numRegionServers metricssystem.MetricsSystem.DroppedPubAll metricssystem.MetricsSystem.NumActiveSinks metricssystem.MetricsSystem.NumActiveSources
http://git-wip-us.apache.org/repos/asf/ambari/blob/041e4e9a/ambari-metrics/ambari-metrics-timelineservice/src/main/resources/metrics_def/SLAVE_HBASE.dat ---------------------------------------------------------------------- diff --git a/ambari-metrics/ambari-metrics-timelineservice/src/main/resources/metrics_def/SLAVE_HBASE.dat b/ambari-metrics/ambari-metrics-timelineservice/src/main/resources/metrics_def/SLAVE_HBASE.dat index 38b870f..3b8e586 100644 --- a/ambari-metrics/ambari-metrics-timelineservice/src/main/resources/metrics_def/SLAVE_HBASE.dat +++ b/ambari-metrics/ambari-metrics-timelineservice/src/main/resources/metrics_def/SLAVE_HBASE.dat @@ -25,29 +25,29 @@ ipc.IPC.QueueCallTime_num_ops ipc.IPC.queueSize ipc.IPC.receivedBytes ipc.IPC.sentBytes -jvm.JvmMetrics.GcCount -jvm.JvmMetrics.GcCountConcurrentMarkSweep -jvm.JvmMetrics.GcCountCopy -jvm.JvmMetrics.GcTimeMillis -jvm.JvmMetrics.GcTimeMillisConcurrentMarkSweep -jvm.JvmMetrics.GcTimeMillisCopy -jvm.JvmMetrics.LogError -jvm.JvmMetrics.LogFatal -jvm.JvmMetrics.LogInfo -jvm.JvmMetrics.LogWarn -jvm.JvmMetrics.MemHeapCommittedM -jvm.JvmMetrics.MemHeapMaxM -jvm.JvmMetrics.MemHeapUsedM -jvm.JvmMetrics.MemMaxM -jvm.JvmMetrics.MemNonHeapCommittedM -jvm.JvmMetrics.MemNonHeapMaxM -jvm.JvmMetrics.MemNonHeapUsedM -jvm.JvmMetrics.ThreadsBlocked -jvm.JvmMetrics.ThreadsNew -jvm.JvmMetrics.ThreadsRunnable -jvm.JvmMetrics.ThreadsTerminated -jvm.JvmMetrics.ThreadsTimedWaiting -jvm.JvmMetrics.ThreadsWaiting +jvm.RegionServer.JvmMetrics.GcCount +jvm.RegionServer.JvmMetrics.GcCountConcurrentMarkSweep +jvm.RegionServer.JvmMetrics.GcCountParNew +jvm.RegionServer.JvmMetrics.GcTimeMillis +jvm.RegionServer.JvmMetrics.GcTimeMillisConcurrentMarkSweep +jvm.RegionServer.JvmMetrics.GcTimeMillisParNew +jvm.RegionServer.JvmMetrics.LogError +jvm.RegionServer.JvmMetrics.LogFatal +jvm.RegionServer.JvmMetrics.LogInfo +jvm.RegionServer.JvmMetrics.LogWarn +jvm.RegionServer.JvmMetrics.MemHeapCommittedM +jvm.RegionServer.JvmMetrics.MemHeapMaxM +jvm.RegionServer.JvmMetrics.MemHeapUsedM +jvm.RegionServer.JvmMetrics.MemMaxM +jvm.RegionServer.JvmMetrics.MemNonHeapCommittedM +jvm.RegionServer.JvmMetrics.MemNonHeapMaxM +jvm.RegionServer.JvmMetrics.MemNonHeapUsedM +jvm.RegionServer.JvmMetrics.ThreadsBlocked +jvm.RegionServer.JvmMetrics.ThreadsNew +jvm.RegionServer.JvmMetrics.ThreadsRunnable +jvm.RegionServer.JvmMetrics.ThreadsTerminated +jvm.RegionServer.JvmMetrics.ThreadsTimedWaiting +jvm.RegionServer.JvmMetrics.ThreadsWaiting metricssystem.MetricsSystem.DroppedPubAll metricssystem.MetricsSystem.NumActiveSinks metricssystem.MetricsSystem.NumActiveSources @@ -60,119 +60,541 @@ metricssystem.MetricsSystem.Sink_timelineDropped metricssystem.MetricsSystem.Sink_timelineNumOps metricssystem.MetricsSystem.Sink_timelineQsize metricssystem.MetricsSystem.SnapshotAvgTime -metricssystem.MetricsSystem.SnapshotNumOps -regionserver.Server.Append_75th_percentile -regionserver.Server.Append_95th_percentile -regionserver.Server.Append_99th_percentile -regionserver.Server.Append_max -regionserver.Server.Append_mean -regionserver.Server.Append_median -regionserver.Server.Append_min -regionserver.Server.Append_num_ops -regionserver.Server.blockCacheCount -regionserver.Server.blockCacheEvictionCount -regionserver.Server.blockCacheExpressHitPercent -regionserver.Server.blockCacheFreeSize -regionserver.Server.blockCacheHitCount -regionserver.Server.blockCacheMissCount -regionserver.Server.blockCacheSize -regionserver.Server.blockCountHitPercent -regionserver.Server.checkMutateFailedCount -regionserver.Server.checkMutatePassedCount -regionserver.Server.compactionQueueLength -regionserver.Server.Delete_75th_percentile -regionserver.Server.Delete_95th_percentile -regionserver.Server.Delete_99th_percentile -regionserver.Server.Delete_max -regionserver.Server.Delete_mean -regionserver.Server.Delete_median -regionserver.Server.Delete_min -regionserver.Server.Delete_num_ops -regionserver.Server.flushQueueLength -regionserver.Server.Get_75th_percentile -regionserver.Server.Get_95th_percentile -regionserver.Server.Get_99th_percentile -regionserver.Server.Get_max -regionserver.Server.Get_mean -regionserver.Server.Get_median -regionserver.Server.Get_min -regionserver.Server.Get_num_ops -regionserver.Server.hlogFileCount -regionserver.Server.hlogFileSize -regionserver.Server.Increment_75th_percentile -regionserver.Server.Increment_95th_percentile -regionserver.Server.Increment_99th_percentile -regionserver.Server.Increment_max -regionserver.Server.Increment_mean -regionserver.Server.Increment_median -regionserver.Server.Increment_min -regionserver.Server.Increment_num_ops -regionserver.Server.memStoreSize -regionserver.Server.Mutate_75th_percentile -regionserver.Server.Mutate_95th_percentile -regionserver.Server.Mutate_99th_percentile -regionserver.Server.Mutate_max -regionserver.Server.Mutate_mean -regionserver.Server.Mutate_median -regionserver.Server.Mutate_min -regionserver.Server.Mutate_num_ops -regionserver.Server.mutationsWithoutWALCount -regionserver.Server.mutationsWithoutWALSize -regionserver.Server.percentFilesLocal -regionserver.Server.readRequestCount -regionserver.Server.regionCount -regionserver.Server.regionServerStartTime -regionserver.Server.Replay_75th_percentile -regionserver.Server.Replay_95th_percentile -regionserver.Server.Replay_99th_percentile -regionserver.Server.Replay_max -regionserver.Server.Replay_mean -regionserver.Server.Replay_median -regionserver.Server.Replay_min -regionserver.Server.Replay_num_ops -regionserver.Server.slowAppendCount -regionserver.Server.slowDeleteCount -regionserver.Server.slowGetCount -regionserver.Server.slowIncrementCount -regionserver.Server.slowPutCount -regionserver.Server.staticBloomSize -regionserver.Server.staticIndexSize -regionserver.Server.storeCount -regionserver.Server.storeFileCount -regionserver.Server.storeFileIndexSize -regionserver.Server.storeFileSize -regionserver.Server.totalRequestCount -regionserver.Server.updatesBlockedTime -regionserver.Server.writeRequestCount -regionserver.WAL.appendCount -regionserver.WAL.AppendSize_75th_percentile -regionserver.WAL.AppendSize_95th_percentile -regionserver.WAL.AppendSize_99th_percentile -regionserver.WAL.AppendSize_max -regionserver.WAL.AppendSize_mean -regionserver.WAL.AppendSize_median -regionserver.WAL.AppendSize_min -regionserver.WAL.AppendSize_num_ops -regionserver.WAL.AppendTime_75th_percentile -regionserver.WAL.AppendTime_95th_percentile -regionserver.WAL.AppendTime_99th_percentile -regionserver.WAL.AppendTime_max -regionserver.WAL.AppendTime_mean -regionserver.WAL.AppendTime_median -regionserver.WAL.AppendTime_min -regionserver.WAL.AppendTime_num_ops -regionserver.WAL.slowAppendCount -regionserver.WAL.SyncTime_75th_percentile -regionserver.WAL.SyncTime_95th_percentile -regionserver.WAL.SyncTime_99th_percentile -regionserver.WAL.SyncTime_max -regionserver.WAL.SyncTime_mean -regionserver.WAL.SyncTime_median -regionserver.WAL.SyncTime_min -regionserver.WAL.SyncTime_num_ops -ugi.UgiMetrics.GetGroupsAvgTime -ugi.UgiMetrics.GetGroupsNumOps -ugi.UgiMetrics.LoginFailureAvgTime -ugi.UgiMetrics.LoginFailureNumOps -ugi.UgiMetrics.LoginSuccessAvgTime -ugi.UgiMetrics.LoginSuccessNumOps \ No newline at end of file +metricssystem.MetricsSystem.SnapshotNumOps +regionserver.RegionServer.ProcessCallTime_25th_percentile +regionserver.RegionServer.ProcessCallTime_75th_percentile +regionserver.RegionServer.ProcessCallTime_90th_percentile +regionserver.RegionServer.ProcessCallTime_95th_percentile +regionserver.RegionServer.ProcessCallTime_98th_percentile +regionserver.RegionServer.ProcessCallTime_99.9th_percentile +regionserver.RegionServer.ProcessCallTime_99th_percentile +regionserver.RegionServer.ProcessCallTime_max +regionserver.RegionServer.ProcessCallTime_mean +regionserver.RegionServer.ProcessCallTime_median +regionserver.RegionServer.ProcessCallTime_min +regionserver.RegionServer.ProcessCallTime_num_ops +regionserver.RegionServer.QueueCallTime_25th_percentile +regionserver.RegionServer.QueueCallTime_75th_percentile +regionserver.RegionServer.QueueCallTime_90th_percentile +regionserver.RegionServer.QueueCallTime_95th_percentile +regionserver.RegionServer.QueueCallTime_98th_percentile +regionserver.RegionServer.QueueCallTime_99.9th_percentile +regionserver.RegionServer.QueueCallTime_99th_percentile +regionserver.RegionServer.QueueCallTime_max +regionserver.RegionServer.QueueCallTime_mean +regionserver.RegionServer.QueueCallTime_median +regionserver.RegionServer.QueueCallTime_min +regionserver.RegionServer.QueueCallTime_num_ops +regionserver.RegionServer.RequestSize_25th_percentile +regionserver.RegionServer.RequestSize_75th_percentile +regionserver.RegionServer.RequestSize_90th_percentile +regionserver.RegionServer.RequestSize_95th_percentile +regionserver.RegionServer.RequestSize_98th_percentile +regionserver.RegionServer.RequestSize_99.9th_percentile +regionserver.RegionServer.RequestSize_99th_percentile +regionserver.RegionServer.RequestSize_max +regionserver.RegionServer.RequestSize_mean +regionserver.RegionServer.RequestSize_median +regionserver.RegionServer.RequestSize_min +regionserver.RegionServer.RequestSize_num_ops +regionserver.RegionServer.ResponseSize_25th_percentile +regionserver.RegionServer.ResponseSize_75th_percentile +regionserver.RegionServer.ResponseSize_90th_percentile +regionserver.RegionServer.ResponseSize_95th_percentile +regionserver.RegionServer.ResponseSize_98th_percentile +regionserver.RegionServer.ResponseSize_99.9th_percentile +regionserver.RegionServer.ResponseSize_99th_percentile +regionserver.RegionServer.ResponseSize_max +regionserver.RegionServer.ResponseSize_mean +regionserver.RegionServer.ResponseSize_median +regionserver.RegionServer.ResponseSize_min +regionserver.RegionServer.ResponseSize_num_ops +regionserver.RegionServer.TotalCallTime_25th_percentile +regionserver.RegionServer.TotalCallTime_75th_percentile +regionserver.RegionServer.TotalCallTime_90th_percentile +regionserver.RegionServer.TotalCallTime_95th_percentile +regionserver.RegionServer.TotalCallTime_98th_percentile +regionserver.RegionServer.TotalCallTime_99.9th_percentile +regionserver.RegionServer.TotalCallTime_99th_percentile +regionserver.RegionServer.TotalCallTime_max +regionserver.RegionServer.TotalCallTime_mean +regionserver.RegionServer.TotalCallTime_median +regionserver.RegionServer.TotalCallTime_min +regionserver.RegionServer.TotalCallTime_num_ops +regionserver.RegionServer.authenticationFailures +regionserver.RegionServer.authenticationSuccesses +regionserver.RegionServer.authorizationFailures +regionserver.RegionServer.authorizationSuccesses +regionserver.RegionServer.exceptions +regionserver.RegionServer.exceptions.FailedSanityCheckException +regionserver.RegionServer.exceptions.NotServingRegionException +regionserver.RegionServer.exceptions.OutOfOrderScannerNextException +regionserver.RegionServer.exceptions.RegionMovedException +regionserver.RegionServer.exceptions.RegionTooBusyException +regionserver.RegionServer.exceptions.ScannerResetException +regionserver.RegionServer.exceptions.UnknownScannerException +regionserver.RegionServer.numActiveHandler +regionserver.RegionServer.numCallsInGeneralQueue +regionserver.RegionServer.numCallsInPriorityQueue +regionserver.RegionServer.numCallsInReplicationQueue +regionserver.RegionServer.numGeneralCallsDropped +regionserver.RegionServer.numLifoModeSwitches +regionserver.RegionServer.numOpenConnections +regionserver.RegionServer.queueSize +regionserver.RegionServer.receivedBytes +regionserver.RegionServer.sentBytes +regionserver.Replication.sink.ageOfLastAppliedOp +regionserver.Replication.sink.appliedBatches +regionserver.Replication.sink.appliedHFiles +regionserver.Replication.sink.appliedOps +regionserver.Server.Append_25th_percentile +regionserver.Server.Append_75th_percentile +regionserver.Server.Append_90th_percentile +regionserver.Server.Append_95th_percentile +regionserver.Server.Append_98th_percentile +regionserver.Server.Append_99.9th_percentile +regionserver.Server.Append_99th_percentile +regionserver.Server.Append_max +regionserver.Server.Append_mean +regionserver.Server.Append_median +regionserver.Server.Append_min +regionserver.Server.Append_num_ops +regionserver.Server.CompactionInputFileCount_25th_percentile +regionserver.Server.CompactionInputFileCount_75th_percentile +regionserver.Server.CompactionInputFileCount_90th_percentile +regionserver.Server.CompactionInputFileCount_95th_percentile +regionserver.Server.CompactionInputFileCount_98th_percentile +regionserver.Server.CompactionInputFileCount_99.9th_percentile +regionserver.Server.CompactionInputFileCount_99th_percentile +regionserver.Server.CompactionInputFileCount_max +regionserver.Server.CompactionInputFileCount_mean +regionserver.Server.CompactionInputFileCount_median +regionserver.Server.CompactionInputFileCount_min +regionserver.Server.CompactionInputFileCount_num_ops +regionserver.Server.CompactionInputSize_25th_percentile +regionserver.Server.CompactionInputSize_75th_percentile +regionserver.Server.CompactionInputSize_90th_percentile +regionserver.Server.CompactionInputSize_95th_percentile +regionserver.Server.CompactionInputSize_98th_percentile +regionserver.Server.CompactionInputSize_99.9th_percentile +regionserver.Server.CompactionInputSize_99th_percentile +regionserver.Server.CompactionInputSize_SizeRangeCount_100-1000 +regionserver.Server.CompactionInputSize_max +regionserver.Server.CompactionInputSize_mean +regionserver.Server.CompactionInputSize_median +regionserver.Server.CompactionInputSize_min +regionserver.Server.CompactionInputSize_num_ops +regionserver.Server.CompactionOutputFileCount_25th_percentile +regionserver.Server.CompactionOutputFileCount_75th_percentile +regionserver.Server.CompactionOutputFileCount_90th_percentile +regionserver.Server.CompactionOutputFileCount_95th_percentile +regionserver.Server.CompactionOutputFileCount_98th_percentile +regionserver.Server.CompactionOutputFileCount_99.9th_percentile +regionserver.Server.CompactionOutputFileCount_99th_percentile +regionserver.Server.CompactionOutputFileCount_max +regionserver.Server.CompactionOutputFileCount_mean +regionserver.Server.CompactionOutputFileCount_median +regionserver.Server.CompactionOutputFileCount_min +regionserver.Server.CompactionOutputFileCount_num_ops +regionserver.Server.CompactionOutputSize_25th_percentile +regionserver.Server.CompactionOutputSize_75th_percentile +regionserver.Server.CompactionOutputSize_90th_percentile +regionserver.Server.CompactionOutputSize_95th_percentile +regionserver.Server.CompactionOutputSize_98th_percentile +regionserver.Server.CompactionOutputSize_99.9th_percentile +regionserver.Server.CompactionOutputSize_99th_percentile +regionserver.Server.CompactionOutputSize_SizeRangeCount_100-1000 +regionserver.Server.CompactionOutputSize_max +regionserver.Server.CompactionOutputSize_mean +regionserver.Server.CompactionOutputSize_median +regionserver.Server.CompactionOutputSize_min +regionserver.Server.CompactionOutputSize_num_ops +regionserver.Server.CompactionTime_25th_percentile +regionserver.Server.CompactionTime_75th_percentile +regionserver.Server.CompactionTime_90th_percentile +regionserver.Server.CompactionTime_95th_percentile +regionserver.Server.CompactionTime_98th_percentile +regionserver.Server.CompactionTime_99.9th_percentile +regionserver.Server.CompactionTime_99th_percentile +regionserver.Server.CompactionTime_TimeRangeCount_100-300 +regionserver.Server.CompactionTime_max +regionserver.Server.CompactionTime_mean +regionserver.Server.CompactionTime_median +regionserver.Server.CompactionTime_min +regionserver.Server.CompactionTime_num_ops +regionserver.Server.Delete_25th_percentile +regionserver.Server.Delete_75th_percentile +regionserver.Server.Delete_90th_percentile +regionserver.Server.Delete_95th_percentile +regionserver.Server.Delete_98th_percentile +regionserver.Server.Delete_99.9th_percentile +regionserver.Server.Delete_99th_percentile +regionserver.Server.Delete_max +regionserver.Server.Delete_mean +regionserver.Server.Delete_median +regionserver.Server.Delete_min +regionserver.Server.Delete_num_ops +regionserver.Server.FlushMemstoreSize_25th_percentile +regionserver.Server.FlushMemstoreSize_75th_percentile +regionserver.Server.FlushMemstoreSize_90th_percentile +regionserver.Server.FlushMemstoreSize_95th_percentile +regionserver.Server.FlushMemstoreSize_98th_percentile +regionserver.Server.FlushMemstoreSize_99.9th_percentile +regionserver.Server.FlushMemstoreSize_99th_percentile +regionserver.Server.FlushMemstoreSize_SizeRangeCount_100-1000 +regionserver.Server.FlushMemstoreSize_max +regionserver.Server.FlushMemstoreSize_mean +regionserver.Server.FlushMemstoreSize_median +regionserver.Server.FlushMemstoreSize_min +regionserver.Server.FlushMemstoreSize_num_ops +regionserver.Server.FlushOutputSize_25th_percentile +regionserver.Server.FlushOutputSize_75th_percentile +regionserver.Server.FlushOutputSize_90th_percentile +regionserver.Server.FlushOutputSize_95th_percentile +regionserver.Server.FlushOutputSize_98th_percentile +regionserver.Server.FlushOutputSize_99.9th_percentile +regionserver.Server.FlushOutputSize_99th_percentile +regionserver.Server.FlushOutputSize_SizeRangeCount_100-1000 +regionserver.Server.FlushOutputSize_max +regionserver.Server.FlushOutputSize_mean +regionserver.Server.FlushOutputSize_median +regionserver.Server.FlushOutputSize_min +regionserver.Server.FlushOutputSize_num_ops +regionserver.Server.FlushTime_25th_percentile +regionserver.Server.FlushTime_75th_percentile +regionserver.Server.FlushTime_90th_percentile +regionserver.Server.FlushTime_95th_percentile +regionserver.Server.FlushTime_98th_percentile +regionserver.Server.FlushTime_99.9th_percentile +regionserver.Server.FlushTime_99th_percentile +regionserver.Server.FlushTime_max +regionserver.Server.FlushTime_mean +regionserver.Server.FlushTime_median +regionserver.Server.FlushTime_min +regionserver.Server.FlushTime_num_ops +regionserver.Server.Get_25th_percentile +regionserver.Server.Get_75th_percentile +regionserver.Server.Get_90th_percentile +regionserver.Server.Get_95th_percentile +regionserver.Server.Get_98th_percentile +regionserver.Server.Get_99.9th_percentile +regionserver.Server.Get_99th_percentile +regionserver.Server.Get_max +regionserver.Server.Get_mean +regionserver.Server.Get_median +regionserver.Server.Get_min +regionserver.Server.Get_num_ops +regionserver.Server.Increment_25th_percentile +regionserver.Server.Increment_75th_percentile +regionserver.Server.Increment_90th_percentile +regionserver.Server.Increment_95th_percentile +regionserver.Server.Increment_98th_percentile +regionserver.Server.Increment_99.9th_percentile +regionserver.Server.Increment_99th_percentile +regionserver.Server.Increment_max +regionserver.Server.Increment_mean +regionserver.Server.Increment_median +regionserver.Server.Increment_min +regionserver.Server.Increment_num_ops +regionserver.Server.MajorCompactionInputFileCount_25th_percentile +regionserver.Server.MajorCompactionInputFileCount_75th_percentile +regionserver.Server.MajorCompactionInputFileCount_90th_percentile +regionserver.Server.MajorCompactionInputFileCount_95th_percentile +regionserver.Server.MajorCompactionInputFileCount_98th_percentile +regionserver.Server.MajorCompactionInputFileCount_99.9th_percentile +regionserver.Server.MajorCompactionInputFileCount_99th_percentile +regionserver.Server.MajorCompactionInputFileCount_max +regionserver.Server.MajorCompactionInputFileCount_mean +regionserver.Server.MajorCompactionInputFileCount_median +regionserver.Server.MajorCompactionInputFileCount_min +regionserver.Server.MajorCompactionInputFileCount_num_ops +regionserver.Server.MajorCompactionInputSize_25th_percentile +regionserver.Server.MajorCompactionInputSize_75th_percentile +regionserver.Server.MajorCompactionInputSize_90th_percentile +regionserver.Server.MajorCompactionInputSize_95th_percentile +regionserver.Server.MajorCompactionInputSize_98th_percentile +regionserver.Server.MajorCompactionInputSize_99.9th_percentile +regionserver.Server.MajorCompactionInputSize_99th_percentile +regionserver.Server.MajorCompactionInputSize_max +regionserver.Server.MajorCompactionInputSize_mean +regionserver.Server.MajorCompactionInputSize_median +regionserver.Server.MajorCompactionInputSize_min +regionserver.Server.MajorCompactionInputSize_num_ops +regionserver.Server.MajorCompactionOutputFileCount_25th_percentile +regionserver.Server.MajorCompactionOutputFileCount_75th_percentile +regionserver.Server.MajorCompactionOutputFileCount_90th_percentile +regionserver.Server.MajorCompactionOutputFileCount_95th_percentile +regionserver.Server.MajorCompactionOutputFileCount_98th_percentile +regionserver.Server.MajorCompactionOutputFileCount_99.9th_percentile +regionserver.Server.MajorCompactionOutputFileCount_99th_percentile +regionserver.Server.MajorCompactionOutputFileCount_max +regionserver.Server.MajorCompactionOutputFileCount_mean +regionserver.Server.MajorCompactionOutputFileCount_median +regionserver.Server.MajorCompactionOutputFileCount_min +regionserver.Server.MajorCompactionOutputFileCount_num_ops +regionserver.Server.MajorCompactionOutputSize_25th_percentile +regionserver.Server.MajorCompactionOutputSize_75th_percentile +regionserver.Server.MajorCompactionOutputSize_90th_percentile +regionserver.Server.MajorCompactionOutputSize_95th_percentile +regionserver.Server.MajorCompactionOutputSize_98th_percentile +regionserver.Server.MajorCompactionOutputSize_99.9th_percentile +regionserver.Server.MajorCompactionOutputSize_99th_percentile +regionserver.Server.MajorCompactionOutputSize_max +regionserver.Server.MajorCompactionOutputSize_mean +regionserver.Server.MajorCompactionOutputSize_median +regionserver.Server.MajorCompactionOutputSize_min +regionserver.Server.MajorCompactionOutputSize_num_ops +regionserver.Server.MajorCompactionTime_25th_percentile +regionserver.Server.MajorCompactionTime_75th_percentile +regionserver.Server.MajorCompactionTime_90th_percentile +regionserver.Server.MajorCompactionTime_95th_percentile +regionserver.Server.MajorCompactionTime_98th_percentile +regionserver.Server.MajorCompactionTime_99.9th_percentile +regionserver.Server.MajorCompactionTime_99th_percentile +regionserver.Server.MajorCompactionTime_max +regionserver.Server.MajorCompactionTime_mean +regionserver.Server.MajorCompactionTime_median +regionserver.Server.MajorCompactionTime_min +regionserver.Server.MajorCompactionTime_num_ops +regionserver.Server.Mutate_25th_percentile +regionserver.Server.Mutate_75th_percentile +regionserver.Server.Mutate_90th_percentile +regionserver.Server.Mutate_95th_percentile +regionserver.Server.Mutate_98th_percentile +regionserver.Server.Mutate_99.9th_percentile +regionserver.Server.Mutate_99th_percentile +regionserver.Server.Mutate_max +regionserver.Server.Mutate_mean +regionserver.Server.Mutate_median +regionserver.Server.Mutate_min +regionserver.Server.Mutate_num_ops +regionserver.Server.PauseTimeWithGc_25th_percentile +regionserver.Server.PauseTimeWithGc_75th_percentile +regionserver.Server.PauseTimeWithGc_90th_percentile +regionserver.Server.PauseTimeWithGc_95th_percentile +regionserver.Server.PauseTimeWithGc_98th_percentile +regionserver.Server.PauseTimeWithGc_99.9th_percentile +regionserver.Server.PauseTimeWithGc_99th_percentile +regionserver.Server.PauseTimeWithGc_max +regionserver.Server.PauseTimeWithGc_mean +regionserver.Server.PauseTimeWithGc_median +regionserver.Server.PauseTimeWithGc_min +regionserver.Server.PauseTimeWithGc_num_ops +regionserver.Server.PauseTimeWithoutGc_25th_percentile +regionserver.Server.PauseTimeWithoutGc_75th_percentile +regionserver.Server.PauseTimeWithoutGc_90th_percentile +regionserver.Server.PauseTimeWithoutGc_95th_percentile +regionserver.Server.PauseTimeWithoutGc_98th_percentile +regionserver.Server.PauseTimeWithoutGc_99.9th_percentile +regionserver.Server.PauseTimeWithoutGc_99th_percentile +regionserver.Server.PauseTimeWithoutGc_max +regionserver.Server.PauseTimeWithoutGc_mean +regionserver.Server.PauseTimeWithoutGc_median +regionserver.Server.PauseTimeWithoutGc_min +regionserver.Server.PauseTimeWithoutGc_num_ops +regionserver.Server.Replay_25th_percentile +regionserver.Server.Replay_75th_percentile +regionserver.Server.Replay_90th_percentile +regionserver.Server.Replay_95th_percentile +regionserver.Server.Replay_98th_percentile +regionserver.Server.Replay_99.9th_percentile +regionserver.Server.Replay_99th_percentile +regionserver.Server.Replay_max +regionserver.Server.Replay_mean +regionserver.Server.Replay_median +regionserver.Server.Replay_min +regionserver.Server.Replay_num_ops +regionserver.Server.ScanSize_25th_percentile +regionserver.Server.ScanSize_75th_percentile +regionserver.Server.ScanSize_90th_percentile +regionserver.Server.ScanSize_95th_percentile +regionserver.Server.ScanSize_98th_percentile +regionserver.Server.ScanSize_99.9th_percentile +regionserver.Server.ScanSize_99th_percentile +regionserver.Server.ScanSize_max +regionserver.Server.ScanSize_mean +regionserver.Server.ScanSize_median +regionserver.Server.ScanSize_min +regionserver.Server.ScanSize_num_ops +regionserver.Server.ScanTime_25th_percentile +regionserver.Server.ScanTime_75th_percentile +regionserver.Server.ScanTime_90th_percentile +regionserver.Server.ScanTime_95th_percentile +regionserver.Server.ScanTime_98th_percentile +regionserver.Server.ScanTime_99.9th_percentile +regionserver.Server.ScanTime_99th_percentile +regionserver.Server.ScanTime_max +regionserver.Server.ScanTime_mean +regionserver.Server.ScanTime_median +regionserver.Server.ScanTime_min +regionserver.Server.ScanTime_num_ops +regionserver.Server.SplitTime_25th_percentile +regionserver.Server.SplitTime_75th_percentile +regionserver.Server.SplitTime_90th_percentile +regionserver.Server.SplitTime_95th_percentile +regionserver.Server.SplitTime_98th_percentile +regionserver.Server.SplitTime_99.9th_percentile +regionserver.Server.SplitTime_99th_percentile +regionserver.Server.SplitTime_max +regionserver.Server.SplitTime_mean +regionserver.Server.SplitTime_median +regionserver.Server.SplitTime_min +regionserver.Server.SplitTime_num_ops +regionserver.Server.averageRegionSize +regionserver.Server.avgStoreFileAge +regionserver.Server.blockCacheBloomChunkHitCount +regionserver.Server.blockCacheBloomChunkMissCount +regionserver.Server.blockCacheCount +regionserver.Server.blockCacheCountHitPercent +regionserver.Server.blockCacheDataHitCount +regionserver.Server.blockCacheDataMissCount +regionserver.Server.blockCacheDeleteFamilyBloomHitCount +regionserver.Server.blockCacheDeleteFamilyBloomMissCount +regionserver.Server.blockCacheEvictionCount +regionserver.Server.blockCacheEvictionCountPrimary +regionserver.Server.blockCacheExpressHitPercent +regionserver.Server.blockCacheFileInfoHitCount +regionserver.Server.blockCacheFileInfoMissCount +regionserver.Server.blockCacheFreeSize +regionserver.Server.blockCacheGeneralBloomMetaHitCount +regionserver.Server.blockCacheGeneralBloomMetaMissCount +regionserver.Server.blockCacheHitCount +regionserver.Server.blockCacheHitCountPrimary +regionserver.Server.blockCacheIntermediateIndexHitCount +regionserver.Server.blockCacheIntermediateIndexMissCount +regionserver.Server.blockCacheLeafIndexHitCount +regionserver.Server.blockCacheLeafIndexMissCount +regionserver.Server.blockCacheMetaHitCount +regionserver.Server.blockCacheMetaMissCount +regionserver.Server.blockCacheMissCount +regionserver.Server.blockCacheMissCountPrimary +regionserver.Server.blockCacheRootIndexHitCount +regionserver.Server.blockCacheRootIndexMissCount +regionserver.Server.blockCacheSize +regionserver.Server.blockCacheTrailerHitCount +regionserver.Server.blockCacheTrailerMissCount +regionserver.Server.blockedRequestCount +regionserver.Server.cellsCountCompactedFromMob +regionserver.Server.cellsCountCompactedToMob +regionserver.Server.cellsSizeCompactedFromMob +regionserver.Server.cellsSizeCompactedToMob +regionserver.Server.checkMutateFailedCount +regionserver.Server.checkMutatePassedCount +regionserver.Server.compactedCellsCount +regionserver.Server.compactedCellsSize +regionserver.Server.compactedInputBytes +regionserver.Server.compactedOutputBytes +regionserver.Server.compactionQueueLength +regionserver.Server.flushQueueLength +regionserver.Server.flushedCellsCount +regionserver.Server.flushedCellsSize +regionserver.Server.flushedMemstoreBytes +regionserver.Server.flushedOutputBytes +regionserver.Server.hlogFileCount +regionserver.Server.hlogFileSize +regionserver.Server.largeCompactionQueueLength +regionserver.Server.majorCompactedCellsCount +regionserver.Server.majorCompactedCellsSize +regionserver.Server.majorCompactedInputBytes +regionserver.Server.majorCompactedOutputBytes +regionserver.Server.maxStoreFileAge +regionserver.Server.memStoreSize +regionserver.Server.minStoreFileAge +regionserver.Server.mobFileCacheAccessCount +regionserver.Server.mobFileCacheCount +regionserver.Server.mobFileCacheEvictedCount +regionserver.Server.mobFileCacheHitPercent +regionserver.Server.mobFileCacheMissCount +regionserver.Server.mobFlushCount +regionserver.Server.mobFlushedCellsCount +regionserver.Server.mobFlushedCellsSize +regionserver.Server.mobScanCellsCount +regionserver.Server.mobScanCellsSize +regionserver.Server.mutationsWithoutWALCount +regionserver.Server.mutationsWithoutWALSize +regionserver.Server.numReferenceFiles +regionserver.Server.pauseInfoThresholdExceeded +regionserver.Server.pauseWarnThresholdExceeded +regionserver.Server.percentFilesLocal +regionserver.Server.percentFilesLocalSecondaryRegions +regionserver.Server.readRequestCount +regionserver.Server.regionCount +regionserver.Server.regionServerStartTime +regionserver.Server.rpcGetRequestCount +regionserver.Server.rpcMultiRequestCount +regionserver.Server.rpcMutateRequestCount +regionserver.Server.rpcScanRequestCount +regionserver.Server.slowAppendCount +regionserver.Server.slowDeleteCount +regionserver.Server.slowGetCount +regionserver.Server.slowIncrementCount +regionserver.Server.slowPutCount +regionserver.Server.smallCompactionQueueLength +regionserver.Server.splitQueueLength +regionserver.Server.splitRequestCount +regionserver.Server.splitSuccessCount +regionserver.Server.staticBloomSize +regionserver.Server.staticIndexSize +regionserver.Server.storeCount +regionserver.Server.storeFileCount +regionserver.Server.storeFileIndexSize +regionserver.Server.storeFileSize +regionserver.Server.totalRequestCount +regionserver.Server.updatesBlockedTime +regionserver.Server.writeRequestCount +regionserver.WAL.AppendSize_25th_percentile +regionserver.WAL.AppendSize_75th_percentile +regionserver.WAL.AppendSize_90th_percentile +regionserver.WAL.AppendSize_95th_percentile +regionserver.WAL.AppendSize_98th_percentile +regionserver.WAL.AppendSize_99.9th_percentile +regionserver.WAL.AppendSize_99th_percentile +regionserver.WAL.AppendSize_SizeRangeCount_100-1000 +regionserver.WAL.AppendSize_max +regionserver.WAL.AppendSize_mean +regionserver.WAL.AppendSize_median +regionserver.WAL.AppendSize_min +regionserver.WAL.AppendSize_num_ops +regionserver.WAL.AppendTime_25th_percentile +regionserver.WAL.AppendTime_75th_percentile +regionserver.WAL.AppendTime_90th_percentile +regionserver.WAL.AppendTime_95th_percentile +regionserver.WAL.AppendTime_98th_percentile +regionserver.WAL.AppendTime_99.9th_percentile +regionserver.WAL.AppendTime_99th_percentile +regionserver.WAL.AppendTime_TimeRangeCount_0-1 +regionserver.WAL.AppendTime_max +regionserver.WAL.AppendTime_mean +regionserver.WAL.AppendTime_median +regionserver.WAL.AppendTime_min +regionserver.WAL.AppendTime_num_ops +regionserver.WAL.SyncTime_25th_percentile +regionserver.WAL.SyncTime_75th_percentile +regionserver.WAL.SyncTime_90th_percentile +regionserver.WAL.SyncTime_95th_percentile +regionserver.WAL.SyncTime_98th_percentile +regionserver.WAL.SyncTime_99.9th_percentile +regionserver.WAL.SyncTime_99th_percentile +regionserver.WAL.SyncTime_TimeRangeCount_0-1 +regionserver.WAL.SyncTime_TimeRangeCount_1-3 +regionserver.WAL.SyncTime_TimeRangeCount_10-30 +regionserver.WAL.SyncTime_TimeRangeCount_3-10 +regionserver.WAL.SyncTime_TimeRangeCount_30-100 +regionserver.WAL.SyncTime_max +regionserver.WAL.SyncTime_mean +regionserver.WAL.SyncTime_median +regionserver.WAL.SyncTime_min +regionserver.WAL.SyncTime_num_ops +regionserver.WAL.appendCount +regionserver.WAL.lowReplicaRollRequest +regionserver.WAL.rollRequest +regionserver.WAL.slowAppendCount +regionserver.WAL.writtenBytes +ugi.UgiMetrics.GetGroupsAvgTime +ugi.UgiMetrics.GetGroupsNumOps +ugi.UgiMetrics.LoginFailureAvgTime +ugi.UgiMetrics.LoginFailureNumOps +ugi.UgiMetrics.LoginSuccessAvgTime +ugi.UgiMetrics.LoginSuccessNumOps +ugi.UgiMetrics.RenewalFailures +ugi.UgiMetrics.RenewalFailuresTotal \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ambari/blob/041e4e9a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/ITPhoenixHBaseAccessor.java ---------------------------------------------------------------------- diff --git a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/ITPhoenixHBaseAccessor.java b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/ITPhoenixHBaseAccessor.java index f6d69f6..c25d414 100644 --- a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/ITPhoenixHBaseAccessor.java +++ b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/ITPhoenixHBaseAccessor.java @@ -111,7 +111,7 @@ public class ITPhoenixHBaseAccessor extends AbstractMiniHBaseClusterTest { public void testGetMetricRecordsMinutes() throws IOException, SQLException { // GIVEN TimelineMetricAggregator aggregatorMinute = - TimelineMetricAggregatorFactory.createTimelineMetricAggregatorMinute(hdb, new Configuration(), null); + TimelineMetricAggregatorFactory.createTimelineMetricAggregatorMinute(hdb, new Configuration(), null, null); long startTime = System.currentTimeMillis(); long ctime = startTime; @@ -149,7 +149,7 @@ public class ITPhoenixHBaseAccessor extends AbstractMiniHBaseClusterTest { public void testGetMetricRecordsHours() throws IOException, SQLException { // GIVEN TimelineMetricAggregator aggregator = - TimelineMetricAggregatorFactory.createTimelineMetricAggregatorHourly(hdb, new Configuration(), null); + TimelineMetricAggregatorFactory.createTimelineMetricAggregatorHourly(hdb, new Configuration(), null, null); MetricHostAggregate expectedAggregate = createMetricHostAggregate(2.0, 0.0, 20, 15.0); @@ -283,7 +283,7 @@ public class ITPhoenixHBaseAccessor extends AbstractMiniHBaseClusterTest { public void testGetClusterMetricRecordsHours() throws Exception { // GIVEN TimelineMetricAggregator agg = - TimelineMetricAggregatorFactory.createTimelineClusterAggregatorHourly(hdb, new Configuration(), null); + TimelineMetricAggregatorFactory.createTimelineClusterAggregatorHourly(hdb, new Configuration(), null, null); long startTime = System.currentTimeMillis(); long ctime = startTime; http://git-wip-us.apache.org/repos/asf/ambari/blob/041e4e9a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/MetricTestHelper.java ---------------------------------------------------------------------- diff --git a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/MetricTestHelper.java b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/MetricTestHelper.java index 7eeb9c4..7dfe1fc 100644 --- a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/MetricTestHelper.java +++ b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/MetricTestHelper.java @@ -109,7 +109,7 @@ public class MetricTestHelper { public static TimelineClusterMetric createEmptyTimelineClusterMetric( String name, long startTime) { TimelineClusterMetric metric = new TimelineClusterMetric(name, - "test_app", "instance_id", startTime, null); + "test_app", "instance_id", startTime); return metric; } http://git-wip-us.apache.org/repos/asf/ambari/blob/041e4e9a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/PhoenixHBaseAccessorTest.java ---------------------------------------------------------------------- diff --git a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/PhoenixHBaseAccessorTest.java b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/PhoenixHBaseAccessorTest.java index bf9246d..7be3c0d 100644 --- a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/PhoenixHBaseAccessorTest.java +++ b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/PhoenixHBaseAccessorTest.java @@ -29,6 +29,7 @@ import org.apache.hadoop.metrics2.sink.timeline.TimelineMetric; import org.apache.hadoop.metrics2.sink.timeline.TimelineMetrics; import org.apache.hadoop.yarn.server.applicationhistoryservice.metrics.timeline.aggregators.TimelineClusterMetric; import org.apache.hadoop.yarn.server.applicationhistoryservice.metrics.timeline.aggregators.Function; +import org.apache.hadoop.yarn.server.applicationhistoryservice.metrics.timeline.discovery.TimelineMetricMetadataManager; import org.apache.hadoop.yarn.server.applicationhistoryservice.metrics.timeline.query.Condition; import org.apache.hadoop.yarn.server.applicationhistoryservice.metrics.timeline.query.DefaultCondition; import org.apache.hadoop.yarn.server.applicationhistoryservice.metrics.timeline.query.PhoenixConnectionProvider; @@ -55,6 +56,7 @@ import java.util.LinkedList; import java.util.List; import java.util.Map; +import static org.easymock.EasyMock.anyObject; import static org.easymock.EasyMock.expect; import static org.junit.Assert.assertEquals; import static org.junit.Assert.fail; @@ -256,7 +258,7 @@ public class PhoenixHBaseAccessorTest { TimelineClusterMetric clusterMetric = new TimelineClusterMetric("metricName", "appId", "instanceId", - System.currentTimeMillis(), "type"); + System.currentTimeMillis()); TimelineMetric timelineMetric = new TimelineMetric(); timelineMetric.setMetricName("Metric1"); timelineMetric.setType("type1"); @@ -268,6 +270,12 @@ public class PhoenixHBaseAccessorTest { clusterTimeAggregateMap.put(clusterMetric, new MetricHostAggregate()); hostAggregateMap.put(timelineMetric, new MetricHostAggregate()); + TimelineMetricMetadataManager metricMetadataManagerMock = EasyMock.createMock(TimelineMetricMetadataManager.class); + expect(metricMetadataManagerMock.getUuid(anyObject(TimelineClusterMetric.class))).andReturn(new byte[16]).times(2); + expect(metricMetadataManagerMock.getUuid(anyObject(TimelineMetric.class))).andReturn(new byte[20]).once(); + replay(metricMetadataManagerMock); + + accessor.setMetadataInstance(metricMetadataManagerMock); accessor.saveClusterAggregateRecords(clusterAggregateMap); accessor.saveHostAggregateRecords(hostAggregateMap, PhoenixTransactSQL.METRICS_AGGREGATE_MINUTE_TABLE_NAME); http://git-wip-us.apache.org/repos/asf/ambari/blob/041e4e9a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TestPhoenixTransactSQL.java ---------------------------------------------------------------------- diff --git a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TestPhoenixTransactSQL.java b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TestPhoenixTransactSQL.java index e988a61..dd73a8a 100644 --- a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TestPhoenixTransactSQL.java +++ b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TestPhoenixTransactSQL.java @@ -26,6 +26,7 @@ import org.apache.hadoop.yarn.server.applicationhistoryservice.metrics.timeline. import org.apache.hadoop.yarn.server.applicationhistoryservice.metrics.timeline.query.TopNCondition; import org.easymock.Capture; import org.junit.Assert; +import org.junit.Ignore; import org.junit.Test; import java.sql.Connection; import java.sql.ParameterMetaData; @@ -46,13 +47,12 @@ import org.easymock.EasyMock; public class TestPhoenixTransactSQL { @Test public void testConditionClause() throws Exception { - Condition condition = new DefaultCondition( + Condition condition = new DefaultCondition(Arrays.asList(new byte[8], new byte[8]), new ArrayList<>(Arrays.asList("cpu_user", "mem_free")), Collections.singletonList("h1"), "a1", "i1", 1407959718L, 1407959918L, null, null, false); String preparedClause = condition.getConditionClause().toString(); - String expectedClause = "(METRIC_NAME IN (?, ?)) AND HOSTNAME = ? AND " + - "APP_ID = ? AND INSTANCE_ID = ? AND SERVER_TIME >= ? AND SERVER_TIME < ?"; + String expectedClause = "(UUID IN (?, ?)) AND SERVER_TIME >= ? AND SERVER_TIME < ?"; Assert.assertNotNull(preparedClause); Assert.assertEquals(expectedClause, preparedClause); @@ -60,21 +60,21 @@ public class TestPhoenixTransactSQL { @Test public void testSplitByMetricNamesCondition() throws Exception { - Condition c = new DefaultCondition( + Condition c = new DefaultCondition(Arrays.asList(new byte[8], new byte[8]), Arrays.asList("cpu_user", "mem_free"), Collections.singletonList("h1"), "a1", "i1", 1407959718L, 1407959918L, null, null, false); SplitByMetricNamesCondition condition = new SplitByMetricNamesCondition(c); - condition.setCurrentMetric(c.getMetricNames().get(0)); + condition.setCurrentUuid(new byte[8]); String preparedClause = condition.getConditionClause().toString(); - String expectedClause = "METRIC_NAME = ? AND HOSTNAME = ? AND " + - "APP_ID = ? AND INSTANCE_ID = ? AND SERVER_TIME >= ? AND SERVER_TIME < ?"; + String expectedClause = "UUID = ? AND SERVER_TIME >= ? AND SERVER_TIME < ?"; Assert.assertNotNull(preparedClause); Assert.assertEquals(expectedClause, preparedClause); } + @Ignore @Test public void testLikeConditionClause() throws Exception { Condition condition = new DefaultCondition( @@ -363,7 +363,7 @@ public class TestPhoenixTransactSQL { @Test public void testPrepareGetLatestMetricSqlStmtMultipleHostNames() throws SQLException { - Condition condition = new DefaultCondition( + Condition condition = new DefaultCondition(Arrays.asList(new byte[16], new byte[16], new byte[16], new byte[16]), new ArrayList<>(Arrays.asList("cpu_user", "mem_free")), Arrays.asList("h1", "h2"), "a1", "i1", null, null, null, null, false); Connection connection = createNiceMock(Connection.class); @@ -376,7 +376,7 @@ public class TestPhoenixTransactSQL { .andReturn(parameterMetaData).once(); // 6 = 1 instance_id + 1 appd_id + 2 hostnames + 2 metric names expect(parameterMetaData.getParameterCount()) - .andReturn(6).once(); + .andReturn(4).once(); replay(connection, preparedStatement, parameterMetaData); PhoenixTransactSQL.prepareGetLatestMetricSqlStmt(connection, condition); @@ -389,7 +389,7 @@ public class TestPhoenixTransactSQL { @Test public void testPrepareGetLatestMetricSqlStmtSortMergeJoinAlgorithm() throws SQLException { - Condition condition = new DefaultCondition( + Condition condition = new DefaultCondition(Arrays.asList(new byte[16], new byte[16]), new ArrayList<>(Arrays.asList("cpu_user", "mem_free")), Arrays.asList("h1"), "a1", "i1", null, null, null, null, false); Connection connection = createNiceMock(Connection.class); @@ -401,7 +401,7 @@ public class TestPhoenixTransactSQL { expect(preparedStatement.getParameterMetaData()) .andReturn(parameterMetaData).anyTimes(); expect(parameterMetaData.getParameterCount()) - .andReturn(6).anyTimes(); + .andReturn(2).anyTimes(); replay(connection, preparedStatement, parameterMetaData); PhoenixTransactSQL.setSortMergeJoinEnabled(true); @@ -558,22 +558,19 @@ public class TestPhoenixTransactSQL { @Test public void testTopNHostsConditionClause() throws Exception { - List<String> hosts = Arrays.asList("h1", "h2", "h3", "h4"); + List<String> hosts = Arrays.asList("h1", "h2"); + List<byte[]> uuids = Arrays.asList(new byte[16], new byte[16]); - Condition condition = new TopNCondition( - new ArrayList<>(Collections.singletonList("cpu_user")), hosts, + Condition condition = new TopNCondition(uuids, new ArrayList<>(Collections.singletonList("cpu_user")), hosts, "a1", "i1", 1407959718L, 1407959918L, null, null, false, 2, null, false); String conditionClause = condition.getConditionClause().toString(); - String expectedClause = "(METRIC_NAME IN (?)) AND HOSTNAME IN (" + - "SELECT " + PhoenixTransactSQL.getNaiveTimeRangeHint(condition.getStartTime(),120000l) + - " HOSTNAME FROM METRIC_RECORD WHERE " + - "(METRIC_NAME IN (?)) AND " + - "HOSTNAME IN (? ,? ,? ,?) AND " + - "APP_ID = ? AND INSTANCE_ID = ? AND " + + String expectedClause = " UUID IN (" + + "SELECT " + PhoenixTransactSQL.getNaiveTimeRangeHint(condition.getStartTime(),120000l) + " " + + "UUID FROM METRIC_RECORD WHERE " + + "(UUID IN (?, ?)) AND " + "SERVER_TIME >= ? AND SERVER_TIME < ? " + - "GROUP BY METRIC_NAME, HOSTNAME, APP_ID ORDER BY MAX(METRIC_MAX) DESC LIMIT 2) " + - "AND APP_ID = ? AND INSTANCE_ID = ? AND SERVER_TIME >= ? AND SERVER_TIME < ?"; + "GROUP BY UUID ORDER BY MAX(METRIC_MAX) DESC LIMIT 2) AND SERVER_TIME >= ? AND SERVER_TIME < ?"; Assert.assertEquals(expectedClause, conditionClause); } @@ -581,21 +578,18 @@ public class TestPhoenixTransactSQL { @Test public void testTopNMetricsConditionClause() throws Exception { List<String> metricNames = new ArrayList<>(Arrays.asList("m1", "m2", "m3")); + List<byte[]> uuids = Arrays.asList(new byte[16], new byte[16], new byte[16]); - Condition condition = new TopNCondition( - metricNames, Collections.singletonList("h1"), + Condition condition = new TopNCondition(uuids, metricNames, Collections.singletonList("h1"), "a1", "i1", 1407959718L, 1407959918L, null, null, false, 2, null, false); String conditionClause = condition.getConditionClause().toString(); - String expectedClause = " METRIC_NAME IN (" + + String expectedClause = " UUID IN (" + "SELECT " + PhoenixTransactSQL.getNaiveTimeRangeHint(condition.getStartTime(),120000l) + - " METRIC_NAME FROM METRIC_RECORD WHERE " + - "(METRIC_NAME IN (?, ?, ?)) AND " + - "HOSTNAME = ? AND " + - "APP_ID = ? AND INSTANCE_ID = ? AND " + + " UUID FROM METRIC_RECORD WHERE " + + "(UUID IN (?, ?, ?)) AND " + "SERVER_TIME >= ? AND SERVER_TIME < ? " + - "GROUP BY METRIC_NAME, APP_ID ORDER BY MAX(METRIC_MAX) DESC LIMIT 2) " + - "AND HOSTNAME = ? AND APP_ID = ? AND INSTANCE_ID = ? AND SERVER_TIME >= ? AND SERVER_TIME < ?"; + "GROUP BY UUID ORDER BY MAX(METRIC_MAX) DESC LIMIT 2) AND SERVER_TIME >= ? AND SERVER_TIME < ?"; Assert.assertEquals(expectedClause, conditionClause); } @@ -605,57 +599,12 @@ public class TestPhoenixTransactSQL { List<String> metricNames = new ArrayList<>(Arrays.asList("m1", "m2")); List<String> hosts = Arrays.asList("h1", "h2"); + List<byte[]> uuids = Arrays.asList(new byte[16], new byte[16], new byte[16], new byte[16]); - Condition condition = new TopNCondition( - metricNames, hosts, + Condition condition = new TopNCondition(uuids, metricNames, hosts, "a1", "i1", 1407959718L, 1407959918L, null, null, false, 2, null, false); Assert.assertEquals(condition.getConditionClause(), null); } - @Test - public void testHostsRegexpConditionClause() { - Condition condition = new TopNCondition( - new ArrayList<>(Arrays.asList("m1")), Arrays.asList("%.ambari", "host1.apache"), - "a1", "i1", 1407959718L, 1407959918L, null, null, false, 2, null, false); - - String conditionClause = condition.getConditionClause().toString(); - String expectedClause = "(METRIC_NAME IN (?)) AND HOSTNAME IN (SELECT " + - PhoenixTransactSQL.getNaiveTimeRangeHint(condition.getStartTime(),120000l) + - " HOSTNAME FROM METRIC_RECORD WHERE (METRIC_NAME IN (?)) " + - "AND (HOSTNAME LIKE ? OR HOSTNAME LIKE ?) AND APP_ID = ? AND INSTANCE_ID = ? AND SERVER_TIME >= ? AND SERVER_TIME < ? GROUP BY " + - "METRIC_NAME, HOSTNAME, APP_ID ORDER BY MAX(METRIC_MAX) DESC LIMIT 2) AND APP_ID = ? AND INSTANCE_ID = ? AND " + - "SERVER_TIME >= ? AND SERVER_TIME < ?"; - Assert.assertEquals(expectedClause, conditionClause); - - condition = new TopNCondition( - new ArrayList<>(Arrays.asList("m1")), Arrays.asList("%.ambari"), - "a1", "i1", 1407959718L, 1407959918L, null, null, false, 2, null, false); - - conditionClause = condition.getConditionClause().toString(); - expectedClause = "(METRIC_NAME IN (?)) AND HOSTNAME IN (SELECT " + - PhoenixTransactSQL.getNaiveTimeRangeHint(condition.getStartTime(),120000l) + - " HOSTNAME FROM METRIC_RECORD WHERE (METRIC_NAME IN (?)) " + - "AND (HOSTNAME LIKE ?) AND APP_ID = ? AND INSTANCE_ID = ? AND SERVER_TIME >= ? AND SERVER_TIME < ? GROUP BY " + - "METRIC_NAME, HOSTNAME, APP_ID ORDER BY MAX(METRIC_MAX) DESC LIMIT 2) AND APP_ID = ? AND INSTANCE_ID = ? AND " + - "SERVER_TIME >= ? AND SERVER_TIME < ?"; - - Assert.assertEquals(expectedClause, conditionClause); - - condition = new TopNCondition( - new ArrayList<>(Arrays.asList("m1", "m2", "m3")), Arrays.asList("h1.ambari"), - "a1", "i1", 1407959718L, 1407959918L, null, null, false, 2, null, false); - - conditionClause = condition.getConditionClause().toString(); - expectedClause = " METRIC_NAME IN (" + - "SELECT " + PhoenixTransactSQL.getNaiveTimeRangeHint(condition.getStartTime(),120000l) + - " METRIC_NAME FROM METRIC_RECORD WHERE " + - "(METRIC_NAME IN (?, ?, ?)) AND " + - "HOSTNAME = ? AND " + - "APP_ID = ? AND INSTANCE_ID = ? AND " + - "SERVER_TIME >= ? AND SERVER_TIME < ? " + - "GROUP BY METRIC_NAME, APP_ID ORDER BY MAX(METRIC_MAX) DESC LIMIT 2) " + - "AND HOSTNAME = ? AND APP_ID = ? AND INSTANCE_ID = ? AND SERVER_TIME >= ? AND SERVER_TIME < ?"; - Assert.assertEquals(expectedClause, conditionClause); - } } http://git-wip-us.apache.org/repos/asf/ambari/blob/041e4e9a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TestTimelineMetricStore.java ---------------------------------------------------------------------- diff --git a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TestTimelineMetricStore.java b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TestTimelineMetricStore.java index ac2f9d7..95a0e86 100644 --- a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TestTimelineMetricStore.java +++ b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TestTimelineMetricStore.java @@ -25,6 +25,8 @@ import org.apache.hadoop.metrics2.sink.timeline.TimelineMetricMetadata; import org.apache.hadoop.metrics2.sink.timeline.TimelineMetrics; import org.apache.hadoop.metrics2.sink.timeline.TopNConfig; import org.apache.hadoop.yarn.api.records.timeline.TimelinePutResponse; +import org.apache.hadoop.yarn.server.applicationhistoryservice.metrics.timeline.discovery.TimelineMetricMetadataKey; + import java.io.IOException; import java.sql.SQLException; import java.util.ArrayList; @@ -111,4 +113,12 @@ public class TestTimelineMetricStore implements TimelineMetricStore { public List<String> getLiveInstances() { return Collections.emptyList(); } + + @Override + public Map<String, TimelineMetricMetadataKey> getUuids() throws SQLException, IOException { + return null; + } + } + + http://git-wip-us.apache.org/repos/asf/ambari/blob/041e4e9a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TimelineMetricsAggregatorMemorySink.java ---------------------------------------------------------------------- diff --git a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TimelineMetricsAggregatorMemorySink.java b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TimelineMetricsAggregatorMemorySink.java index 53f6f6c..51cde4a 100644 --- a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TimelineMetricsAggregatorMemorySink.java +++ b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TimelineMetricsAggregatorMemorySink.java @@ -92,7 +92,7 @@ public class TimelineMetricsAggregatorMemorySink TimelineClusterMetric clusterMetricClone = new TimelineClusterMetric(clusterMetric.getMetricName(), clusterMetric.getAppId(), clusterMetric.getInstanceId(), - clusterMetric.getTimestamp(), clusterMetric.getType()); + clusterMetric.getTimestamp()); MetricHostAggregate hostAggregate = entry.getValue(); MetricHostAggregate hostAggregateClone = new MetricHostAggregate( hostAggregate.getSum(), (int) hostAggregate.getNumberOfSamples(), @@ -116,7 +116,7 @@ public class TimelineMetricsAggregatorMemorySink TimelineClusterMetric clusterMetricClone = new TimelineClusterMetric(clusterMetric.getMetricName(), clusterMetric.getAppId(), clusterMetric.getInstanceId(), - clusterMetric.getTimestamp(), clusterMetric.getType()); + clusterMetric.getTimestamp()); MetricClusterAggregate clusterAggregate = entry.getValue(); MetricClusterAggregate clusterAggregateClone = new MetricClusterAggregate( clusterAggregate.getSum(), (int) clusterAggregate.getNumberOfHosts(), http://git-wip-us.apache.org/repos/asf/ambari/blob/041e4e9a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/DownSamplerTest.java ---------------------------------------------------------------------- diff --git a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/DownSamplerTest.java b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/DownSamplerTest.java index a0fea40..0fca2e3 100644 --- a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/DownSamplerTest.java +++ b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/DownSamplerTest.java @@ -20,6 +20,7 @@ package org.apache.hadoop.yarn.server.applicationhistoryservice.metrics.timeline import junit.framework.Assert; import org.apache.hadoop.conf.Configuration; +import org.junit.Ignore; import org.junit.Test; import java.util.List; @@ -57,6 +58,7 @@ public class DownSamplerTest { Assert.assertTrue(downSamplers.get(0) instanceof TopNDownSampler); } + @Ignore @Test public void testPrepareTopNDownSamplingStatement() throws Exception { Configuration configuration = new Configuration(); http://git-wip-us.apache.org/repos/asf/ambari/blob/041e4e9a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/ITClusterAggregator.java ---------------------------------------------------------------------- diff --git a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/ITClusterAggregator.java b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/ITClusterAggregator.java index 86c9b40..e66e65d 100644 --- a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/ITClusterAggregator.java +++ b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/ITClusterAggregator.java @@ -94,7 +94,6 @@ public class ITClusterAggregator extends AbstractMiniHBaseClusterTest { Condition condition = new DefaultCondition(null, null, null, null, startTime, endTime, null, null, true); condition.setStatement(String.format(GET_CLUSTER_AGGREGATE_SQL, - PhoenixTransactSQL.getNaiveTimeRangeHint(startTime, NATIVE_TIME_RANGE_DELTA), METRICS_CLUSTER_AGGREGATE_TABLE_NAME)); PreparedStatement pstmt = PhoenixTransactSQL.prepareGetMetricsSqlStmt(conn, condition); @@ -169,7 +168,6 @@ public class ITClusterAggregator extends AbstractMiniHBaseClusterTest { Condition condition = new DefaultCondition(null, null, null, null, startTime, endTime, null, null, true); condition.setStatement(String.format(GET_CLUSTER_AGGREGATE_SQL, - PhoenixTransactSQL.getNaiveTimeRangeHint(startTime, NATIVE_TIME_RANGE_DELTA), METRICS_CLUSTER_AGGREGATE_TABLE_NAME)); PreparedStatement pstmt = PhoenixTransactSQL.prepareGetMetricsSqlStmt(conn, condition); @@ -229,7 +227,6 @@ public class ITClusterAggregator extends AbstractMiniHBaseClusterTest { Condition condition = new DefaultCondition(null, null, null, null, startTime, endTime, null, null, true); condition.setStatement(String.format(GET_CLUSTER_AGGREGATE_SQL, - PhoenixTransactSQL.getNaiveTimeRangeHint(startTime, NATIVE_TIME_RANGE_DELTA), METRICS_CLUSTER_AGGREGATE_TABLE_NAME)); PreparedStatement pstmt = PhoenixTransactSQL.prepareGetMetricsSqlStmt(conn, condition); @@ -263,7 +260,7 @@ public class ITClusterAggregator extends AbstractMiniHBaseClusterTest { public void testAggregateDailyClusterMetrics() throws Exception { // GIVEN TimelineMetricAggregator agg = - TimelineMetricAggregatorFactory.createTimelineClusterAggregatorDaily(hdb, getConfigurationForTest(false), null); + TimelineMetricAggregatorFactory.createTimelineClusterAggregatorDaily(hdb, getConfigurationForTest(false), null, null); // this time can be virtualized! or made independent from real clock long startTime = System.currentTimeMillis(); @@ -308,7 +305,7 @@ public class ITClusterAggregator extends AbstractMiniHBaseClusterTest { public void testShouldAggregateClusterOnMinuteProperly() throws Exception { TimelineMetricAggregator agg = - TimelineMetricAggregatorFactory.createTimelineClusterAggregatorMinute(hdb, getConfigurationForTest(false), null); + TimelineMetricAggregatorFactory.createTimelineClusterAggregatorMinute(hdb, getConfigurationForTest(false), null, null); long startTime = System.currentTimeMillis(); long ctime = startTime; @@ -375,7 +372,7 @@ public class ITClusterAggregator extends AbstractMiniHBaseClusterTest { public void testShouldAggregateClusterOnHourProperly() throws Exception { // GIVEN TimelineMetricAggregator agg = - TimelineMetricAggregatorFactory.createTimelineClusterAggregatorHourly(hdb, getConfigurationForTest(false), null); + TimelineMetricAggregatorFactory.createTimelineClusterAggregatorHourly(hdb, getConfigurationForTest(false), null, null); // this time can be virtualized! or made independent from real clock long startTime = System.currentTimeMillis(); @@ -419,7 +416,7 @@ public class ITClusterAggregator extends AbstractMiniHBaseClusterTest { public void testShouldAggregateDifferentMetricsOnHourProperly() throws Exception { // GIVEN TimelineMetricAggregator agg = - TimelineMetricAggregatorFactory.createTimelineClusterAggregatorHourly(hdb, getConfigurationForTest(false), null); + TimelineMetricAggregatorFactory.createTimelineClusterAggregatorHourly(hdb, getConfigurationForTest(false), null, null); long startTime = System.currentTimeMillis(); long ctime = startTime; @@ -507,7 +504,6 @@ public class ITClusterAggregator extends AbstractMiniHBaseClusterTest { new ArrayList<String>() {{ add("cpu_user"); }}, null, "app1", null, startTime, endTime, null, null, true); condition.setStatement(String.format(GET_CLUSTER_AGGREGATE_SQL, - PhoenixTransactSQL.getNaiveTimeRangeHint(startTime, NATIVE_TIME_RANGE_DELTA), METRICS_CLUSTER_AGGREGATE_TABLE_NAME)); PreparedStatement pstmt = PhoenixTransactSQL.prepareGetMetricsSqlStmt(conn, condition); @@ -583,7 +579,6 @@ public class ITClusterAggregator extends AbstractMiniHBaseClusterTest { Condition condition = new DefaultCondition(null, null, null, null, startTime, endTime, null, null, true); condition.setStatement(String.format(GET_CLUSTER_AGGREGATE_SQL, - PhoenixTransactSQL.getNaiveTimeRangeHint(startTime, NATIVE_TIME_RANGE_DELTA), METRICS_CLUSTER_AGGREGATE_TABLE_NAME)); PreparedStatement pstmt = PhoenixTransactSQL.prepareGetMetricsSqlStmt(conn, condition); @@ -611,7 +606,7 @@ public class ITClusterAggregator extends AbstractMiniHBaseClusterTest { public void testAggregationUsingGroupByQuery() throws Exception { // GIVEN TimelineMetricAggregator agg = - TimelineMetricAggregatorFactory.createTimelineClusterAggregatorHourly(hdb, getConfigurationForTest(true), null); + TimelineMetricAggregatorFactory.createTimelineClusterAggregatorHourly(hdb, getConfigurationForTest(true), null, null); long startTime = System.currentTimeMillis(); long ctime = startTime; http://git-wip-us.apache.org/repos/asf/ambari/blob/041e4e9a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/ITMetricAggregator.java ---------------------------------------------------------------------- diff --git a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/ITMetricAggregator.java b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/ITMetricAggregator.java index 75b3f91..14ac4d7 100644 --- a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/ITMetricAggregator.java +++ b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/ITMetricAggregator.java @@ -85,7 +85,7 @@ public class ITMetricAggregator extends AbstractMiniHBaseClusterTest { // GIVEN TimelineMetricAggregator aggregatorMinute = TimelineMetricAggregatorFactory.createTimelineMetricAggregatorMinute(hdb, - getConfigurationForTest(false), null); + getConfigurationForTest(false), null, null); TimelineMetricReadHelper readHelper = new TimelineMetricReadHelper(false); long startTime = System.currentTimeMillis(); @@ -146,7 +146,7 @@ public class ITMetricAggregator extends AbstractMiniHBaseClusterTest { // GIVEN TimelineMetricAggregator aggregator = TimelineMetricAggregatorFactory.createTimelineMetricAggregatorHourly(hdb, - getConfigurationForTest(false), null); + getConfigurationForTest(false), null, null); TimelineMetricReadHelper readHelper = new TimelineMetricReadHelper(false); long startTime = System.currentTimeMillis(); @@ -209,7 +209,7 @@ public class ITMetricAggregator extends AbstractMiniHBaseClusterTest { // GIVEN TimelineMetricAggregator aggregator = TimelineMetricAggregatorFactory.createTimelineMetricAggregatorDaily(hdb, - getConfigurationForTest(false), null); + getConfigurationForTest(false), null, null); TimelineMetricReadHelper readHelper = new TimelineMetricReadHelper(false); long startTime = System.currentTimeMillis(); @@ -271,7 +271,7 @@ public class ITMetricAggregator extends AbstractMiniHBaseClusterTest { // GIVEN TimelineMetricAggregator aggregatorMinute = TimelineMetricAggregatorFactory.createTimelineMetricAggregatorMinute(hdb, - getConfigurationForTest(true), null); + getConfigurationForTest(true), null, null); TimelineMetricReadHelper readHelper = new TimelineMetricReadHelper(false); long startTime = System.currentTimeMillis(); http://git-wip-us.apache.org/repos/asf/ambari/blob/041e4e9a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/TimelineMetricClusterAggregatorSecondTest.java ---------------------------------------------------------------------- diff --git a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/TimelineMetricClusterAggregatorSecondTest.java b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/TimelineMetricClusterAggregatorSecondTest.java index 6541b2c..937dd80 100644 --- a/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/TimelineMetricClusterAggregatorSecondTest.java +++ b/ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/aggregators/TimelineMetricClusterAggregatorSecondTest.java @@ -19,9 +19,11 @@ package org.apache.hadoop.yarn.server.applicationhistoryservice.metrics.timeline import static org.apache.hadoop.yarn.server.applicationhistoryservice.metrics.timeline.availability.AggregationTaskRunner.AGGREGATOR_NAME.METRIC_AGGREGATE_SECOND; +import static org.easymock.EasyMock.anyBoolean; import static org.easymock.EasyMock.anyObject; import static org.easymock.EasyMock.createNiceMock; import static org.easymock.EasyMock.expect; +import static org.easymock.EasyMock.expectLastCall; import static org.easymock.EasyMock.replay; import java.sql.ResultSet; @@ -51,6 +53,8 @@ public class TimelineMetricClusterAggregatorSecondTest { Configuration configuration = new Configuration(); TimelineMetricMetadataManager metricMetadataManagerMock = createNiceMock(TimelineMetricMetadataManager.class); + expect(metricMetadataManagerMock.getUuid(anyObject(TimelineClusterMetric.class))).andReturn(new byte[16]).once(); + replay(metricMetadataManagerMock); TimelineMetricClusterAggregatorSecond secondAggregator = new TimelineMetricClusterAggregatorSecond( METRIC_AGGREGATE_SECOND, metricMetadataManagerMock, null, @@ -84,7 +88,7 @@ public class TimelineMetricClusterAggregatorSecondTest { Map<TimelineClusterMetric, Double> timelineClusterMetricMap = secondAggregator.sliceFromTimelineMetric(counterMetric, timeSlices); TimelineClusterMetric timelineClusterMetric = new TimelineClusterMetric(counterMetric.getMetricName(), counterMetric.getAppId(), - counterMetric.getInstanceId(), 0l, null); + counterMetric.getInstanceId(), 0l); timelineClusterMetric.setTimestamp(roundedStartTime + 2*sliceInterval); Assert.assertTrue(timelineClusterMetricMap.containsKey(timelineClusterMetric)); @@ -103,7 +107,7 @@ public class TimelineMetricClusterAggregatorSecondTest { timelineClusterMetricMap = secondAggregator.sliceFromTimelineMetric(metric, timeSlices); timelineClusterMetric = new TimelineClusterMetric(metric.getMetricName(), metric.getAppId(), - metric.getInstanceId(), 0l, null); + metric.getInstanceId(), 0l); timelineClusterMetric.setTimestamp(roundedStartTime + 2*sliceInterval); Assert.assertTrue(timelineClusterMetricMap.containsKey(timelineClusterMetric)); @@ -168,7 +172,7 @@ public class TimelineMetricClusterAggregatorSecondTest { Assert.assertEquals(aggregateClusterMetrics.size(), 4); TimelineClusterMetric timelineClusterMetric = new TimelineClusterMetric(timelineMetric.getMetricName(), - timelineMetric.getAppId(), timelineMetric.getInstanceId(), startTime + 30*seconds, timelineMetric.getType()); + timelineMetric.getAppId(), timelineMetric.getInstanceId(), startTime + 30*seconds); Assert.assertTrue(aggregateClusterMetrics.containsKey(timelineClusterMetric)); Assert.assertEquals(aggregateClusterMetrics.get(timelineClusterMetric).getSum(), 1.0); @@ -330,6 +334,29 @@ public class TimelineMetricClusterAggregatorSecondTest { TimelineMetricMetadataManager metricMetadataManagerMock = createNiceMock(TimelineMetricMetadataManager.class); expect(metricMetadataManagerMock.getMetadataCacheValue((TimelineMetricMetadataKey) anyObject())).andReturn(null).anyTimes(); + + /* + m1-h1-a1 + m2-h1-a1 + m2-h1-a2 + m2-h2-a1 + m2-h2-a2 + m2-h3-a2 + + So live_hosts : a1 = 2 + live_hosts : a2 = 3 + */ + + TimelineMetric metric1 = new TimelineMetric("m1", "h1", "a1", null); + TimelineMetric metric2 = new TimelineMetric("m2", "h1", "a1", null); + TimelineMetric metric3 = new TimelineMetric("m2", "h1", "a2", null); + TimelineMetric metric4 = new TimelineMetric("m2", "h2", "a1", null); + TimelineMetric metric5 = new TimelineMetric("m2", "h2", "a2", null); + TimelineMetric metric6 = new TimelineMetric("m2", "h3", "a2", null); + + expect(metricMetadataManagerMock.getMetricFromUuid((byte[]) anyObject())). + andReturn(metric1).andReturn(metric2).andReturn(metric3). + andReturn(metric4).andReturn(metric5).andReturn(metric6); replay(metricMetadataManagerMock); TimelineMetricClusterAggregatorSecond secondAggregator = new TimelineMetricClusterAggregatorSecond( @@ -344,40 +371,16 @@ public class TimelineMetricClusterAggregatorSecondTest { ResultSet rs = createNiceMock(ResultSet.class); TreeMap<Long, Double> metricValues = new TreeMap<>(); - metricValues.put(startTime + 15*seconds, 1.0); - metricValues.put(startTime + 45*seconds, 2.0); - metricValues.put(startTime + 75*seconds, 3.0); - metricValues.put(startTime + 105*seconds, 4.0); + metricValues.put(startTime + 15 * seconds, 1.0); + metricValues.put(startTime + 45 * seconds, 2.0); + metricValues.put(startTime + 75 * seconds, 3.0); + metricValues.put(startTime + 105 * seconds, 4.0); expect(rs.next()).andReturn(true).times(6); expect(rs.next()).andReturn(false); - /* - m1-h1-a1 - m2-h1-a1 - m2-h1-a2 - m2-h2-a1 - m2-h2-a2 - m2-h3-a2 - - So live_hosts : a1 = 2 - live_hosts : a2 = 3 - */ - expect(rs.getString("METRIC_NAME")).andReturn("m1").times(1); - expect(rs.getString("METRIC_NAME")).andReturn("m2").times(5); - - expect(rs.getString("HOSTNAME")).andReturn("h1").times(3); - expect(rs.getString("HOSTNAME")).andReturn("h2").times(2); - expect(rs.getString("HOSTNAME")).andReturn("h3").times(1); - - expect(rs.getString("APP_ID")).andReturn("a1").times(2); - expect(rs.getString("APP_ID")).andReturn("a2").times(1); - expect(rs.getString("APP_ID")).andReturn("a1").times(1); - expect(rs.getString("APP_ID")).andReturn("a2").times(2); - expect(rs.getLong("SERVER_TIME")).andReturn(now - 150000).times(6); expect(rs.getLong("START_TIME")).andReturn(now - 150000).times(6); - expect(rs.getString("UNITS")).andReturn(null).times(6); ObjectMapper mapper = new ObjectMapper(); expect(rs.getString("METRICS")).andReturn(mapper.writeValueAsString(metricValues)).times(6);
