Java源码示例：org.apache.flink.runtime.rest.messages.checkpoints.TaskCheckpointMessageParameters
示例1
public TaskCheckpointStatisticDetailsHandler(
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String, String> responseHeaders,
MessageHeaders<EmptyRequestBody, TaskCheckpointStatisticsWithSubtaskDetails, TaskCheckpointMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor,
CheckpointStatsCache checkpointStatsCache) {
super(
leaderRetriever,
timeout,
responseHeaders,
messageHeaders,
executionGraphCache,
executor,
checkpointStatsCache);
}
示例2
public TaskCheckpointStatisticDetailsHandler(
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String, String> responseHeaders,
MessageHeaders<EmptyRequestBody, TaskCheckpointStatisticsWithSubtaskDetails, TaskCheckpointMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor,
CheckpointStatsCache checkpointStatsCache) {
super(
leaderRetriever,
timeout,
responseHeaders,
messageHeaders,
executionGraphCache,
executor,
checkpointStatsCache);
}
示例3
public TaskCheckpointStatisticDetailsHandler(
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String, String> responseHeaders,
MessageHeaders<EmptyRequestBody, TaskCheckpointStatisticsWithSubtaskDetails, TaskCheckpointMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor,
CheckpointStatsCache checkpointStatsCache) {
super(
leaderRetriever,
timeout,
responseHeaders,
messageHeaders,
executionGraphCache,
executor,
checkpointStatsCache);
}
示例4
@Override
protected TaskCheckpointStatisticsWithSubtaskDetails handleCheckpointRequest(
HandlerRequest<EmptyRequestBody, TaskCheckpointMessageParameters> request,
AbstractCheckpointStats checkpointStats) throws RestHandlerException {
final JobVertexID jobVertexId = request.getPathParameter(JobVertexIdPathParameter.class);
final TaskStateStats taskStatistics = checkpointStats.getTaskStateStats(jobVertexId);
if (taskStatistics == null) {
throw new NotFoundException("There is no checkpoint statistics for task " + jobVertexId + '.');
}
return createCheckpointDetails(checkpointStats, taskStatistics);
}
示例5
@Override
protected TaskCheckpointStatisticsWithSubtaskDetails handleCheckpointRequest(
HandlerRequest<EmptyRequestBody, TaskCheckpointMessageParameters> request,
AbstractCheckpointStats checkpointStats) throws RestHandlerException {
final JobVertexID jobVertexId = request.getPathParameter(JobVertexIdPathParameter.class);
final TaskStateStats taskStatistics = checkpointStats.getTaskStateStats(jobVertexId);
if (taskStatistics == null) {
throw new NotFoundException("There is no checkpoint statistics for task " + jobVertexId + '.');
}
return createCheckpointDetails(checkpointStats, taskStatistics);
}
示例6
@Override
protected TaskCheckpointStatisticsWithSubtaskDetails handleCheckpointRequest(
HandlerRequest<EmptyRequestBody, TaskCheckpointMessageParameters> request,
AbstractCheckpointStats checkpointStats) throws RestHandlerException {
final JobVertexID jobVertexId = request.getPathParameter(JobVertexIdPathParameter.class);
final TaskStateStats taskStatistics = checkpointStats.getTaskStateStats(jobVertexId);
if (taskStatistics == null) {
throw new NotFoundException("There is no checkpoint statistics for task " + jobVertexId + '.');
}
return createCheckpointDetails(checkpointStats, taskStatistics);
}
