Package | Description |
---|---|
org.apache.flink.runtime.metrics.groups | |
org.apache.flink.runtime.metrics.scope | |
org.apache.flink.runtime.taskexecutor |
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
TaskManagerMetricGroup |
TaskManagerServices.getTaskManagerMetricGroup() |
Constructor and Description |
---|
TaskExecutor(RpcService rpcService,
TaskManagerConfiguration taskManagerConfiguration,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment networkEnvironment,
HighAvailabilityServices haServices,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
TaskManagerMetricGroup taskManagerMetricGroup,
BroadcastVariableManager broadcastVariableManager,
FileCache fileCache,
TaskSlotTable taskSlotTable,
JobManagerTable jobManagerTable,
JobLeaderService jobLeaderService,
FatalErrorHandler fatalErrorHandler) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.