public CassandraSinkBuilder setHost()

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

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

        public CassandraSinkBuilder<IN> setHost(final String host, final int port) {
            if (this.builder != null) {
                throw new IllegalArgumentException(
                        "Builder was already set. You must use either setHost() or setClusterBuilder().");
            }
            this.builder =
                    new ClusterBuilder() {
                        @Override
                        protected Cluster buildCluster(Cluster.Builder builder) {
                            return builder.addContactPoint(host).withPort(port).build();
                        }
                    };
            return this;
        }