public Row convert()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/converter/RowResultRowConverter.java [30:45]

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

    public Row convert(RowResult row) {
        Schema schema = row.getColumnProjection();

        Row values = new Row(schema.getColumnCount());
        schema.getColumns()
                .forEach(
                        column -> {
                            String name = column.getName();
                            int pos = schema.getColumnIndex(name);
                            if (row.isNull(name)) {
                                return;
                            }
                            values.setField(pos, row.getObject(name));
                        });
        return values;
    }