eagle-jpm/eagle-hadoop-queue/src/main/java/org/apache/eagle/hadoop/queue/common/HadoopClusterConstants.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 *  Unless required by applicable law or agreed to in writing, software
 *  distributed under the License is distributed on an "AS IS" BASIS,
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *  See the License for the specific language governing permissions and
 *  limitations under the License.
 *
 */
package org.apache.eagle.hadoop.queue.common;

public class HadoopClusterConstants {

    public enum AggregateFunc {
        MAX, AVG
    }

    public enum DataType {
        METRIC, ENTITY
    }

    public enum DataSource {
        CLUSTER_METRIC, RUNNING_APPS, SCHEDULER
    }

    public static class MetricName {

        // Metrics from running apps
        public static final String HADOOP_APPS_ALLOCATED_MB = "hadoop.%s.allocatedmb";
        public static final String HADOOP_APPS_ALLOCATED_VCORES = "hadoop.%s.allocatedvcores";
        public static final String HADOOP_APPS_RUNNING_CONTAINERS = "hadoop.%s.runningcontainers";

        // metrics from cluster metrics
        public static final String HADOOP_CLUSTER_NUMPENDING_JOBS = "hadoop.cluster.numpendingjobs";
        public static final String HADOOP_CLUSTER_ALLOCATED_MEMORY = "hadoop.cluster.allocatedmemory";
        public static final String HADOOP_CLUSTER_TOTAL_MEMORY = "hadoop.cluster.totalmemory";
        public static final String HADOOP_CLUSTER_AVAILABLE_MEMORY = "hadoop.cluster.availablememory";
        public static final String HADOOP_CLUSTER_RESERVED_MEMORY = "hadoop.cluster.reservedmemory";
        public static final String HADOOP_CLUSTER_TOTAL_VIRTUAL_CORES = "hadoop.cluster.totalvirtualcores";
        public static final String HADOOP_CLUSTER_ALLOCATED_VIRTUAL_CORES = "hadoop.cluster.allocatedvcores";

        // metrics from scheduler info
        public static final String HADOOP_CLUSTER_CAPACITY = "hadoop.cluster.capacity";
        public static final String HADOOP_CLUSTER_USED_CAPACITY = "hadoop.cluster.usedcapacity";

        public static final String HADOOP_QUEUE_NUMPENDING_JOBS = "hadoop.queue.numpendingjobs";
        public static final String HADOOP_QUEUE_USED_CAPACITY = "hadoop.queue.usedcapacity";
        public static final String HADOOP_QUEUE_USED_CAPACITY_RATIO = "hadoop.queue.usedcapacityratio";

        public static final String HADOOP_USER_NUMPENDING_JOBS = "hadoop.user.numpendingjobs";
        public static final String HADOOP_USER_USED_MEMORY = "hadoop.user.usedmemory";
        public static final String HADOOP_USER_USED_MEMORY_RATIO = "hadoop.user.usedmemoryratio";

    }

    public static class LeafQueueInfo {
        public static final String TIMESTAMP = "timestamp";
        public static final String QUEUE_SITE = "site";
        public static final String QUEUE_NAME = "queue";
        public static final String QUEUE_STATE = "state";
        public static final String QUEUE_SCHEDULER = "scheduler";
        public static final String QUEUE_ABSOLUTE_CAPACITY = "absoluteCapacity";
        public static final String QUEUE_ABSOLUTE_MAX_CAPACITY = "absoluteMaxCapacity";
        public static final String QUEUE_ABSOLUTE_USED_CAPACITY = "absoluteUsedCapacity";
        public static final String QUEUE_MAX_USER_USED_CAPACITY = "maxUserUsedCapacity";
        public static final String QUEUE_USER_LIMIT_CAPACITY = "userLimitCapacity";
        public static final String QUEUE_USED_MEMORY = "memory";
        public static final String QUEUE_USED_VCORES = "vcores";
        public static final String QUEUE_NUM_ACTIVE_APPS = "numActiveApplications";
        public static final String QUEUE_NUM_PENDING_APPS = "numPendingApplications";
        public static final String QUEUE_MAX_ACTIVE_APPS = "maxActiveApplications";
    }

    public static final String RUNNING_QUEUE_SERVICE_NAME = "RunningQueueService";

    // tag constants
    public static final String TAG_PARENT_QUEUE = "parentQueue";
    public static final String TAG_QUEUE = "queue";
    public static final String TAG_USER = "user";
    public static final String TAG_SITE = "site";
    public static final String TAG_CLUSTER = "cluster";

    // field constants
    public static final String FIELD_DATATYPE = "dataType";
    public static final String FIELD_DATA = "data";

}