org.apache.flink.streaming.runtime.tasks

Class CheckpointExceptionHandlerFactory

java.lang.Object

org.apache.flink.streaming.runtime.tasks.CheckpointExceptionHandlerFactory

public class CheckpointExceptionHandlerFactory
extends Object

This factory produces CheckpointExceptionHandler instances that handle exceptions during checkpointing in a StreamTask.

Constructor Summary

Constructors

Constructor and Description
CheckpointExceptionHandlerFactory()

Method Summary

Modifier and Type	Method and Description
CheckpointExceptionHandler	createCheckpointExceptionHandler(boolean failTaskOnCheckpointException, Environment environment) Returns a CheckpointExceptionHandler that either causes a task to fail completely or to just declines checkpoint on exception, depending on the parameter flag.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CheckpointExceptionHandlerFactory

public CheckpointExceptionHandlerFactory()

Method Detail

createCheckpointExceptionHandler

public CheckpointExceptionHandler createCheckpointExceptionHandler(boolean failTaskOnCheckpointException,
                                                                   Environment environment)

Returns a CheckpointExceptionHandler that either causes a task to fail completely or to just declines checkpoint on exception, depending on the parameter flag.