[
https://issues.apache.org/jira/browse/STORM-851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14695440#comment-14695440
]
ASF GitHub Bot commented on STORM-851:
--------------------------------------
Github user harshach commented on a diff in the pull request:
https://github.com/apache/storm/pull/665#discussion_r36992356
--- Diff:
external/storm-solr/src/main/java/org/apache/storm/solr/mapper/SolrJsonMapper.java
---
@@ -0,0 +1,97 @@
+package org.apache.storm.solr.mapper;
+
+import backtype.storm.tuple.ITuple;
+import com.google.gson.Gson;
+import org.apache.solr.client.solrj.SolrClient;
+import org.apache.solr.client.solrj.SolrRequest;
+import org.apache.solr.client.solrj.impl.CloudSolrClient;
+import org.apache.solr.client.solrj.request.ContentStreamUpdateRequest;
+import org.apache.solr.common.util.ContentStream;
+import org.apache.solr.common.util.ContentStreamBase;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+
+/**
+ * Created by hlouro on 7/24/15.
+ */
+public class SolrJsonMapper implements SolrMapper {
+ private static final Logger logger =
LoggerFactory.getLogger(SolrJsonMapper.class);
+ private static final String JSON_UPDATE_URL = "/update/json/docs";
--- End diff --
should we expose this as configurable option?
> Storm Solr connector
> --------------------
>
> Key: STORM-851
> URL: https://issues.apache.org/jira/browse/STORM-851
> Project: Apache Storm
> Issue Type: Improvement
> Reporter: Sriharsha Chintalapani
> Assignee: Hugo Louro
>
> Storm solr connector should provide bolt and trident implementation to allow
> users to index data coming through the topology into solr.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
