Examples of com.google.enterprise.connector.spi.DocumentList.checkpoint()

com.google.enterprise.connector.spi.DocumentList.checkpoint()

Provides a checkpoint that can be used to control traversal. The implementor should provide a string that can be used by the framework to resume traversal starting just after this document. The framework will typically call this method on the last document it has chosen to process (for whatever reason: scheduling, completion of all documents currently available, etc.) It will persist this string, so that it can be recovered after a crash if necessary. When it chooses to restart traversal, it will supply this string in a call to {@link TraversalManager#resumeTraversal(String)}.

If {@code null} is returned, then no new checkpoint will be saved,and the existing checkpoint will be supplied to {@link TraversalManager#startTraversal()} or{@link TraversalManager#resumeTraversal(String)}, in effect, restarting the traversal from the last saved checkpoint. @return a non-{@code null} {@code String} that can be suppliedsubsequently to {@link TraversalManager#resumeTraversal(String)} @throws RepositoryException if a repository access error occurs or ifthere is insufficient information to create a checkpoint string. If {@code checkpoint()} throws an exception, a subsequentcall to {@link TraversalManager#resumeTraversal(String)} will besupplied the last known good checkpoint string.

    trav.setBatchHint(halfSize);
    DocumentList docList = trav.startTraversal();
    testUserProfiles(docList, names);
    assertEquals(EXPECTED_NAMES.subList(0, halfSize), names);


    String checkpoint = docList.checkpoint();
    JSONObject jo = new 
        JSONObject(checkpoint.substring(CHECKPOINT_PREFIX.length()));
    assertTrue(jo.has("userProfileChangeToken"));
    assertTrue(jo.has("userProfileLastFullSync"));
    assertTrue(jo.has("userProfileNextIndex"));

    // which includes 66 with its original ModifyDate, since that was
    // in the candidates.
    // TODO(jlacey): We could query these values as the max(ModifyDate)
    // from DTree when it matches WebNodes, and from DAuditNew.
    assertEquals("2002-02-02 00:00:00,66,2013-04-24 08:00:00.000,10042",
        list.checkpoint());
  }


  public void testStartTraversalWithDTreeAncestors()
      throws SQLException, RepositoryException {
    testStartTraversal(true);

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.