protected void sanityCheck()

in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java [471:476]

• 6 lines of code
• 2 McCabe index (conditional complexity)

        protected void sanityCheck() {
            if (builder == null) {
                throw new IllegalArgumentException(
                        "Cassandra host information must be supplied using either setHost() or setClusterBuilder().");
            }
        }