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 Tuple2<TaskManagerMetricGroup,MetricGroup> |
MetricUtils.instantiateTaskManagerMetricGroup(MetricRegistry metricRegistry,
String hostName,
ResourceID resourceID,
Optional<Time> systemResourceProbeInterval) |
Constructor and Description |
---|
TaskExecutor(RpcService rpcService,
TaskManagerConfiguration taskManagerConfiguration,
HighAvailabilityServices haServices,
TaskManagerServices taskExecutorServices,
ExternalResourceInfoProvider externalResourceInfoProvider,
HeartbeatServices heartbeatServices,
TaskManagerMetricGroup taskManagerMetricGroup,
String metricQueryServiceAddress,
BlobCacheService blobCacheService,
FatalErrorHandler fatalErrorHandler,
TaskExecutorPartitionTracker partitionTracker,
BackPressureSampleService backPressureSampleService) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.