fix arrow -> operators that weren't rendering properly in javadocs

Author: sammefford

src/main/java/com/marklogic/client/datamovement/BatchListener.java

@@ -31,14 +31,14 @@ public interface BatchListener<T extends Batch<?>> {
    *     QueryBatcher qhb = dataMovementManager.newQueryBatcher(query)
    *         .withBatchSize(1000)
    *         .withThreadCount(20)
-   *         .onUrisReady(batch -&gt; {
+   *         .onUrisReady(batch -> {
    *             for ( String uri : batch.getItems() ) {
    *                 if ( uri.endsWith(".txt") ) {
    *                     batch.getClient().newDocumentManager().delete(uri);
    *                 }
    *             }
    *         })
-   *         .onQueryFailure(queryBatchException -&gt; queryBatchException.printStackTrace());
+   *         .onQueryFailure(queryBatchException -> queryBatchException.printStackTrace());
    *     JobTicket ticket = dataMovementManager.startJob(qhb);
    *     qhb.awaitCompletion();
    *     dataMovementManager.stopJob(ticket);

src/main/java/com/marklogic/client/datamovement/ExportListener.java

@@ -44,11 +44,11 @@
  *         .onUrisReady(
  *           new ExportListener()
  *               .withConsistentSnapshot()
- *               .onDocumentReady(doc -> {
+ *               .onDocumentReady(doc -> {
  *                 logger.debug("Contents=[{}]", doc.getContentAs(String.class));
  *               })
  *         )
- *         .onQueryFailure(exception -> exception.printStackTrace());
+ *         .onQueryFailure(exception -> exception.printStackTrace());
  *
  *     JobTicket ticket = moveMgr.startJob(exportBatcher);
  *     exportBatcher.awaitCompletion();

src/main/java/com/marklogic/client/datamovement/QueryBatchListener.java

@@ -31,14 +31,14 @@ public interface QueryBatchListener extends BatchListener<QueryBatch> {
    *     QueryBatcher qhb = dataMovementManager.newQueryBatcher(query)
    *         .withBatchSize(1000)
    *         .withThreadCount(20)
-   *         .onUrisReady(batch -&gt; {
+   *         .onUrisReady(batch -> {
    *             for ( String uri : batch.getItems() ) {
    *                 if ( uri.endsWith(".txt") ) {
    *                     batch.getClient().newDocumentManager().delete(uri);
    *                 }
    *             }
    *         })
-   *         .onQueryFailure(queryBatchException -&gt; queryBatchException.printStackTrace());
+   *         .onQueryFailure(queryBatchException -> queryBatchException.printStackTrace());
    *     JobTicket ticket = dataMovementManager.startJob(qhb);
    *     qhb.awaitCompletion();
    *     dataMovementManager.stopJob(ticket);

src/main/java/com/marklogic/client/datamovement/QueryBatcher.java

@@ -42,7 +42,7 @@
  *     QueryBatcher qhb = dataMovementManager.newQueryBatcher(query)
  *         .withConsistentSnapshot()
  *         .onUrisReady( new DeleteListener() )
- *         .onQueryFailure(exception -> exception.printStackTrace());
+ *         .onQueryFailure(exception -> exception.printStackTrace());
  *     JobTicket ticket = dataMovementManager.startJob(qhb);
  *     qhb.awaitCompletion();
  *     dataMovementManager.stopJob(ticket);
@@ -78,14 +78,14 @@
  *         .withBatchSize(1000)
  *         .withThreadCount(20)
  *         .withConsistentSnapshot()
- *         .onUrisReady(batch -> {
+ *         .onUrisReady(batch -> {
  *             for ( String uri : batch.getItems() ) {
  *                 if ( uri.endsWith(".txt") ) {
  *                     client.newDocumentManager().delete(uri);
  *                 }
  *             }
  *         })
- *         .onQueryFailure(exception -> exception.printStackTrace());
+ *         .onQueryFailure(exception -> exception.printStackTrace());
  *     JobTicket ticket = dataMovementManager.startJob(qhb);
  *     qhb.awaitCompletion();
  *     dataMovementManager.stopJob(ticket);
@@ -95,16 +95,16 @@
  *     ArrayList<String> uris = new ArrayList<>();
  *     QueryBatcher getUris = dataMovementManager.newQueryBatcher(query)
  *       .withBatchSize(5000)
- *       .onUrisReady( batch -> uris.addAll(Arrays.asList(batch.getItems())) )
- *       .onQueryFailure(exception -> exception.printStackTrace());
+ *       .onUrisReady( batch -> uris.addAll(Arrays.asList(batch.getItems())) )
+ *       .onQueryFailure(exception -> exception.printStackTrace());
  *     JobTicket getUrisTicket = dataMovementManager.startJob(getUris);
  *     getUris.awaitCompletion();
  *     dataMovementManager.stopJob(getUrisTicket);
  *
  *     // now we have the uris, let's step through them
  *     QueryBatcher performDelete = moveMgr.newQueryBatcher(uris.iterator())
  *       .onUrisReady(new DeleteListener())
- *       .onQueryFailure(exception -> exception.printStackTrace());
+ *       .onQueryFailure(exception -> exception.printStackTrace());
  *     JobTicket ticket = dataMovementManager.startJob(performDelete);
  *     performDelete.awaitCompletion();
  *     dataMovementManager.stopJob(ticket);

src/main/java/com/marklogic/client/datamovement/UrisToWriterListener.java

@@ -30,7 +30,7 @@
  *     QueryBatcher getUris = dataMovementManager.newQueryBatcher(query)
  *       .withBatchSize(5000)
  *       .onUrisReady( new UrisToWriterListener(writer) )
- *       .onQueryFailure(exception -> exception.printStackTrace());
+ *       .onQueryFailure(exception -> exception.printStackTrace());
  *     JobTicket getUrisTicket = dataMovementManager.startJob(getUris);
  *     getUris.awaitCompletion();
  *     dataMovementManager.stopJob(getUrisTicket);
@@ -41,7 +41,7 @@
  *     BufferedReader reader = new BufferedReader(new FileReader("uriCache.txt"));
  *     QueryBatcher performDelete = dataMovementManager.newQueryBatcher(reader.lines().iterator())
  *       .onUrisReady(new DeleteListener())
- *       .onQueryFailure(exception -> exception.printStackTrace());
+ *       .onQueryFailure(exception -> exception.printStackTrace());
  *     JobTicket ticket = dataMovementManager.startJob(performDelete);
  *     performDelete.awaitCompletion();
  *     dataMovementManager.stopJob(ticket);

src/main/java/com/marklogic/client/datamovement/WriteBatchListener.java

@@ -31,14 +31,14 @@ public interface WriteBatchListener extends BatchListener<WriteBatch> {
    *     WriteBatcher wb = dataMovementManager.newWriteBatcher(query)
    *         .withBatchSize(1000)
    *         .withThreadCount(20)
-   *         .onBatchSuccess(batch -&gt; {
+   *         .onBatchSuccess(batch -> {
    *             for ( WriteEvent doc : batch.getItems() ) {
    *                 if ( doc.getTargetUri().contains("/legal/") ) {
    *                     // do something
    *                 }
    *             }
    *         })
-   *         .onBatchFailure(throwable -&gt; throwable.printStackTrace());
+   *         .onBatchFailure(throwable -> throwable.printStackTrace());
    *
    * @param batch the batch of documents written and some metadata about the current status of the job
    */

src/main/java/com/marklogic/client/datamovement/WriteBatcher.java

@@ -40,10 +40,10 @@
  *     WriteBatcher whb = dataMovementManager.newWriteBatcher()
  *         .withBatchSize(100)
  *         .withThreadCount(20)
- *         .onBatchSuccess(batch -> {
+ *         .onBatchSuccess(batch -> {
  *             logger.debug("batch # {}, so far: {}", batch.getJobBatchNumber(), batch.getJobResultsSoFar());
  *         })
- *         .onBatchFailure((batch,throwable) -> throwable.printStackTrace() );
+ *         .onBatchFailure((batch,throwable) -> throwable.printStackTrace() );
  *     JobTicket ticket = dataMovementManager.startJob(whb);
  *     whb.add  ("doc1.txt", new StringHandle("doc1 contents"));
  *     whb.addAs("doc2.txt", "doc2 contents");

src/main/java/com/marklogic/client/datamovement/package-info.java

@@ -218,6 +218,9 @@
  * WriteBatcher.  Please make sure to enable your slf4j-compliant [logging
  * framework](../../../../overview-summary.html#logging).
  *
+ * <br/><br/><br/><br/><br/><br/><br/><br/><br/><br/><br/><br/><br/><br/>
+ * <br/><br/><br/><br/><br/><br/><br/><br/><br/><br/><br/><br/><br/><br/>
+ * <br/><br/><br/><br/><br/><br/><br/><br/><br/><br/><br/><br/><br/><br/>
  */
 /*
  * Copyright 2015-2016 MarkLogic Corporation