From e918ec199ef5a7ce28f4b4a08163d39e6a4f2578 Mon Sep 17 00:00:00 2001 From: reger Date: Sun, 6 Aug 2017 23:26:27 +0200 Subject: [PATCH] Replace deprecated ConcurrentHashSet with recommended Java8 ConcurrentHashMap.newKeySet() in postprocessDocuments() --- source/net/yacy/search/schema/CollectionConfiguration.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/source/net/yacy/search/schema/CollectionConfiguration.java b/source/net/yacy/search/schema/CollectionConfiguration.java index c2cad79f1..5d39c5fb4 100644 --- a/source/net/yacy/search/schema/CollectionConfiguration.java +++ b/source/net/yacy/search/schema/CollectionConfiguration.java @@ -54,7 +54,6 @@ import org.apache.solr.common.SolrDocumentList; import org.apache.solr.common.SolrException; import org.apache.solr.common.SolrInputDocument; import org.apache.solr.common.SolrInputField; -import org.eclipse.jetty.util.ConcurrentHashSet; import net.yacy.cora.document.analysis.Classification; import net.yacy.cora.document.analysis.Classification.ContentDomain; @@ -1323,11 +1322,11 @@ public class CollectionConfiguration extends SchemaConfiguration implements Seri final CollectionConfiguration collection, final String collection1query, final Map rankings, final AtomicInteger allcount) { final Map hostExtentCache = new HashMap(); // a mapping from the host id to the number of documents which contain this host-id - final Set uniqueURLs = new ConcurrentHashSet(); // will be used in a concurrent environment + final Set uniqueURLs = ConcurrentHashMap.newKeySet(); // will be used in a concurrent environment final Set localOmitFields = new HashSet(); localOmitFields.add(CollectionSchema.process_sxt.getSolrFieldName()); localOmitFields.add(CollectionSchema.harvestkey_s.getSolrFieldName()); - final Collection failids = new ConcurrentHashSet(); + final Collection failids = ConcurrentHashMap.newKeySet(); final AtomicInteger countcheck = new AtomicInteger(0); final AtomicInteger proccount = new AtomicInteger(); final AtomicInteger proccount_referencechange = new AtomicInteger();