qingbo li created NIFI-6165:
-------------------------------
Summary: PutSolrRecord Improvement
Key: NIFI-6165
URL: https://issues.apache.org/jira/browse/NIFI-6165
Project: Apache NiFi
Issue Type: Improvement
Environment: nifi1.9
Reporter: qingbo li
{code:java}
while ((record = reader.nextRecord()) != null) {
SolrInputDocument inputDoc = new SolrInputDocument();
writeRecord(record, inputDoc,fieldList,EMPTY_STRING);
inputDocumentList.add(inputDoc);
if(inputDocumentList.size()==batchSize) {
index(isSolrCloud, collection, commitWithin, contentStreamPath, requestParams,
inputDocumentList);
inputDocumentList = new ArrayList<>();
}
index(isSolrCloud, collection, commitWithin, contentStreamPath, requestParams,
inputDocumentList);
}
{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)