pyflink.datastream.connectors.cassandra.CassandraFailureHandler

class CassandraFailureHandler(j_cassandra_failure_handler)

Handle a failed Throwable.

Methods

no_op()

A CassandraFailureHandler that simply fails the sink on any failures.