You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@nifi.apache.org by "qingbo li (JIRA)" <ji...@apache.org> on 2019/03/30 07:54:00 UTC

[jira] [Created] (NIFI-6165) PutSolrRecord Improvement

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)