#914 - Moved to datamovement package from example package

Author: vivekmuniyandi

marklogic-client-api/src/main/java/com/marklogic/client/example/cookbook/datamovement/ExtractViaTemplateListener.java renamed to marklogic-client-api/src/main/java/com/marklogic/client/datamovement/ExtractRowsViaTemplateListener.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.marklogic.client.example.cookbook.datamovement;
+package com.marklogic.client.datamovement;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -29,10 +29,6 @@
 import com.fasterxml.jackson.core.JsonParser;
 import com.fasterxml.jackson.core.JsonToken;
 import com.marklogic.client.MarkLogicIOException;
-import com.marklogic.client.datamovement.BatchFailureListener;
-import com.marklogic.client.datamovement.QueryBatchListener;
-import com.marklogic.client.datamovement.QueryBatch;
-import com.marklogic.client.datamovement.QueryBatcher;
 import com.marklogic.client.expression.PlanBuilder;
 import com.marklogic.client.io.JacksonParserHandle;
 import com.marklogic.client.io.StringHandle;
@@ -54,7 +50,7 @@
  * <pre>{@code
  * StructuredQueryDefinition query = new StructuredQueryBuilder().directory(1, "/employees/");
  * QueryBatcher qb = moveMgr.newQueryBatcher(query)
- *     .onUrisReady(new ExtractViaTemplateListener().withTemplate(templateUri).onTypedRowReady(row -&gt; {
+ *     .onUrisReady(new ExtractRowsViaTemplateListener().withTemplate(templateUri).onTypedRowReady(row -&gt; {
  *       System.out.println("row:" + row);
  *     }));
  * moveMgr.startJob(qb);
@@ -85,17 +81,17 @@
  * emitted by the rows. Also, the templates should emit only rows and not
  * triples.
  */
-public class ExtractViaTemplateListener implements QueryBatchListener, AutoCloseable {
+public class ExtractRowsViaTemplateListener implements QueryBatchListener, AutoCloseable {
   private static Logger logger =
-    LoggerFactory.getLogger(ExtractViaTemplateListener.class);
+    LoggerFactory.getLogger(ExtractRowsViaTemplateListener.class);
   private List<String> templateUris = new ArrayList<>();
   private String templateDb;
   private List<Consumer<TypedRow>> rowListeners = new ArrayList<>();
   private List<BatchFailureListener<QueryBatch>> failureListeners = new ArrayList<>();
   private PlanBuilder pb;
 
-  public ExtractViaTemplateListener() {
-    logger.debug("new ExtractViaTemplateListener - this should print once/job; " +
+  public ExtractRowsViaTemplateListener() {
+    logger.debug("new ExtractRowsViaTemplateListener - this should print once/job; " +
       "if you see this once/batch, fix your job configuration");
   }
 
@@ -106,12 +102,12 @@ public ExtractViaTemplateListener() {
    * @param templateUri the uri of the template to be applied to each batch.
    * @return the instance for chaining
    */
-  public ExtractViaTemplateListener withTemplate(String templateUri) {
+  public ExtractRowsViaTemplateListener withTemplate(String templateUri) {
     this.templateUris.add(templateUri);
     return this;
   }
 
-  private ExtractViaTemplateListener withTemplateDatabase(String templateDatabase) {
+  private ExtractRowsViaTemplateListener withTemplateDatabase(String templateDatabase) {
     this.templateDb = templateDatabase;
     return this;
   }
@@ -123,7 +119,7 @@ private ExtractViaTemplateListener withTemplateDatabase(String templateDatabase)
    * @param listener the listener which needs to be applied to each row
    * @return the instance for chaining
    */
-  public ExtractViaTemplateListener onTypedRowReady(Consumer<TypedRow> listener) {
+  public ExtractRowsViaTemplateListener onTypedRowReady(Consumer<TypedRow> listener) {
     rowListeners.add(listener);
     return this;
   }
@@ -136,7 +132,7 @@ public ExtractViaTemplateListener onTypedRowReady(Consumer<TypedRow> listener) {
    *
    * @return this instance for method chaining
    */
-  public ExtractViaTemplateListener onFailure(BatchFailureListener<QueryBatch> listener) {
+  public ExtractRowsViaTemplateListener onFailure(BatchFailureListener<QueryBatch> listener) {
     failureListeners.add(listener);
     return this;
   }
@@ -147,7 +143,7 @@ public void initializeListener(QueryBatcher queryBatcher) {
   }
 
   /**
-   * This is the method QueryBatcher calls for ExtractViaTemplateListener to do
+   * This is the method QueryBatcher calls for ExtractRowsViaTemplateListener to do
    * its thing. You should not need to call it.
    *
    * @param batch the batch of uris and some metadata about the current status

marklogic-client-api/src/main/java/com/marklogic/client/example/cookbook/datamovement/TypedRow.java renamed to marklogic-client-api/src/main/java/com/marklogic/client/datamovement/TypedRow.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.marklogic.client.example.cookbook.datamovement;
+package com.marklogic.client.datamovement;
 
 import java.util.LinkedHashMap;
 import com.marklogic.client.type.XsAnyAtomicTypeVal;

marklogic-client-api/src/main/java/com/marklogic/client/example/cookbook/datamovement/ExtractViaTemplate.java renamed to marklogic-client-api/src/main/java/com/marklogic/client/example/cookbook/datamovement/ExtractRowsViaTemplate.java

@@ -24,6 +24,7 @@
 import com.fasterxml.jackson.core.JsonParser.Feature;
 import com.fasterxml.jackson.databind.ObjectMapper;
 
+import com.marklogic.client.datamovement.ExtractRowsViaTemplateListener;
 import com.marklogic.client.document.JSONDocumentManager;
 import com.marklogic.client.DatabaseClient;
 import com.marklogic.client.datamovement.DataMovementManager;
@@ -43,7 +44,7 @@
  * to a Tableau TDE (Tableau Data Extract) file.
  *
  */
-public class ExtractViaTemplate {
+public class ExtractRowsViaTemplate {
   private static int threadCount = 3;
   private static int batchSize   = 3;
   private String templateUri = "employees.tde";
@@ -57,7 +58,7 @@ public class ExtractViaTemplate {
     new SimpleDateFormat("yyyy-MM-dd");
 
   public static void main(String[] args) throws ParseException, IOException {
-    new ExtractViaTemplate().run();
+    new ExtractRowsViaTemplate().run();
   }
 
   public void run() throws ParseException, IOException {
@@ -67,7 +68,7 @@ public void run() throws ParseException, IOException {
       .onUrisReady(
         // This object will be closed by the QueryBatcher when stopJob is
         // called and hence there won't be a resource leak.
-        new ExtractViaTemplateListener()
+        new ExtractRowsViaTemplateListener()
           .withTemplate(templateUri)
           .onTypedRowReady( row -> {
             System.out.println("row:" + row);
@@ -88,7 +89,7 @@ public void run() throws ParseException, IOException {
      *
      * QueryBatcher qbConsumer = moveMgr.newQueryBatcher(query)
      *  .onUrisReady(
-     *    new ExtractViaTemplateListener()
+     *    new ExtractRowsViaTemplateListener()
      *      .withTemplate(templateName)
      *      .onTypedRowReady(tableauWriter)
      *  );

marklogic-client-api/src/test/java/com/marklogic/client/test/example/cookbook/ExtractViaTemplateTest.java renamed to marklogic-client-api/src/test/java/com/marklogic/client/test/example/cookbook/ExtractRowsViaTemplateTest.java

@@ -17,11 +17,11 @@
 
 import org.junit.Test;
 
-import com.marklogic.client.example.cookbook.datamovement.ExtractViaTemplate;
+import com.marklogic.client.example.cookbook.datamovement.ExtractRowsViaTemplate;
 
-public class ExtractViaTemplateTest {
+public class ExtractRowsViaTemplateTest {
   @Test
   public void testMain() throws Exception {
-    ExtractViaTemplate.main(new String[0]);
+    ExtractRowsViaTemplate.main(new String[0]);
   }
 }