private BoundStatement bind()

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

• 11 lines of code
• 4 McCabe index (conditional complexity)

    private BoundStatement bind(Object[] fields) {
        BoundStatement bs = ps.bind(fields);
        if (ignoreNullFields) {
            for (int i = 0; i < fields.length; i++) {
                if (fields[i] == null) {
                    bs.unset(i);
                }
            }
        }
        return bs;
    }