@Test public void test_UpdateDocuments_NullList() throws IOException, SolrServerException { solrWriter.updateDocuments(null, testBatchId); }
public void updateDocuments(List<CRFSolrDocument> newDocs, final String publishingBatchId) throws IOException, SolrServerException { LOG.warn(LoggingComponent.appendAppFields(LoggingComponent.Migrator.PERSISTENCE_SOLR, publishingBatchId), "Preparing to split SOLR update of {} docs in chunks of {}",newDocs.size(),solrBatchSize); for (int docsStartChunkIndex = 0; docsStartChunkIndex <= newDocs.size(); docsStartChunkIndex += solrBatchSize) { final int endOfArray = Math.min(newDocs.size(), docsStartChunkIndex + solrBatchSize); final List<CRFSolrDocument> newDocsChunk = newDocs.subList(docsStartChunkIndex, endOfArray); LOG.warn(LoggingComponent.appendAppFields(LoggingComponent.Migrator.PERSISTENCE_SOLR, publishingBatchId), "Chunk SOLR update of size {}",newDocsChunk.size()); updateDocumentsChunk(newDocsChunk, publishingBatchId); } }
SOLRWriter { public void updateDocuments(List<CRFSolrDocument> newDocs, final String publishingBatchId) throws IOException, SolrServerException { LOG.warn(LoggingComponent.appendAppFields(LoggingComponent.Migrator.PERSISTENCE_SOLR, publishingBatchId), "Preparing to split SOLR update of {} docs in chunks of {}",newDocs.size(),solrBatchSize); for (int docsStartChunkIndex = 0; docsStartChunkIndex <= newDocs.size(); docsStartChunkIndex += solrBatchSize) { final int endOfArray = Math.min(newDocs.size(), docsStartChunkIndex + solrBatchSize); final List<CRFSolrDocument> newDocsChunk = newDocs.subList(docsStartChunkIndex, endOfArray); LOG.warn(LoggingComponent.appendAppFields(LoggingComponent.Migrator.PERSISTENCE_SOLR, publishingBatchId), "Chunk SOLR update of size {}",newDocsChunk.size()); updateDocumentsChunk(newDocsChunk, publishingBatchId); } } }
SOLRWriter { public void updateDocuments(List<CRFSolrDocument> newDocs, final String publishingBatchId) throws IOException, SolrServerException { LOG.warn(LoggingComponent.appendAppFields(LoggingComponent.Migrator.PERSISTENCE_SOLR, publishingBatchId), "Preparing to split SOLR update of {} docs in chunks of {}",newDocs.size(),solrBatchSize); for (int docsStartChunkIndex = 0; docsStartChunkIndex <= newDocs.size(); docsStartChunkIndex += solrBatchSize) { final int endOfArray = Math.min(newDocs.size(), docsStartChunkIndex + solrBatchSize); final List<CRFSolrDocument> newDocsChunk = newDocs.subList(docsStartChunkIndex, endOfArray); LOG.warn(LoggingComponent.appendAppFields(LoggingComponent.Migrator.PERSISTENCE_SOLR, publishingBatchId), "Chunk SOLR update of size {}",newDocsChunk.size()); updateDocumentsChunk(newDocsChunk, publishingBatchId); } } SOLRWriter(final DBTargetConfig solrConfig); }
SOLRWriter { public void updateDocuments(List<CRFSolrDocument> newDocs, final String publishingBatchId) throws IOException, SolrServerException { LOG.warn(LoggingComponent.appendAppFields(LoggingComponent.Migrator.PERSISTENCE_SOLR, publishingBatchId), "Preparing to split SOLR update of {} docs in chunks of {}",newDocs.size(),solrBatchSize); for (int docsStartChunkIndex = 0; docsStartChunkIndex <= newDocs.size(); docsStartChunkIndex += solrBatchSize) { final int endOfArray = Math.min(newDocs.size(), docsStartChunkIndex + solrBatchSize); final List<CRFSolrDocument> newDocsChunk = newDocs.subList(docsStartChunkIndex, endOfArray); LOG.warn(LoggingComponent.appendAppFields(LoggingComponent.Migrator.PERSISTENCE_SOLR, publishingBatchId), "Chunk SOLR update of size {}",newDocsChunk.size()); updateDocumentsChunk(newDocsChunk, publishingBatchId); } } SOLRWriter(final DBTargetConfig solrConfig); String getSolrUrl(); void updateDocuments(List<CRFSolrDocument> newDocs, final String publishingBatchId); List<HarvesterRecord> filterDocumentIds(final List<HarvesterRecord> documents, final String publishingBatchId); String getConnectionId(); }
SOLRWriter { public void updateDocuments(List<CRFSolrDocument> newDocs, final String publishingBatchId) throws IOException, SolrServerException { LOG.warn(LoggingComponent.appendAppFields(LoggingComponent.Migrator.PERSISTENCE_SOLR, publishingBatchId), "Preparing to split SOLR update of {} docs in chunks of {}",newDocs.size(),solrBatchSize); for (int docsStartChunkIndex = 0; docsStartChunkIndex <= newDocs.size(); docsStartChunkIndex += solrBatchSize) { final int endOfArray = Math.min(newDocs.size(), docsStartChunkIndex + solrBatchSize); final List<CRFSolrDocument> newDocsChunk = newDocs.subList(docsStartChunkIndex, endOfArray); LOG.warn(LoggingComponent.appendAppFields(LoggingComponent.Migrator.PERSISTENCE_SOLR, publishingBatchId), "Chunk SOLR update of size {}",newDocsChunk.size()); updateDocumentsChunk(newDocsChunk, publishingBatchId); } } SOLRWriter(final DBTargetConfig solrConfig); String getSolrUrl(); void updateDocuments(List<CRFSolrDocument> newDocs, final String publishingBatchId); List<HarvesterRecord> filterDocumentIds(final List<HarvesterRecord> documents, final String publishingBatchId); String getConnectionId();  }