blob: cfca4be1dc419c6065bc034b41af3c3cb554a881 [file] [log] [blame]
using Lucene.Net.Index;
using Lucene.Net.Queries.Function;
using Lucene.Net.Util.Mutable;
using System.Collections;
using System.IO;
namespace Lucene.Net.Search.Grouping.Function
{
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/// <summary>
/// Concrete implementation of <see cref="AbstractFirstPassGroupingCollector{TGroupValue}"/> that groups based on
/// <see cref="ValueSource"/> instances.
///
/// @lucene.experimental
/// </summary>
public class FunctionFirstPassGroupingCollector : AbstractFirstPassGroupingCollector<MutableValue>
{
private readonly ValueSource groupByVS;
private readonly IDictionary /* Map<?, ?> */ vsContext;
private FunctionValues.ValueFiller filler;
private MutableValue mval;
/// <summary>
/// Creates a first pass collector.
/// </summary>
/// <param name="groupByVS">The <see cref="ValueSource"/> instance to group by</param>
/// <param name="vsContext">The <see cref="ValueSource"/> context</param>
/// <param name="groupSort">
/// The <see cref="Sort"/> used to sort the
/// groups. The top sorted document within each group
/// according to groupSort, determines how that group
/// sorts against other groups. This must be non-null,
/// ie, if you want to groupSort by relevance use
/// <see cref="Sort.RELEVANCE"/>.
/// </param>
/// <param name="topNGroups">How many top groups to keep.</param>
/// <exception cref="IOException">When I/O related errors occur</exception>
public FunctionFirstPassGroupingCollector(ValueSource groupByVS, IDictionary /* Map<?, ?> */ vsContext, Sort groupSort, int topNGroups)
: base(groupSort, topNGroups)
{
this.groupByVS = groupByVS;
this.vsContext = vsContext;
}
protected override MutableValue GetDocGroupValue(int doc)
{
filler.FillValue(doc);
return mval;
}
protected override MutableValue CopyDocGroupValue(MutableValue groupValue, MutableValue reuse)
{
if (reuse != null)
{
reuse.Copy(groupValue);
return reuse;
}
return groupValue.Duplicate();
}
public override void SetNextReader(AtomicReaderContext context)
{
base.SetNextReader(context);
FunctionValues values = groupByVS.GetValues(vsContext, context);
filler = values.GetValueFiller();
mval = filler.Value;
}
}
}