Modifier and Type | Method and Description |
---|---|
CompletableFuture<OperatorBackPressureStatsResponse> |
Dispatcher.requestOperatorBackPressureStats(JobID jobId,
JobVertexID jobVertexId) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<OperatorBackPressureStatsResponse> |
JobMaster.requestOperatorBackPressureStats(JobVertexID jobVertexId) |
CompletableFuture<OperatorBackPressureStatsResponse> |
JobMasterGateway.requestOperatorBackPressureStats(JobVertexID jobVertexId)
Requests the statistics on operator back pressure.
|
Modifier and Type | Method and Description |
---|---|
static OperatorBackPressureStatsResponse |
OperatorBackPressureStatsResponse.of(OperatorBackPressureStats operatorBackPressureStats) |
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<OperatorBackPressureStatsResponse> |
RestfulGateway.requestOperatorBackPressureStats(JobID jobId,
JobVertexID jobVertexId)
Requests the statistics on operator back pressure.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.