public CassandraSinkBuilder setClusterBuilder()

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

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

        public CassandraSinkBuilder<IN> setClusterBuilder(ClusterBuilder builder) {
            if (this.builder != null) {
                throw new IllegalArgumentException(
                        "Builder was already set. You must use either setHost() or setClusterBuilder().");
            }
            this.builder = builder;
            return this;
        }