public Mutation convertToMutation()

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

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

    public Mutation convertToMutation(RowData record) {
        Long timestamp = timestampMetadata.read(record);
        Long timeToLive = timeToLiveMetadata.read(record);
        RowKind kind = record.getRowKind();
        if (kind == RowKind.INSERT || kind == RowKind.UPDATE_AFTER) {
            return serde.createPutMutation(record, timestamp, timeToLive);
        } else {
            return serde.createDeleteMutation(record, timestamp);
        }
    }