org.apache.nutch.indexwriter.elastic

Class ElasticIndexWriter

java.lang.Object

org.apache.nutch.indexwriter.elastic.ElasticIndexWriter

All Implemented Interfaces:

Configurable, IndexWriter, Pluggable

public class ElasticIndexWriter
extends java.lang.Object
implements IndexWriter

Sends NutchDocuments to a configured Elasticsearch index.

Field Summary

Fields inherited from interface org.apache.nutch.indexer.IndexWriter

X_POINT_ID

Constructor Summary

Constructors

Constructor and Description
ElasticIndexWriter()

Method Summary

Modifier and Type	Method and Description
protected BulkProcessor.Listener	bulkProcessorListener() Generates a default BulkProcessor.Listener
void	close()
void	commit()
void	delete(java.lang.String key)
java.lang.String	describe() Returns a String describing the IndexWriter instance and the specific parameters it can take
Configuration	getConf()
protected Client	makeClient(Configuration conf) Generates a TransportClient or NodeClient
void	open(JobConf job, java.lang.String name)
void	setConf(Configuration conf)
void	update(NutchDocument doc)
void	write(NutchDocument doc)

Methods inherited from class java.lang.Object

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

Constructor Detail

ElasticIndexWriter

public ElasticIndexWriter()

Method Detail

open

public void open(JobConf job,
                 java.lang.String name)
          throws java.io.IOException

Specified by:

open in interface IndexWriter

Throws:

java.io.IOException

makeClient

protected Client makeClient(Configuration conf)
                     throws java.io.IOException

Generates a TransportClient or NodeClient

Throws:

java.io.IOException

bulkProcessorListener

protected BulkProcessor.Listener bulkProcessorListener()

Generates a default BulkProcessor.Listener

write

public void write(NutchDocument doc)
           throws java.io.IOException

Specified by:

write in interface IndexWriter

Throws:

java.io.IOException

delete

public void delete(java.lang.String key)
            throws java.io.IOException

Specified by:

delete in interface IndexWriter

Throws:

java.io.IOException

update

public void update(NutchDocument doc)
            throws java.io.IOException

Specified by:

update in interface IndexWriter

Throws:

java.io.IOException

commit

public void commit()
            throws java.io.IOException

Specified by:

commit in interface IndexWriter

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface IndexWriter

Throws:

java.io.IOException

describe

public java.lang.String describe()

Description copied from interface: IndexWriter

Returns a String describing the IndexWriter instance and the specific parameters it can take

Specified by:

describe in interface IndexWriter

setConf

public void setConf(Configuration conf)

Specified by:

setConf in interface Configurable

getConf

public Configuration getConf()

Specified by:

getConf in interface Configurable