public boolean equals()

in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java [213:238]

• 26 lines of code
• 18 McCabe index (conditional complexity)

    public boolean equals(Object o) {
        if (this == o) {
            return true;
        }
        if (o == null || getClass() != o.getClass()) {
            return false;
        }
        if (!super.equals(o)) {
            return false;
        }
        SourceConfiguration that = (SourceConfiguration) o;
        return messageQueueCapacity == that.messageQueueCapacity
                && partitionDiscoveryIntervalMs == that.partitionDiscoveryIntervalMs
                && enableAutoAcknowledgeMessage == that.enableAutoAcknowledgeMessage
                && autoCommitCursorInterval == that.autoCommitCursorInterval
                && fetchOneMessageTime == that.fetchOneMessageTime
                && Objects.equals(maxFetchTime, that.maxFetchTime)
                && maxFetchRecords == that.maxFetchRecords
                && verifyInitialOffsets == that.verifyInitialOffsets
                && Objects.equals(subscriptionName, that.subscriptionName)
                && subscriptionMode == that.subscriptionMode
                && allowKeySharedOutOfOrderDelivery == that.allowKeySharedOutOfOrderDelivery
                && enableSchemaEvolution == that.enableSchemaEvolution
                && enableMetrics == that.enableMetrics
                && resetSubscriptionCursor == that.resetSubscriptionCursor;
    }