public boolean equals()

in hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamer.java [492:535]

• 44 lines of code
• 38 McCabe index (conditional complexity)

    public boolean equals(Object o) {
      if (this == o) {
        return true;
      }
      if (o == null || getClass() != o.getClass()) {
        return false;
      }
      Config config = (Config) o;
      return sourceLimit == config.sourceLimit
          && Objects.equals(targetBasePath, config.targetBasePath)
          && Objects.equals(targetTableName, config.targetTableName)
          && Objects.equals(tableType, config.tableType)
          && Objects.equals(baseFileFormat, config.baseFileFormat)
          && Objects.equals(propsFilePath, config.propsFilePath)
          && Objects.equals(configs, config.configs)
          && Objects.equals(sourceClassName, config.sourceClassName)
          && Objects.equals(sourceOrderingField, config.sourceOrderingField)
          && Objects.equals(payloadClassName, config.payloadClassName)
          && Objects.equals(schemaProviderClassName, config.schemaProviderClassName)
          && Objects.equals(transformerClassNames, config.transformerClassNames)
          && operation == config.operation
          && Objects.equals(filterDupes, config.filterDupes)
          && Objects.equals(enableHiveSync, config.enableHiveSync)
          && Objects.equals(enableMetaSync, config.enableMetaSync)
          && Objects.equals(forceEmptyMetaSync, config.forceEmptyMetaSync)
          && Objects.equals(syncClientToolClassNames, config.syncClientToolClassNames)
          && Objects.equals(maxPendingCompactions, config.maxPendingCompactions)
          && Objects.equals(maxPendingClustering, config.maxPendingClustering)
          && Objects.equals(continuousMode, config.continuousMode)
          && Objects.equals(minSyncIntervalSeconds, config.minSyncIntervalSeconds)
          && Objects.equals(sparkMaster, config.sparkMaster)
          && Objects.equals(commitOnErrors, config.commitOnErrors)
          && Objects.equals(deltaSyncSchedulingWeight, config.deltaSyncSchedulingWeight)
          && Objects.equals(compactSchedulingWeight, config.compactSchedulingWeight)
          && Objects.equals(clusterSchedulingWeight, config.clusterSchedulingWeight)
          && Objects.equals(deltaSyncSchedulingMinShare, config.deltaSyncSchedulingMinShare)
          && Objects.equals(compactSchedulingMinShare, config.compactSchedulingMinShare)
          && Objects.equals(clusterSchedulingMinShare, config.clusterSchedulingMinShare)
          && Objects.equals(forceDisableCompaction, config.forceDisableCompaction)
          && Objects.equals(checkpoint, config.checkpoint)
          && Objects.equals(initialCheckpointProvider, config.initialCheckpointProvider)
          && Objects.equals(ingestionMetricsClass, config.ingestionMetricsClass)
          && Objects.equals(help, config.help);
    }