org.xbib.elasticsearch.plugin.jdbc.feeder

Class JDBCFeeder

java.lang.Object

org.xbib.elasticsearch.plugin.jdbc.feeder.JDBCFeeder

All Implemented Interfaces:

CommandLineInterpreter

public class JDBCFeeder
extends Object
implements CommandLineInterpreter

Standalone feeder for JDBC

Field Summary

Fields

Modifier and Type	Field and Description
protected IngestFactory	ingestFactory
protected PrintStream	printStream
protected Reader	reader
protected Writer	writer

Constructor Summary

Constructors

Constructor and Description
JDBCFeeder() Constructor for running this from command line

Method Summary

Methods

Modifier and Type	Method and Description
protected RiverFlow	createRiverFlow(Map<String,Object> spec, org.elasticsearch.common.settings.Settings settings)
JDBCFeeder	errorsTo(PrintStream printStream)
JDBCFeeder	readFrom(Reader reader)
void	shutdown()
Thread	shutdownHook() Shut down feeder instance by Ctrl-C
JDBCFeeder	start()
JDBCFeeder	writeTo(Writer writer)

Methods inherited from class java.lang.Object

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

Field Detail

reader

protected Reader reader

writer

protected Writer writer

printStream

protected PrintStream printStream

ingestFactory

protected IngestFactory ingestFactory

Constructor Detail

JDBCFeeder

public JDBCFeeder()

Constructor for running this from command line

Method Detail

readFrom

public JDBCFeeder readFrom(Reader reader)

Specified by:

readFrom in interface CommandLineInterpreter

createRiverFlow

protected RiverFlow createRiverFlow(Map<String,Object> spec,
                        org.elasticsearch.common.settings.Settings settings)
                             throws IOException

Throws:

IOException

writeTo

public JDBCFeeder writeTo(Writer writer)

Specified by:

writeTo in interface CommandLineInterpreter

errorsTo

public JDBCFeeder errorsTo(PrintStream printStream)

Specified by:

errorsTo in interface CommandLineInterpreter

start

public JDBCFeeder start()
                 throws Exception

Specified by:

start in interface CommandLineInterpreter

Throws:

Exception

shutdownHook

public Thread shutdownHook()

Shut down feeder instance by Ctrl-C

Specified by:

shutdownHook in interface CommandLineInterpreter

Returns:

shutdown thread

shutdown

public void shutdown()
              throws Exception

Specified by:

shutdown in interface CommandLineInterpreter

Throws:

Exception