D-Net

import eu.dnetlib.functionality.index.model.Any.ValueType;

import eu.dnetlib.functionality.index.model.document.IndexDocument;

import eu.dnetlib.functionality.index.model.document.Status;

import eu.dnetlib.functionality.index.utils.MetadataReference;

import org.springframework.beans.factory.annotation.Required;

                                                            final String dsId,

                                                            final String version) {

            }

        };

    }

    public Function<String, IndexDocument> getRecordMapper(final Map<String, ValueType> schema, final MetadataReference mdRef, final String dsId, final String version, final boolean emptyResult) {

        if (emptyResult == false) return getRecordMapper(schema, dsId, version);

        else {

                }

            };

        }

    }

	/**

	 * Builds a groupResult.

	 *

	 * @param count

	 */

	public GroupResult(final String name, final String value, final int count) {

	}

	/**

	 *            input document

	 * @return the application of the schemaXslt transformation to the docIn document

	 * @throws IndexServiceException

	 *         document

	 * @throws IndexServiceException

	 */

		final StringTemplate conf = new StringTemplate(getSolrConfig()

				.getTemplate());

		for (Entry<String, String> e : filter(params).entrySet()) {

package eu.dnetlib.functionality.index.utils;

import com.google.common.collect.Maps;

import com.google.gson.JsonElement;

import com.google.gson.JsonObject;

import org.apache.solr.client.solrj.response.LukeResponse.FieldInfo;

import org.apache.solr.client.solrj.response.SolrPingResponse;

import org.apache.solr.common.cloud.SolrZkClient;

import org.apache.zookeeper.Watcher;

import org.apache.zookeeper.data.Stat;

import org.springframework.beans.factory.annotation.Required;

public class RemoteSolrAdministrator {

	/**

	public boolean indexCollectionExists(final String indexCollectionId, final CloudSolrClient client) {

		try {

			// server.connect();

			SolrZkClient zkClient = client.getZkStateReader().getZkClient();

			if (!zkClient.isConnected()) {

				client.connect();

			}

package eu.dnetlib.functionality.index;

import eu.dnetlib.functionality.cql.CqlValueTransformerMap;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.apache.solr.client.solrj.impl.CloudSolrClient;

import org.dom4j.Document;

import org.dom4j.DocumentException;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Required;

/**

 * The Class SolrIndexServerDAO.

 */

	 */

	@Override

	public void createIndexCollection(final MetadataReference mdref, final String fields) throws IndexServiceException {

			client.connect();

			if (!solrAdministrator.indexCollectionExists(mdref.toString(), client)) {

		} catch (Exception e) {

			log.error("Error on creating IndexCollection", e);

			throw new IndexServiceException("Error on creating IndexCollection", e);

		}

	}

	@Override

	public void updateIndexCollection(final MetadataReference mdRef, final Document fields) throws IndexServiceException {

			client.connect();

			Map<String, String> params = Maps.newHashMap();

			zkUtils.uploadZookeperConfig(client.getZkStateReader().getZkClient(), mdRef.toString(), fields, params, true);

			client.getZkStateReader().close();

			solrAdministrator.reloadCollection(getServiceProperties().get("host"), getServiceProperties().get("port"), mdRef.toString());

		} catch (Exception e) {

			log.error("Error on updating IndexCollection", e);

			throw new IndexServiceException("Error on updating IndexCollection", e);

		}

	}

	 */

	@Override

	public IndexCollection getIndexCollection(final MetadataReference mdref) throws IndexServiceException {

		return new SolrIndexCollection(client);

	}

		} catch (IOException e) {

			throw new IndexServiceException(e);

		}

	}

	/**

	 *             the index service exception

	 */

	private CloudSolrClient getClient(final MetadataReference mdRef) throws IndexServiceException {

	}

	/**

	 * @return a server instance

	 */

	private CloudSolrClient getClient() {

		log.info("connecting to address: " + address);

	}

	/**

package eu.dnetlib.functionality.index;

import org.apache.commons.lang3.StringUtils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.apache.solr.client.solrj.response.UpdateResponse;

import org.apache.solr.common.SolrInputDocument;

/**

 * The Class SolrIndexCollection.

 */

	/** The Constant STATUS_INDEX_OK. */

	public static final int STATUS_INDEX_OK = 0;

	private CloudSolrClient client;

	private boolean shutdown = false;

	/**

	 * The Constructor.

	 *

	 *            the client

	 */

		client.connect();

	}

	@Override

	public boolean add(final IndexDocument doc) throws IndexServiceException {

		if (isShutdown()) throw new IndexServiceException("Please get another SolrIndexCollection: this has been shut down");

		final SolrIndexDocument solrDocument = (SolrIndexDocument) doc;

		try {

			final UpdateResponse response = client.add(solrDocument.getSolrDocument());

					<!-- Case insensitive stop word removal.

					-->

					<filter class="solr.StopFilterFactory"

					/>

					<filter class="solr.LowerCaseFilterFactory"/>

					<filter class="solr.EnglishPossessiveFilterFactory"/>

					<tokenizer class="solr.StandardTokenizerFactory"/>

					<filter class="solr.SynonymGraphFilterFactory" synonyms="synonyms.txt" ignoreCase="true" expand="true"/>

					<filter class="solr.StopFilterFactory"

					/>

					<filter class="solr.LowerCaseFilterFactory"/>

					<filter class="solr.EnglishPossessiveFilterFactory"/>

					<!-- Case insensitive stop word removal.

					-->

					<filter class="solr.StopFilterFactory"

					/>

					<filter class="solr.WordDelimiterGraphFilterFactory" generateWordParts="1" generateNumberParts="1" catenateWords="1" catenateNumbers="1" catenateAll="0" splitOnCaseChange="1"/>

					<filter class="solr.LowerCaseFilterFactory"/>

					<tokenizer class="solr.WhitespaceTokenizerFactory"/>

					<filter class="solr.SynonymGraphFilterFactory" synonyms="synonyms.txt" ignoreCase="true" expand="true"/>

					<filter class="solr.StopFilterFactory"

					/>

					<filter class="solr.WordDelimiterGraphFilterFactory" generateWordParts="1" generateNumberParts="1" catenateWords="0" catenateNumbers="0" catenateAll="0" splitOnCaseChange="1"/>

					<filter class="solr.LowerCaseFilterFactory"/>

					<filter class="solr.StopFilterFactory" ignoreCase="true" words="stopwords.txt" />

					<filter class="solr.LowerCaseFilterFactory"/>

					<filter class="solr.ReversedWildcardFilterFactory" withOriginal="true"

				</analyzer>

				<analyzer type="query">

					<tokenizer class="solr.StandardTokenizerFactory"/>

			  http://wiki.apache.org/solr/SolrAdaptersForLuceneSpatial4

			-->

			<fieldType name="location_rpt" class="solr.SpatialRecursivePrefixTreeFieldType"

		</schema>

	</xsl:template>

		EditorialMarkerFactory will do exactly that:

	   <transformer name="qecBooster" class="org.apache.solr.response.transform.EditorialMarkerFactory" />

	  -->

	<parent>

		<groupId>eu.dnetlib</groupId>

		<artifactId>dnet45-parent</artifactId>

		<relativePath />

	</parent>

	<modelVersion>4.0.0</modelVersion>

	<groupId>eu.dnetlib</groupId>

	<artifactId>dnet-index-solr-service</artifactId>

	<scm>

		<developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet45/modules/dnet-index-solr-service/trunk</developerConnection>

	</scm>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>dnet-modular-index-service</artifactId>

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

		</dependency>

	</dependencies>

</project>