Merge branch 'facet-threads' of [email protected]:ny6asik/SolrNet.git

stantoxt · Sep 19, 2014 · 3491b9f · 3491b9f
2 parents d917153 + 12eb1c8
commit 3491b9f
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 0 deletions.
diff --git a/SolrNet.Tests/SolrQueryExecuterTests.cs b/SolrNet.Tests/SolrQueryExecuterTests.cs
@@ -622,6 +622,7 @@ public void FacetFieldOptions() {
                     Missing = true,
                     Offset = 55,
                     Sort = true,
+                    Threads = 5
                 }).ToDictionary(x => x.Key, x => x.Value);
             Assert.AreEqual("pref", facetOptions["facet.prefix"]);
             Assert.AreEqual("123", facetOptions["facet.enum.cache.minDf"]);
@@ -630,6 +631,7 @@ public void FacetFieldOptions() {
             Assert.AreEqual("true", facetOptions["facet.missing"]);
             Assert.AreEqual("55", facetOptions["facet.offset"]);
             Assert.AreEqual("true", facetOptions["facet.sort"]);
+            Assert.AreEqual("5", facetOptions["facet.threads"]);
         }
 
         [Test]

diff --git a/SolrNet/Commands/Parameters/FacetParameters.cs b/SolrNet/Commands/Parameters/FacetParameters.cs
@@ -73,6 +73,11 @@ public class FacetParameters {
         /// </summary>
         public int? EnumCacheMinDf { get; set; }
 
+        /// <summary>
+        /// Indicate number of threads to spawn when calculating facets, 
+        /// </summary>
+        public int? Threads { get; set; }
+
         /// <summary>
         /// Faceting parameters
         /// </summary>

diff --git a/SolrNet/Impl/SolrQueryExecuter.cs b/SolrNet/Impl/SolrQueryExecuter.cs
@@ -221,6 +221,8 @@ public IEnumerable<KeyValuePair<string, string>> GetFacetFieldOptions(FacetParam
                 yield return KV.Create("facet.offset", fp.Offset.ToString());
             if (fp.Sort.HasValue)
                 yield return KV.Create("facet.sort", fp.Sort.ToString().ToLowerInvariant());
+            if (fp.Threads.HasValue)
+                yield return KV.Create("facet.threads", fp.Threads.ToString().ToLowerInvariant());
         }
 
         /// <summary>