public boolean belongsTo()

in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/domain/TransactionId.java [195:212]

• 13 lines of code
• 6 McCabe index (conditional complexity)

    public boolean belongsTo(Xid xid) {
        if (!(xid instanceof TransactionId)) {
            return false;
        }

        TransactionId tXid = (TransactionId) xid;

        if (FORMAT_ID != tXid.getFormatId() || !Arrays.equals(jobId, tXid.jobId)) {
            return false;
        }

        if (subtaskId == tXid.subtaskId && numberOfSubtasks == tXid.numberOfSubtasks) {
            return true;
        }

        // Check if was a job downgrade
        return numberOfSubtasks < tXid.subtaskId;
    }