org.apache.flink.streaming.connectors.cassandra

Interface CassandraFailureHandler

All Superinterfaces:

Serializable

All Known Implementing Classes:

NoOpCassandraFailureHandler

@PublicEvolving
public interface CassandraFailureHandler
extends Serializable

An implementation of CassandraFailureHandler is provided by the user to define how Throwable should be handled, e.g. dropping them if the failure is only temporary.

Example:

{@code
        private static class ExampleFailureHandler implements CassandraFailureHandler {

Method Summary

Modifier and Type	Method and Description
void	onFailure(Throwable failure) Handle a failed Throwable.

Method Detail

onFailure

void onFailure(Throwable failure)
        throws IOException

Handle a failed Throwable.

Parameters:

failure - the cause of failure

Throws:

IOException - if the sink should fail on this failure, the implementation should rethrow the throwable or a custom one