public OUT nextRecord()

in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraInputFormat.java [61:67]

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

    public OUT nextRecord(OUT reuse) throws IOException {
        final Row item = resultSet.one();
        for (int i = 0; i < reuse.getArity(); i++) {
            reuse.setField(item.getObject(i), i);
        }
        return reuse;
    }