org.infinispan.query.impl.massindex

Class IndexingReducer

java.lang.Object

org.infinispan.query.impl.massindex.IndexingReducer

All Implemented Interfaces:

Serializable, Reducer<Object,org.hibernate.search.backend.LuceneWork>

public final class IndexingReducer
extends Object
implements Reducer<Object,org.hibernate.search.backend.LuceneWork>

This Reduce doesn't really index the entries but forwards them to the appropriate index master; the backend knows how to deal with sharding and this way we avoid unnecessary round trips.

Author:

Sanne Grinovero (C) 2012 Red Hat Inc.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
IndexingReducer()

Method Summary

Methods

Modifier and Type	Method and Description
void	flush() Since indexing work is done asynchronously in the backend, we need to flush at the end to make sure we don't return control to user before all work was processed and flushed.
void	initialize(Cache<?,?> inputCache)
org.hibernate.search.backend.LuceneWork	reduce(Object reducedKey, Iterator<org.hibernate.search.backend.LuceneWork> iter) Combines/reduces all intermediate values for a particular intermediate key to a single value.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IndexingReducer

public IndexingReducer()

Method Detail

initialize

public void initialize(Cache<?,?> inputCache)

reduce

public org.hibernate.search.backend.LuceneWork reduce(Object reducedKey,
                                             Iterator<org.hibernate.search.backend.LuceneWork> iter)

Description copied from interface: Reducer

Combines/reduces all intermediate values for a particular intermediate key to a single value.

Specified by:

reduce in interface Reducer<Object,org.hibernate.search.backend.LuceneWork>

flush

public void flush()

Since indexing work is done asynchronously in the backend, we need to flush at the end to make sure we don't return control to user before all work was processed and flushed.