public void write()

in pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr/SolrAbstractSink.java [69:95]

• 25 lines of code
• 5 McCabe index (conditional complexity)

    public void write(Record<T> record) {
        UpdateRequest updateRequest = new UpdateRequest();
        if (solrSinkConfig.getSolrCommitWithinMs() > 0) {
            updateRequest.setCommitWithin(solrSinkConfig.getSolrCommitWithinMs());
        }
        if (enableBasicAuth) {
            updateRequest.setBasicAuthCredentials(
                solrSinkConfig.getUsername(),
                solrSinkConfig.getPassword()
            );
        }

        SolrInputDocument document = convert(record);
        updateRequest.add(document);

        try {
            UpdateResponse updateResponse = updateRequest.process(client, solrSinkConfig.getSolrCollection());
            if (updateResponse.getStatus() == 0) {
                record.ack();
            } else {
                record.fail();
            }
        } catch (SolrServerException | IOException e) {
            record.fail();
            log.warn("Solr update document exception ", e);
        }
    }