org.apache.solr.handler.dataimport
Class DocBuilder

java.lang.Object
  org.apache.solr.handler.dataimport.DocBuilder

public class DocBuilder
extends Object

DocBuilder is responsible for creating Solr documents out of the given configuration. It also maintains statistics information. It depends on the EntityProcessor implementations to fetch data.

This API is experimental and subject to change

Since:

solr 1.3

Nested Class Summary

static class

DocBuilder.Statistics

Field Summary

DocBuilder.Statistics	importStatistics
static String	INDEX_START_TIME
static String	LAST_INDEX_TIME
static String	TIME_ELAPSED

Constructor Summary

DocBuilder(DataImporter dataImporter, SolrWriter solrWriter, DIHProperties propWriter, RequestInfo reqParams)

Method Summary

void	abort()
void	addStatusMessage(String msg)
Set<Map<String,Object>>	collectDelta(EntityProcessorWrapper epw, VariableResolver resolver, Set<Map<String,Object>> deletedRows) Collects unique keys of all Solr documents for whom one or more source tables have been changed since the last indexed time.
void	execute()
RequestInfo	getReqParams()

Methods inherited from class java.lang.Object

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

Field Detail

importStatistics

public DocBuilder.Statistics importStatistics

TIME_ELAPSED

public static final String TIME_ELAPSED

See Also:

Constant Field Values

LAST_INDEX_TIME

public static final String LAST_INDEX_TIME

See Also:

Constant Field Values

INDEX_START_TIME

public static final String INDEX_START_TIME

See Also:

Constant Field Values

Constructor Detail

DocBuilder

public DocBuilder(DataImporter dataImporter,
                  SolrWriter solrWriter,
                  DIHProperties propWriter,
                  RequestInfo reqParams)

Method Detail

execute

public void execute()

addStatusMessage

public void addStatusMessage(String msg)

collectDelta

public Set<Map<String,Object>> collectDelta(EntityProcessorWrapper epw,
                                            VariableResolver resolver,
                                            Set<Map<String,Object>> deletedRows)

Collects unique keys of all Solr documents for whom one or more source tables have been changed since the last indexed time.

Note: In our definition, unique key of Solr document is the primary key of the top level entity (unless skipped using docRoot=false) in the Solr document in data-config.xml

Returns:

an iterator to the list of keys for which Solr documents should be updated.

abort

public void abort()

getReqParams

public RequestInfo getReqParams()