Modifier and Type | Class and Description |
---|---|
static class |
UnregisteredMetricGroups.UnregisteredTaskManagerMetricGroup
A safe drop-in replacement for
TaskManagerMetricGroup s. |
Modifier and Type | Method and Description |
---|---|
static TaskManagerMetricGroup |
UnregisteredMetricGroups.createUnregisteredTaskManagerMetricGroup() |
TaskManagerMetricGroup |
TaskManagerJobMetricGroup.parent() |
Constructor and Description |
---|
TaskManagerJobMetricGroup(MetricRegistry registry,
TaskManagerMetricGroup parent,
JobID jobId,
String jobName) |
Modifier and Type | Method and Description |
---|---|
String[] |
TaskManagerJobScopeFormat.formatScope(TaskManagerMetricGroup parent,
JobID jid,
String jobName) |
Modifier and Type | Method and Description |
---|---|
static TaskManagerMetricGroup |
MetricUtils.instantiateTaskManagerMetricGroup(MetricRegistry metricRegistry,
TaskManagerLocation taskManagerLocation,
NetworkEnvironment network) |
Constructor and Description |
---|
TaskExecutor(RpcService rpcService,
TaskManagerConfiguration taskManagerConfiguration,
HighAvailabilityServices haServices,
TaskManagerServices taskExecutorServices,
HeartbeatServices heartbeatServices,
TaskManagerMetricGroup taskManagerMetricGroup,
BlobCacheService blobCacheService,
FatalErrorHandler fatalErrorHandler) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.