private int checkIndexObjects() throws ConnectionException {
  CheckType checkType=CheckType.INDEX_OBJECTS;
  helper.logMessage("\nStart to check INDEX data that the related object records are missing.\n",false,toConsole);
  DbConsistencyStatus status=getStatusFromZk();
  Collection<IndexAndCf> resumeIdxCfs=resumeFromWorkingPoint(checkType,status.getWorkingPoint());
  int totalCorruptCount=0;
  for (  IndexAndCf indexAndCf : resumeIdxCfs) {
    int corruptCount=helper.checkIndexingCF(indexAndCf,toConsole);
    status=getStatusFromZk();
    if (!toConsole && isCancelled(status)) {
      cancel(status);
    }
    if (!toConsole) {
      status.update(this.totalCount,checkType.name(),indexAndCf.generateKey(),corruptCount);
      persistStatus(status);
    }
    totalCorruptCount+=corruptCount;
  }
  DbCheckerFileWriter.close();
  String msg=String.format("\nFinish to check INDEX records: totally checked %d indices " + "and %d corrupted rows found.\n",resumeIdxCfs.size(),totalCorruptCount);
  helper.logMessage(msg,false,toConsole);
  return totalCorruptCount;
}

private int checkIndexObjects ( ) throws ConnectionException { CheckType checkType = CheckType . INDEX_OBJECTS ; helper . logMessage ( "\nStart to check INDEX data that the related object records are missing.\n" , false , toConsole ) ; DbConsistencyStatus status = getStatusFromZk ( ) ; Collection < IndexAndCf > resumeIdxCfs = resumeFromWorkingPoint ( checkType , status . getWorkingPoint ( ) ) ; int totalCorruptCount = 0 ; for ( IndexAndCf indexAndCf : resumeIdxCfs ) { int corruptCount = helper . checkIndexingCF ( indexAndCf , toConsole ) ; status = getStatusFromZk ( ) ; if ( ! toConsole && isCancelled ( status ) ) { cancel ( status ) ; } if ( ! toConsole ) { status . update ( this . totalCount , checkType . name ( ) , indexAndCf . generateKey ( ) , corruptCount ) ; persistStatus ( status ) ; } totalCorruptCount += corruptCount ; } DbCheckerFileWriter . close ( ) ; String msg = String . format ( "\nFinish to check INDEX records: totally checked %d indices " + "and %d corrupted rows found.\n" , resumeIdxCfs . size ( ) , totalCorruptCount ) ; helper . logMessage ( msg , false , toConsole ) ; return totalCorruptCount ; }
scan all the indices and related data object records , to find out the index record is existing but the related data object records is missing .
