org.xbib.elasticsearch.river.jdbc.strategy.mock

Class MockRiverMouth

java.lang.Object

org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

All Implemented Interfaces:

RiverMouth<MockRiverContext>

public class MockRiverMouth
extends Object
implements RiverMouth<MockRiverContext>

Constructor Summary

Constructors

Constructor and Description
MockRiverMouth()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterFetch()
void	beforeFetch()
Map<IndexableObject,String>	data()
void	delete(IndexableObject object)
void	flush()
long	getCounter()
String	getId()
String	getIndex()
Metric	getMetric()
String	getType()
void	index(IndexableObject object, boolean create)
RiverMouth<MockRiverContext>	newInstance()
void	resume()
RiverMouth	setId(String id)
RiverMouth	setIndex(String index)
RiverMouth	setIndexSettings(org.elasticsearch.common.settings.Settings indexSettings)
RiverMouth	setIngestFactory(IngestFactory ingestFactory)
MockRiverMouth	setRiverContext(MockRiverContext context)
RiverMouth	setType(String type)
RiverMouth	setTypeMapping(Map<String,String> typeMapping)
void	shutdown()
String	strategy()
void	suspend()

Methods inherited from class java.lang.Object

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

Constructor Detail

MockRiverMouth

public MockRiverMouth()

Method Detail

strategy

public String strategy()

Specified by:

strategy in interface RiverMouth<MockRiverContext>

newInstance

public RiverMouth<MockRiverContext> newInstance()

Specified by:

newInstance in interface RiverMouth<MockRiverContext>

beforeFetch

public void beforeFetch()
                 throws Exception

Specified by:

beforeFetch in interface RiverMouth<MockRiverContext>

Throws:

Exception

afterFetch

public void afterFetch()
                throws Exception

Specified by:

afterFetch in interface RiverMouth<MockRiverContext>

Throws:

Exception

index

public void index(IndexableObject object,
         boolean create)
           throws IOException

Specified by:

index in interface RiverMouth<MockRiverContext>

Throws:

IOException

delete

public void delete(IndexableObject object)
            throws IOException

Specified by:

delete in interface RiverMouth<MockRiverContext>

Throws:

IOException

data

public Map<IndexableObject,String> data()

setRiverContext

public MockRiverMouth setRiverContext(MockRiverContext context)

Specified by:

setRiverContext in interface RiverMouth<MockRiverContext>

setIngestFactory

public RiverMouth setIngestFactory(IngestFactory ingestFactory)

Specified by:

setIngestFactory in interface RiverMouth<MockRiverContext>

setIndex

public RiverMouth setIndex(String index)

Specified by:

setIndex in interface RiverMouth<MockRiverContext>

getIndex

public String getIndex()

Specified by:

getIndex in interface RiverMouth<MockRiverContext>

setIndexSettings

public RiverMouth setIndexSettings(org.elasticsearch.common.settings.Settings indexSettings)

Specified by:

setIndexSettings in interface RiverMouth<MockRiverContext>

setTypeMapping

public RiverMouth setTypeMapping(Map<String,String> typeMapping)

Specified by:

setTypeMapping in interface RiverMouth<MockRiverContext>

setType

public RiverMouth setType(String type)

Specified by:

setType in interface RiverMouth<MockRiverContext>

getType

public String getType()

Specified by:

getType in interface RiverMouth<MockRiverContext>

setId

public RiverMouth setId(String id)

Specified by:

setId in interface RiverMouth<MockRiverContext>

getId

public String getId()

Specified by:

getId in interface RiverMouth<MockRiverContext>

flush

public void flush()
           throws IOException

Specified by:

flush in interface RiverMouth<MockRiverContext>

Throws:

IOException

shutdown

public void shutdown()
              throws IOException

Specified by:

shutdown in interface RiverMouth<MockRiverContext>

Throws:

IOException

suspend

public void suspend()
             throws Exception

Specified by:

suspend in interface RiverMouth<MockRiverContext>

Throws:

Exception

resume

public void resume()
            throws Exception

Specified by:

resume in interface RiverMouth<MockRiverContext>

Throws:

Exception

getMetric

public Metric getMetric()

Specified by:

getMetric in interface RiverMouth<MockRiverContext>

getCounter

public long getCounter()