@Internal public class NoOpCassandraFailureHandler extends Object implements CassandraFailureHandler
CassandraFailureHandler
that simply fails the sink on any failures.Constructor and Description |
---|
NoOpCassandraFailureHandler() |
public void onFailure(Throwable failure) throws IOException
CassandraFailureHandler
Throwable
.onFailure
in interface CassandraFailureHandler
failure
- the cause of failureIOException
- if the sink should fail on this failure, the implementation should
rethrow the throwable or a custom oneCopyright © 2014–2022 The Apache Software Foundation. All rights reserved.