public Mutation convertToMutation()

in flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/RowDataToMutationConverter.java [50:57]

• 8 lines of code
• 3 McCabe index (conditional complexity)

    public Mutation convertToMutation(RowData record) {
        RowKind kind = record.getRowKind();
        if (kind == RowKind.INSERT || kind == RowKind.UPDATE_AFTER) {
            return serde.createPutMutation(record);
        } else {
            return serde.createDeleteMutation(record);
        }
    }