Package org.apache.flink.kubernetes.operator.metrics

Class KubernetesResourceScopeFormat

java.lang.Object

org.apache.flink.runtime.metrics.scope.ScopeFormat

org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat

public class KubernetesResourceScopeFormat
extends org.apache.flink.runtime.metrics.scope.ScopeFormat

Format for metrics.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	RESOURCE

Fields inherited from class org.apache.flink.runtime.metrics.scope.ScopeFormat

SCOPE_HOST, SCOPE_INHERIT_PARENT, SCOPE_JOB_ID, SCOPE_JOB_NAME, SCOPE_OPERATOR_ID, SCOPE_OPERATOR_NAME, SCOPE_SEPARATOR, SCOPE_TASK_ATTEMPT_ID, SCOPE_TASK_ATTEMPT_NUM, SCOPE_TASK_NAME, SCOPE_TASK_SUBTASK_INDEX, SCOPE_TASK_VERTEX_ID, SCOPE_TASKMANAGER_ID

Constructor Summary

Constructors

Constructor	Description
KubernetesResourceScopeFormat(java.lang.String format)

Method Summary

Modifier and Type	Method	Description
java.lang.String[]	formatScope(java.lang.String namespace, java.lang.String name, java.lang.String hostname, java.lang.String resourceNs, java.lang.String resourceName, java.lang.String resourceType)
static KubernetesResourceScopeFormat	fromConfig(org.apache.flink.configuration.Configuration config)

Methods inherited from class org.apache.flink.runtime.metrics.scope.ScopeFormat

arrayToMap, asVariable, bindVariables, concat, copyTemplate, format, toString, valueOrNull

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

RESOURCE

public static final java.lang.String RESOURCE

Constructor Detail

KubernetesResourceScopeFormat

public KubernetesResourceScopeFormat(java.lang.String format)

Method Detail

formatScope

public java.lang.String[] formatScope(java.lang.String namespace,
                                      java.lang.String name,
                                      java.lang.String hostname,
                                      java.lang.String resourceNs,
                                      java.lang.String resourceName,
                                      java.lang.String resourceType)

fromConfig

public static KubernetesResourceScopeFormat fromConfig(org.apache.flink.configuration.Configuration config)