Uses of Class
org.apache.flink.runtime.metrics.groups.TaskManagerJobMetricGroup
-
-
Uses of TaskManagerJobMetricGroup in org.apache.flink.runtime.metrics.groups
Subclasses of TaskManagerJobMetricGroup in org.apache.flink.runtime.metrics.groups Modifier and Type Class Description static classUnregisteredMetricGroups.UnregisteredTaskManagerJobMetricGroupA safe drop-in replacement forTaskManagerJobMetricGroups.Methods in org.apache.flink.runtime.metrics.groups that return TaskManagerJobMetricGroup Modifier and Type Method Description TaskManagerJobMetricGroupTaskManagerMetricGroup. addJob(org.apache.flink.api.common.JobID jobId, String jobName)static TaskManagerJobMetricGroupUnregisteredMetricGroups. createUnregisteredTaskManagerJobMetricGroup()TaskManagerJobMetricGroupTaskManagerMetricGroup. getJobMetricsGroup(org.apache.flink.api.common.JobID jobId)TaskManagerJobMetricGroupTaskMetricGroup. parent() -
Uses of TaskManagerJobMetricGroup in org.apache.flink.runtime.metrics.scope
Methods in org.apache.flink.runtime.metrics.scope with parameters of type TaskManagerJobMetricGroup Modifier and Type Method Description String[]TaskScopeFormat. formatScope(TaskManagerJobMetricGroup parent, org.apache.flink.util.AbstractID vertexId, ExecutionAttemptID attemptId, String taskName, int subtask, int attemptNumber) -
Uses of TaskManagerJobMetricGroup in org.apache.flink.runtime.state
Methods in org.apache.flink.runtime.state with parameters of type TaskManagerJobMetricGroup Modifier and Type Method Description StateChangelogStorage<?>TaskExecutorStateChangelogStoragesManager. stateChangelogStorageForJob(org.apache.flink.api.common.JobID jobId, org.apache.flink.configuration.Configuration configuration, TaskManagerJobMetricGroup metricGroup, LocalRecoveryConfig localRecoveryConfig) -
Uses of TaskManagerJobMetricGroup in org.apache.flink.runtime.state.changelog
Methods in org.apache.flink.runtime.state.changelog with parameters of type TaskManagerJobMetricGroup Modifier and Type Method Description StateChangelogStorage<?>StateChangelogStorageFactory. createStorage(org.apache.flink.api.common.JobID jobID, org.apache.flink.configuration.Configuration configuration, TaskManagerJobMetricGroup metricGroup, LocalRecoveryConfig localRecoveryConfig)Create the storage based on a configuration.static StateChangelogStorage<?>StateChangelogStorageLoader. load(org.apache.flink.api.common.JobID jobID, org.apache.flink.configuration.Configuration configuration, TaskManagerJobMetricGroup metricGroup, LocalRecoveryConfig localRecoveryConfig) -
Uses of TaskManagerJobMetricGroup in org.apache.flink.runtime.state.changelog.inmemory
Methods in org.apache.flink.runtime.state.changelog.inmemory with parameters of type TaskManagerJobMetricGroup Modifier and Type Method Description StateChangelogStorage<?>InMemoryStateChangelogStorageFactory. createStorage(org.apache.flink.api.common.JobID jobID, org.apache.flink.configuration.Configuration configuration, TaskManagerJobMetricGroup metricGroup, LocalRecoveryConfig localRecoveryConfig)
-