public class FailureMapper<T> extends RichMapFunction<T,T> implements CheckpointListener
The total times to simulate a failure across multiple execution attempts of the operator can also be configured. Note that this also takes into account failures that were not triggered by this mapper, e.g. TaskManager failures.
|Constructor and Description|
|Modifier and Type||Method and Description|
The mapping method.
This method is called as a notification once a distributed checkpoint has been completed.
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public FailureMapper(long numProcessedRecordsFailureThreshold, long numCompleteCheckpointsFailureThreshold, int maxNumFailures)
public void notifyCheckpointComplete(long checkpointId) throws Exception
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.