Skip to content

Commit 5d379d8

Browse files
llingllinggit
authored andcommitted
JavaDoc change for JobReport as now it's count uris processed not queried. Another change if example of QueryBatchListener. Promoting using of docToUriRatio in withBatchSize method instead of using withTreadCount method.
1 parent 25cf341 commit 5d379d8

File tree

2 files changed

+5
-6
lines changed

2 files changed

+5
-6
lines changed

marklogic-client-api/src/main/java/com/marklogic/client/datamovement/JobReport.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,25 +25,25 @@
2525
public interface JobReport {
2626
/**
2727
* {@link WriteBatcher} : gets the number of documents written to the database<br>
28-
* {@link QueryBatcher} : gets the number of uris read from the database
28+
* {@link QueryBatcher} : gets the number of uris processed from the database
2929
* @return the number of events that succeeded
3030
*/
3131
long getSuccessEventsCount();
3232
/**
3333
* {@link WriteBatcher} : gets the number of documents that were sent but failed to write<br>
34-
* {@link QueryBatcher} : gets the number of query attempts that failed (same as getFailureBatchesCount)
34+
* {@link QueryBatcher} : gets the number of batches that failed to process (same as getFailureBatchesCount)
3535
* @return the number of events that failed
3636
*/
3737
long getFailureEventsCount();
3838
/**
3939
* {@link WriteBatcher} : gets the number of batches written to the database<br>
40-
* {@link QueryBatcher} : gets the number of batches of URIs read from the database
40+
* {@link QueryBatcher} : gets the number of batches processed from the database
4141
* @return the number of batches that succeeded
4242
*/
4343
long getSuccessBatchesCount();
4444
/**
4545
* {@link WriteBatcher} : gets the number of batches that the job failed to write<br>
46-
* {@link QueryBatcher} : gets the number of query attempts that failed (same as getFailureEventsCount)
46+
* {@link QueryBatcher} : gets the number of batches that failed to process (same as getFailureEventsCount)
4747
* @return the number of batches that failed
4848
*/
4949
long getFailureBatchesCount();

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,8 +30,7 @@ public interface QueryBatchListener extends BatchListener<QueryBatch> {
3030
*
3131
* <pre>{@code
3232
* QueryBatcher qhb = dataMovementManager.newQueryBatcher(query)
33-
* .withBatchSize(1000)
34-
* .withThreadCount(20)
33+
* .withBatchSize(1000, 20)
3534
* .onUrisReady(batch -> {
3635
* for ( String uri : batch.getItems() ) {
3736
* if ( uri.endsWith(".txt") ) {

0 commit comments

Comments
 (0)