SMILA (incubation) API documentation

org.eclipse.smila.integration.solr
Class SolrSearchPipelet

java.lang.Object
  extended by org.eclipse.smila.integration.solr.SolrSearchPipelet
All Implemented Interfaces:
Pipelet

public class SolrSearchPipelet
extends java.lang.Object
implements Pipelet

This pipelet integrates the Apache Solr's REST API and is designed to be used both in processing and in search pipelines.


Field Summary
static java.lang.String UTF8
           
 
Constructor Summary
SolrSearchPipelet()
           
 
Method Summary
 void configure(AnyMap config)
          set configuration of pipelet.
 java.lang.String getShards()
           
 java.lang.String[] process(Blackboard blackboard, java.lang.String[] message)
          process records on Blackboard service.
 void setShards(java.lang.String shards)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

UTF8

public static final java.lang.String UTF8
See Also:
Constant Field Values
Constructor Detail

SolrSearchPipelet

public SolrSearchPipelet()
Method Detail

process

public java.lang.String[] process(Blackboard blackboard,
                                  java.lang.String[] message)
                           throws ProcessingException
Description copied from interface: Pipelet
process records on Blackboard service.

Specified by:
process in interface Pipelet
Parameters:
blackboard - Blackboard service managing the records.
message - Ids of records to process.
Returns:
Ids of result records. By default this should be the same as the passed in recordIds unless there is a specific reason not to do so. This is especially true for SearchPiplets.
Throws:
ProcessingException - error during processing.

configure

public void configure(AnyMap config)
               throws ProcessingException
Description copied from interface: Pipelet
set configuration of pipelet. called once after instantiation before the pipelet is actually used in a workflow.

Specified by:
configure in interface Pipelet
Parameters:
config - configuration of pipelet.
Throws:
ProcessingException - configuration is not applicable for pipelet (missing properties, wrong datatypes)

setShards

public void setShards(java.lang.String shards)

getShards

public java.lang.String getShards()

SMILA (incubation) API documentation