public CassandraAppendTableSink configure()

in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraAppendTableSink.java [69:81]

13 lines of code
1 McCabe index (conditional complexity)


    public CassandraAppendTableSink configure(
            String[] fieldNames, TypeInformation<?>[] fieldTypes) {
        CassandraAppendTableSink cassandraTableSink =
                new CassandraAppendTableSink(this.builder, this.cql, this.properties);
        cassandraTableSink.fieldNames =
                Preconditions.checkNotNull(fieldNames, "Field names must not be null.");
        cassandraTableSink.fieldTypes =
                Preconditions.checkNotNull(fieldTypes, "Field types must not be null.");
        Preconditions.checkArgument(
                fieldNames.length == fieldTypes.length,
                "Number of provided field names and types does not match.");
        return cassandraTableSink;
    }