public boolean equals()

in src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java [106:116]

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

    public boolean equals(Object obj) {
        if (!(obj instanceof RocketMQSourceSplit)) {
            return false;
        }
        RocketMQSourceSplit other = (RocketMQSourceSplit) obj;
        return topic.equals(other.topic)
                && brokerName.equals(other.brokerName)
                && queueId == other.queueId
                && startingOffset == other.startingOffset
                && stoppingOffset == other.stoppingOffset;
    }