public EpicRetractingInfo getRetractInfo(TopicPartition topicPartition) {
    EpicRetractingInfo info = retractingInfo.get(topicPartition);
    if (info == null) {
      throw new IllegalStateException(
          String.format(
              "the topic partition: %s, %d is not in retracting state",
              topicPartition.topic(), topicPartition.partition()));
    }
    return info;
  }
Turn row kind of a row.

<pre>
+I -> -D
-D -> +I
-U -> +U
+U -> -U
</pre>

@param rowData Before reset row
@return After reset row kind.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/source/log/LogSourceHelper.java