public void recordMismatch()

in spark-job/src/main/java/org/apache/cassandra/diff/JobMetadataDb.java [229:236]

• 8 lines of code
• 3 McCabe index (conditional complexity)

        public void recordMismatch(KeyspaceTablePair table, MismatchType type, BigInteger token) {
            logger.info("Detected mismatch in table {}; partition with token {} is {}",
                        table, token, type == MismatchType.PARTITION_MISMATCH
                                      ? " different in source and target clusters"
                                      : type == MismatchType.ONLY_IN_SOURCE ? "only present in source cluster"
                                                                            : "only present in target cluster");
            ignoreQueryException(() -> session.execute(bindMismatchesStatement(table, token, type.name())));
        }